bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.stages

Package-level declarations

Types

Link copied to clipboard
class AggregateStage(val store: AggregateStore)
Link copied to clipboard
@Named(value = "flush")
@Singleton
class FlushStage : DataFlowStage
Link copied to clipboard
@Named(value = "parse")
@Singleton
class ParseStage(jsonConverter: JsonConverter, protobufConverter: ProtobufConverter) : DataFlowStage
Link copied to clipboard
@Named(value = "state")
@Singleton
class StateStage(stateHistogramStore: StateHistogramStore, statsStore: CommittedStatsStore) : DataFlowStage