Interface ETLBulkStream

All Superinterfaces:
AutoCloseable, Closeable, EventStream, Iterable<Event>
All Known Subinterfaces:
ETLParquetFilesStream, ETLPBByteStream
All Known Implementing Classes:
FileBackedPBEventStream, ParquetBackedPBEventFileStream

public interface ETLBulkStream extends EventStream
Event streams can optionally implement bulk transfer friendly methods. If this interface is implemented, then ETL code will use bulk transfers whan moving data.
Author:
mshankar
  • Method Details

    • getFirstEvent

      Event getFirstEvent(BasicContext context) throws IOException
      Get the first event in this event stream. If there are no events in this stream, return null.
      Parameters:
      context - BasicContext
      Returns:
      Event return the first event, or null
      Throws:
      IOException -