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

Package-level declarations

Types

Link copied to clipboard
@Factory
class DefaultConfigBeanFactory
Link copied to clipboard
@Factory
class DispatcherBeanFactory(lifeCycleConfig: LifecycleParallelismConfig)

The dispatchers (think views of thread pools) and static scopes we use for dataflow.

Link copied to clipboard
@Factory
class InputBeanFactory

Conditionally creates input streams / sockets based on channel medium, then wires up a pipeline to each input with separate aggregate stores but shared state stores.