SqlSink |
SqlSink.withDisableMetricsCollection(Object disableMetricsCollection) |
Set the disableMetricsCollection property: If true, disable data store metrics collection.
|
SqlSink |
SqlSink.withMaxConcurrentConnections(Object maxConcurrentConnections) |
Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store.
|
SqlSink |
SqlSink.withPreCopyScript(Object preCopyScript) |
Set the preCopyScript property: SQL pre-copy script.
|
SqlSink |
SqlSink.withSinkRetryCount(Object sinkRetryCount) |
Set the sinkRetryCount property: Sink retry count.
|
SqlSink |
SqlSink.withSinkRetryWait(Object sinkRetryWait) |
Set the sinkRetryWait property: Sink retry wait.
|
SqlSink |
SqlSink.withSqlWriterStoredProcedureName(Object sqlWriterStoredProcedureName) |
Set the sqlWriterStoredProcedureName property: SQL writer stored procedure name.
|
SqlSink |
SqlSink.withSqlWriterTableType(Object sqlWriterTableType) |
Set the sqlWriterTableType property: SQL writer table type.
|
SqlSink |
SqlSink.withSqlWriterUseTableLock(Object sqlWriterUseTableLock) |
Set the sqlWriterUseTableLock property: Whether to use table lock during bulk copy.
|
SqlSink |
SqlSink.withStoredProcedureParameters(Map<String,StoredProcedureParameter> storedProcedureParameters) |
Set the storedProcedureParameters property: SQL stored procedure parameters.
|
SqlSink |
SqlSink.withStoredProcedureTableTypeParameterName(Object storedProcedureTableTypeParameterName) |
Set the storedProcedureTableTypeParameterName property: The stored procedure parameter name of the table type.
|
SqlSink |
SqlSink.withTableOption(Object tableOption) |
Set the tableOption property: The option to handle sink table, such as autoCreate.
|
SqlSink |
SqlSink.withUpsertSettings(SqlUpsertSettings upsertSettings) |
Set the upsertSettings property: SQL upsert settings.
|
SqlSink |
SqlSink.withWriteBatchSize(Object writeBatchSize) |
Set the writeBatchSize property: Write batch size.
|
SqlSink |
SqlSink.withWriteBatchTimeout(Object writeBatchTimeout) |
Set the writeBatchTimeout property: Write batch timeout.
|
SqlSink |
SqlSink.withWriteBehavior(Object writeBehavior) |
Set the writeBehavior property: Write behavior when copying data into sql.
|