DirectLoadTableAppendStreamLoader
class DirectLoadTableAppendStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader
Stream loader implementation for append mode.
This loader handles the simplest case of appending data to an existing target table. If a temporary table exists, it copies its data to the real table then drops the temp table. All processing writes directly to the real table, without any deduplication.
Constructors
Link copied to clipboard
constructor(stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>)