Airbyte Kotlin Bulk CDK

0.1.92

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

Package-level declarations

Types

DataChannelBeanFactory

@Factory

class DataChannelBeanFactory

Responsible for all wiring that depends directly on the data channel medium.

DataChannelFormat

enum DataChannelFormat : Enum<DataChannelFormat>

DataChannelMedium

enum DataChannelMedium : Enum<DataChannelMedium>

NamespaceDefinitionType

enum NamespaceDefinitionType : Enum<NamespaceDefinitionType>

NamespaceMappingConfig

data class NamespaceMappingConfig(val namespaceDefinitionType: NamespaceDefinitionType, val namespaceFormat: String? = null, val streamPrefix: String? = null)

PipelineInputEvent

typealias PipelineInputEvent = PipelineEvent<StreamKey, DestinationRecordRaw>

SyncBeanFactory

@Factory

class SyncBeanFactory

Factory for instantiating beans necessary for the sync process.

Properties

CHECK_STREAM_NAMESPACE

const val CHECK_STREAM_NAMESPACE: String