B C E F G J N O P R S W

B

build() - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Finalizes the configuration and checks validity.

builder() - Static method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

buildJDBCInputFormat() - Static method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

A builder used to set parameters to the output format's configuration in a fluent way.

buildJDBCOutputFormat() - Static method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

C

close() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

Closes all resources used.

close() - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

Executes prepared statement and closes all resources of this instance.

closeInputFormat() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

configure(String[], TypeInformation<?>[]) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

configure(Configuration) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

configure(Configuration) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

createInputSplits(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

E

emitDataSet(DataSet<Row>) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

emitDataStream(DataStream<Row>) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

F

finish() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

finish() - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

Finalizes the configuration and checks validity.

G

GenericParameterValuesProvider - Class in org.apache.flink.api.java.io.jdbc.split

This splits generator actually does nothing but wrapping the query parameters computed by the user before creating the JDBCInputFormat instance.

GenericParameterValuesProvider(Serializable[][]) - Constructor for class org.apache.flink.api.java.io.jdbc.split.GenericParameterValuesProvider

getFieldNames() - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

getFieldTypes() - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

getInputSplitAssigner(InputSplit[]) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

getOutputType() - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink

getParameterValues() - Method in class org.apache.flink.api.java.io.jdbc.split.GenericParameterValuesProvider

getParameterValues() - Method in class org.apache.flink.api.java.io.jdbc.split.NumericBetweenParametersProvider

getParameterValues() - Method in interface org.apache.flink.api.java.io.jdbc.split.ParameterValuesProvider

Returns the necessary parameters array to use for query in parallel a table.

getProducedType() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

getStatistics(BaseStatistics) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

J

JDBCAppendTableSink - Class in org.apache.flink.api.java.io.jdbc

An at-least-once Table sink for JDBC.

JDBCAppendTableSinkBuilder - Class in org.apache.flink.api.java.io.jdbc

A builder to configure and build the JDBCAppendTableSink.

JDBCAppendTableSinkBuilder() - Constructor for class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

JDBCInputFormat - Class in org.apache.flink.api.java.io.jdbc

InputFormat to read data from a database and generate Rows.

JDBCInputFormat() - Constructor for class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

JDBCInputFormat.JDBCInputFormatBuilder - Class in org.apache.flink.api.java.io.jdbc

Builder for a JDBCInputFormat.

JDBCInputFormatBuilder() - Constructor for class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

JDBCOutputFormat - Class in org.apache.flink.api.java.io.jdbc

OutputFormat to write Rows into a JDBC database.

JDBCOutputFormat() - Constructor for class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

JDBCOutputFormat.JDBCOutputFormatBuilder - Class in org.apache.flink.api.java.io.jdbc

Builder for a JDBCOutputFormat.

JDBCOutputFormatBuilder() - Constructor for class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

N

nextRecord(Row) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

Stores the next resultSet row in a tuple.

NumericBetweenParametersProvider - Class in org.apache.flink.api.java.io.jdbc.split

This query parameters generator is an helper class to parameterize from/to queries on a numeric column.

NumericBetweenParametersProvider(long, long, long) - Constructor for class org.apache.flink.api.java.io.jdbc.split.NumericBetweenParametersProvider

NumericBetweenParametersProvider constructor.

O

open(InputSplit) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

Connects to the source database and executes the query in a parallel fashion if this InputFormat is built using a parameterized query (i.e.

open(int, int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

Connects to the target database and initializes the prepared statement.

openInputFormat() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

org.apache.flink.api.java.io.jdbc - package org.apache.flink.api.java.io.jdbc

org.apache.flink.api.java.io.jdbc.split - package org.apache.flink.api.java.io.jdbc.split

P

ParameterValuesProvider - Interface in org.apache.flink.api.java.io.jdbc.split

This interface is used by the JDBCInputFormat to compute the list of parallel query to run (i.e.

R

reachedEnd() - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat

Checks whether all data has been read.

S

setBatchInterval(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setBatchSize(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the size of the batch.

setDBUrl(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the URL of the JDBC database.

setDBUrl(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setDBUrl(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setDrivername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the name of the JDBC driver that will be used.

setDrivername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setDrivername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setFetchSize(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setParametersProvider(ParameterValuesProvider) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setParameterTypes(TypeInformation<?>...) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the type of the rows that the sink will be accepting.

setParameterTypes(int...) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the type of the rows that the sink will be accepting.

setPassword(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the password of the JDBC connection.

setPassword(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setPassword(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setQuery(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the query that the sink will execute.

setQuery(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setQuery(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setResultSetConcurrency(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setResultSetType(int) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setRowTypeInfo(RowTypeInfo) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setSqlTypes(int[]) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

setUsername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCAppendTableSinkBuilder

Specify the username of the JDBC connection.

setUsername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCInputFormat.JDBCInputFormatBuilder

setUsername(String) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat.JDBCOutputFormatBuilder

W

writeRecord(Row) - Method in class org.apache.flink.api.java.io.jdbc.JDBCOutputFormat

Adds a record to the prepared statement.

B C E F G J N O P R S W