public class FlinkSink
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
FlinkSink.Builder |
Modifier and Type | Method and Description |
---|---|
static <T> FlinkSink.Builder |
builderFor(org.apache.flink.streaming.api.datastream.DataStream<T> input,
org.apache.flink.api.common.functions.MapFunction<T,org.apache.flink.table.data.RowData> mapper,
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> outputType)
Initialize a
FlinkSink.Builder to export the data from generic input data stream into iceberg
table. |
static FlinkSink.Builder |
forRow(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> input,
org.apache.flink.table.api.TableSchema tableSchema)
Initialize a
FlinkSink.Builder to export the data from input data stream with Row s into
iceberg table. |
static FlinkSink.Builder |
forRowData(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)
Initialize a
FlinkSink.Builder to export the data from input data stream with RowData s
into iceberg table. |
public static <T> FlinkSink.Builder builderFor(org.apache.flink.streaming.api.datastream.DataStream<T> input, org.apache.flink.api.common.functions.MapFunction<T,org.apache.flink.table.data.RowData> mapper, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> outputType)
FlinkSink.Builder
to export the data from generic input data stream into iceberg
table. We use RowData
inside the sink connector, so users need to provide a mapper
function and a TypeInformation
to convert those generic records to a RowData
DataStream.T
- the data type of records.input
- the generic source input data stream.mapper
- function to convert the generic data to RowData
outputType
- to define the TypeInformation
for the input data.FlinkSink.Builder
to connect the iceberg table.public static FlinkSink.Builder forRow(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> input, org.apache.flink.table.api.TableSchema tableSchema)
FlinkSink.Builder
to export the data from input data stream with Row
s into
iceberg table. We use RowData
inside the sink connector, so users need to provide a
TableSchema
for builder to convert those Row
s to a RowData
DataStream.input
- the source input data stream with Row
s.tableSchema
- defines the TypeInformation
for input data.FlinkSink.Builder
to connect the iceberg table.public static FlinkSink.Builder forRowData(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> input)
FlinkSink.Builder
to export the data from input data stream with RowData
s
into iceberg table.input
- the source input data stream with RowData
s.FlinkSink.Builder
to connect the iceberg table.