@Experimental public class JdbcOutputFormat extends JdbcBatchingOutputFormat<Row,Row,JdbcBatchStatementExecutor<Row>>
Modifier and Type | Class and Description |
---|---|
static class |
JdbcOutputFormat.JdbcOutputFormatBuilder
Builder for
JdbcOutputFormat . |
JdbcBatchingOutputFormat.Builder, JdbcBatchingOutputFormat.RecordExtractor<F,T>, JdbcBatchingOutputFormat.StatementExecutorFactory<T extends JdbcBatchStatementExecutor<?>>
connectionProvider, DEFAULT_FLUSH_INTERVAL_MILLS, DEFAULT_FLUSH_MAX_SIZE
Modifier and Type | Method and Description |
---|---|
static JdbcOutputFormat.JdbcOutputFormatBuilder |
buildJdbcOutputFormat() |
addToBatch, attemptFlush, builder, close, flush, open, updateExecutor, writeRecord
configure, getConnection
getRuntimeContext, setRuntimeContext
public static JdbcOutputFormat.JdbcOutputFormatBuilder buildJdbcOutputFormat()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.