Class LogRecorder

  • All Implemented Interfaces:
    AutoCloseable

    public final class LogRecorder
    extends Object
    implements AutoCloseable
    This class opens a TCP socket and dumps everything to STDOUT. It is used for printing logs from the UDF.
    • Constructor Detail

      • LogRecorder

        public LogRecorder​(Consumer<Path> logFileHandler)
        Create a new instance of LogRecorder.
        Parameters:
        logFileHandler - callback to notify when a new log file is created
    • Method Detail

      • getPort

        public int getPort()
        Get the port the log recorder listens on.
        Returns:
        port number