Package com.illumon.iris.db.tables.dataimport.logtailer

Class ImportStatePartitionIndex<KEY_TYPE>

java.lang.Object
com.illumon.iris.db.tables.dataimport.importstate.TupleKeyedAbstractImportState<KEY_TYPE>
com.illumon.iris.db.tables.dataimport.logtailer.ImportStatePartitionIndex<KEY_TYPE>
All Implemented Interfaces:
ImportState, Externalizable, Serializable
public class ImportStatePartitionIndex<KEY_TYPE> extends TupleKeyedAbstractImportState<KEY_TYPE> implements Externalizable
See Also:

  • Constructor Details

    • ImportStatePartitionIndex

      public ImportStatePartitionIndex()

    • ImportStatePartitionIndex

      public ImportStatePartitionIndex(ImportStateRowCounter isrc)

  • Method Details

    • onRelease

      public void onRelease()
      Description copied from interface: ImportState
      Call when the data ingestion process for the location observed by this ImportState is finished, temporarily or permanently, in an inconsistent state.
      Specified by:
      onRelease in interface ImportState

    • onClose

      public void onClose()
      Description copied from interface: ImportState
      Called when the data ingestion process for the location observed by this ImportState is finished, temporarily or permanently, in a consistent state.
      Specified by:
      onClose in interface ImportState

    • onResume

      public void onResume(@NotNull FullTableLocationKey locationKey)
      Description copied from interface: ImportState
      Called when data ingestion is resumed for the location observed by this ImportState.
      Specified by:
      onResume in interface ImportState
      Parameters:
      locationKey - The full table location key of the location that has been resumed

    • ensureInitialized

      public void ensureInitialized(@NotNull FullTableLocationKey locationKey)
      Description copied from interface: ImportState
      Called when non-import code needs to ensure that an ImportState's internals have been initialized because of their side effects. Must not interfere with concurrent data ingestion in the same process. Generally should be treated as a query operation, and the caller should hold the LiveTableMonitor lock.
      Specified by:
      ensureInitialized in interface ImportState
      Parameters:
      locationKey - The full table location key of the location whose ImportState is being initialized

    • newRowForKey

      public final void newRowForKey(KEY_TYPE key)
      Description copied from class: TupleKeyedAbstractImportState
      subclasses must implement this callback, we forward all keys through it.
      Specified by:
      newRowForKey in class TupleKeyedAbstractImportState<KEY_TYPE>
      Parameters:
      key - immutable key object containing the parameters passed to newRow from listener/importer.

    • getImportDetails

      @NotNull public Properties getImportDetails()
      Specified by:
      getImportDetails in interface ImportState

    • writeExternal

      public void writeExternal(ObjectOutput out) throws IOException
      Specified by:
      writeExternal in interface Externalizable
      Throws:
      IOException

    • readExternal

      public void readExternal(ObjectInput in) throws IOException
      Specified by:
      readExternal in interface Externalizable
      Throws:
      IOException