Package | Description |
---|---|
org.apache.flink.api.java.io | |
org.apache.flink.api.scala.operators | |
org.apache.flink.connector.jdbc | |
org.apache.flink.connector.jdbc.internal | |
org.apache.flink.connector.jdbc.xa |
Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
|
org.apache.flink.streaming.api.functions.sink |
Modifier and Type | Class and Description |
---|---|
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
class |
LocalCollectionOutputFormat<T>
An output format that adds records to a collection.
|
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCsvOutputFormat<T extends scala.Product>
This is an OutputFormat to serialize Scala Tuples to text.
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcRowOutputFormat
OutputFormat to write Rows into a JDBC database.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericJdbcSinkFunction<T>
A generic SinkFunction for JDBC.
|
class |
JdbcOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>>
A JDBC outputFormat that supports batching records before writing records to database.
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcXaSinkFunction<T>
JDBC sink function that uses XA transactions to provide exactly once guarantees.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputFormatSinkFunction<IN>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.