Package com.snowflake.connectors.taskreactor.worker.ingestion
Task reactor ingestion.
-
Interface Summary Interface Description Ingestion<STATE> Interface that should be implemented by users of task reactor and passed over toIngestionWorker
instance.SimpleIngestion<I,M,C,D> Interface that should be implemented by users of task reactor and passed over toIngestionWorker
instance. -
Class Summary Class Description IngestionWorker<T> A worker executing anIngestion
.SimpleIngestionWorker<I,M,D,C> A worker executing anSimpleIngestion
.SimpleIngestionWorkItem<I,M,C,D> A payload of a work item containing a data needed by a single simple ingestion task.