DirectLoadTableWriter
class DirectLoadTableWriter(internalNamespace: String, names: DestinationCatalog, stateGatherer: DatabaseInitialStatusGatherer<DirectLoadInitialStatus>, destinationHandler: DatabaseHandler, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator) : DestinationWriter
Parameters
directLoadTableTempTableNameMigration
Iff you are implementing a destination which previously existed, and used the T+D style of temporary tables (i.e. suffixing the final table with _airbyte_tmp), you MUST provide this object.
Constructors
Link copied to clipboard
constructor(internalNamespace: String, names: DestinationCatalog, stateGatherer: DatabaseInitialStatusGatherer<DirectLoadInitialStatus>, destinationHandler: DatabaseHandler, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator)