public static class JdbcUpsertTableSink.Builder extends Object
JdbcUpsertTableSink
.Modifier and Type | Field and Description |
---|---|
protected long |
flushIntervalMills |
protected int |
flushMaxSize |
protected int |
maxRetryTimes |
protected TableSchema |
schema |
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
JdbcUpsertTableSink |
build() |
JdbcUpsertTableSink.Builder |
setFlushIntervalMills(long flushIntervalMills)
optional, flush interval mills, over this time, asynchronous threads will flush data.
|
JdbcUpsertTableSink.Builder |
setFlushMaxSize(int flushMaxSize)
optional, flush max size (includes all append, upsert and delete records), over this
number of records, will flush data.
|
JdbcUpsertTableSink.Builder |
setMaxRetryTimes(int maxRetryTimes)
optional, max retry times for jdbc connector.
|
JdbcUpsertTableSink.Builder |
setOptions(JdbcConnectorOptions options)
required, jdbc options.
|
JdbcUpsertTableSink.Builder |
setTableSchema(TableSchema schema)
required, table schema of this table source.
|
protected TableSchema schema
protected int flushMaxSize
protected long flushIntervalMills
protected int maxRetryTimes
public JdbcUpsertTableSink.Builder setTableSchema(TableSchema schema)
public JdbcUpsertTableSink.Builder setOptions(JdbcConnectorOptions options)
public JdbcUpsertTableSink.Builder setFlushMaxSize(int flushMaxSize)
public JdbcUpsertTableSink.Builder setFlushIntervalMills(long flushIntervalMills)
public JdbcUpsertTableSink.Builder setMaxRetryTimes(int maxRetryTimes)
public JdbcUpsertTableSink build()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.