Airbyte Kotlin Bulk CDK
Toggle table of contents
0.1.92
jvm
Platform filter
jvm
Switch theme
Search in API
Airbyte Kotlin Bulk CDK
bulk-cdk-core-load
/
io.airbyte.cdk.load.dataflow.input
/
DataFlowPipelineInputFlow
/
DataFlowPipelineInputFlow
Data
Flow
Pipeline
Input
Flow
constructor
(
inputFlow
:
Flow
<
DestinationMessage
>
,
stateStore
:
StateStore
,
stateKeyClient
:
StateKeyClient
,
completionTracker
:
StreamCompletionTracker
,
statsStore
:
EmittedStatsStore
)