bulk-cdk-core-load/io.airbyte.cdk.load.command/DestinationStreamFactory

DestinationStreamFactory

@Singleton
class DestinationStreamFactory(jsonSchemaToAirbyteType: JsonSchemaToAirbyteType, namespaceMapper: NamespaceMapper, schemaFactory: TableSchemaFactory)

Constructors

Link copied to clipboard
constructor(jsonSchemaToAirbyteType: JsonSchemaToAirbyteType, namespaceMapper: NamespaceMapper, schemaFactory: TableSchemaFactory)

Functions

Link copied to clipboard
fun make(stream: ConfiguredAirbyteStream, resolvedTableName: TableName): DestinationStream