public abstract class UpsertWriter extends Object implements JDBCWriter
Modifier and Type | Method and Description |
---|---|
void |
addRecord(Tuple2<Boolean,Row> record)
Add record to writer, the writer may cache the data.
|
void |
close()
Close JDBC related statements and other classes.
|
static UpsertWriter |
create(JDBCDialect dialect,
String tableName,
String[] fieldNames,
int[] fieldTypes,
String[] keyFields,
boolean objectReuse) |
void |
executeBatch()
Submits a batch of commands to the database for execution.
|
void |
open(Connection connection)
Open the writer by JDBC Connection.
|
public static UpsertWriter create(JDBCDialect dialect, String tableName, String[] fieldNames, int[] fieldTypes, String[] keyFields, boolean objectReuse)
public void open(Connection connection) throws SQLException
JDBCWriter
open
in interface JDBCWriter
SQLException
public void addRecord(Tuple2<Boolean,Row> record) throws SQLException
JDBCWriter
addRecord
in interface JDBCWriter
SQLException
public void executeBatch() throws SQLException
JDBCWriter
executeBatch
in interface JDBCWriter
SQLException
public void close() throws SQLException
JDBCWriter
close
in interface JDBCWriter
SQLException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.