public interface JDBCWriter extends Serializable
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.
|
void |
executeBatch()
Submits a batch of commands to the database for execution.
|
void |
open(Connection connection)
Open the writer by JDBC Connection.
|
void open(Connection connection) throws SQLException
SQLException
void addRecord(Tuple2<Boolean,Row> record)
void executeBatch() throws SQLException
SQLException
void close() throws SQLException
SQLException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.