Uses of Class
org.apache.flink.types.Row

Packages that use Row

Package	Description
org.apache.flink.addons.hbase
org.apache.flink.addons.hbase.util
org.apache.flink.api.common.typeinfo
org.apache.flink.api.java.io
org.apache.flink.api.java.io.jdbc
org.apache.flink.api.java.io.jdbc.writer
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.batch.connectors.cassandra
org.apache.flink.connectors.hive
org.apache.flink.formats.avro
org.apache.flink.formats.avro.typeutils
org.apache.flink.formats.csv
org.apache.flink.formats.json
org.apache.flink.formats.parquet
org.apache.flink.formats.parquet.utils
org.apache.flink.ml.common.mapper
org.apache.flink.ml.common.model
org.apache.flink.orc
org.apache.flink.sql.tests
org.apache.flink.streaming.connectors.cassandra
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch6
org.apache.flink.streaming.connectors.elasticsearch7
org.apache.flink.streaming.connectors.kafka
org.apache.flink.table.api
org.apache.flink.table.client.cli
org.apache.flink.table.client.gateway
org.apache.flink.table.client.gateway.local
org.apache.flink.table.client.gateway.local.result
org.apache.flink.table.descriptors
org.apache.flink.table.filesystem
org.apache.flink.table.planner.functions.tablefunctions
org.apache.flink.table.runtime.operators.python
org.apache.flink.table.runtime.runners.python
org.apache.flink.table.sinks
org.apache.flink.table.sources
org.apache.flink.table.sources.wmstrategies
org.apache.flink.types
org.apache.flink.walkthrough.common.source
org.apache.flink.walkthrough.common.table

Uses of Row in org.apache.flink.addons.hbase

Methods in org.apache.flink.addons.hbase that return Row

Modifier and Type	Method and Description
protected Row	HBaseRowInputFormat.mapResultToOutType(org.apache.hadoop.hbase.client.Result res)

Methods in org.apache.flink.addons.hbase that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Tuple2<Boolean,Row>>	HBaseUpsertTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
StreamTableSink<Tuple2<Boolean,Row>>	HBaseTableFactory.createStreamTableSink(Map<String,String> properties)
StreamTableSource<Row>	HBaseTableFactory.createStreamTableSource(Map<String,String> properties)
AsyncTableFunction<Row>	HBaseTableSource.getAsyncLookupFunction(String[] lookupKeys)
DataSet<Row>	HBaseTableSource.getDataSet(ExecutionEnvironment execEnv)
DataStream<Row>	HBaseTableSource.getDataStream(StreamExecutionEnvironment execEnv)
TableFunction<Row>	HBaseTableSource.getLookupFunction(String[] lookupKeys)
TypeInformation<Row>	HBaseRowInputFormat.getProducedType()
TypeInformation<Row>	HBaseUpsertTableSink.getRecordType()
TypeInformation<Row>	HBaseLookupFunction.getResultType()
TypeInformation<Row>	HBaseTableSource.getReturnType()

Method parameters in org.apache.flink.addons.hbase with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	HBaseUpsertTableSink.consumeDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
void	HBaseUpsertTableSink.emitDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
void	HBaseUpsertSinkFunction.invoke(Tuple2<Boolean,Row> value, SinkFunction.Context context)

Uses of Row in org.apache.flink.addons.hbase.util

Methods in org.apache.flink.addons.hbase.util that return Row

Modifier and Type	Method and Description
Row	HBaseReadWriteHelper.parseToRow(org.apache.hadoop.hbase.client.Result result) Parses HBase Result into Row.
Row	HBaseReadWriteHelper.parseToRow(org.apache.hadoop.hbase.client.Result result, Object rowKey) Parses HBase Result into Row.

Methods in org.apache.flink.addons.hbase.util with parameters of type Row

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.Delete	HBaseReadWriteHelper.createDeleteMutation(Row row) Returns an instance of Delete that remove record from HBase table.
org.apache.hadoop.hbase.client.Put	HBaseReadWriteHelper.createPutMutation(Row row) Returns an instance of Put that writes record to HBase table.

Uses of Row in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo that return types with arguments of type Row

Modifier and Type	Method and Description
static TypeInformation<Row>	Types.ROW_NAMED(String[] fieldNames, TypeInformation<?>... types) Returns type information for Row with fields of the given types and with given names.
static TypeInformation<Row>	Types.ROW(TypeInformation<?>... types) Returns type information for Row with fields of the given types.

Uses of Row in org.apache.flink.api.java.io

Methods in org.apache.flink.api.java.io that return Row

Modifier and Type	Method and Description
protected Row	RowCsvInputFormat.fillRecord(Row reuse, Object[] parsedValues)

Methods in org.apache.flink.api.java.io that return types with arguments of type Row

Modifier and Type	Method and Description
TypeInformation<Row>	RowCsvInputFormat.getProducedType()

Methods in org.apache.flink.api.java.io with parameters of type Row

Modifier and Type	Method and Description
protected Row	RowCsvInputFormat.fillRecord(Row reuse, Object[] parsedValues)

Uses of Row in org.apache.flink.api.java.io.jdbc

Methods in org.apache.flink.api.java.io.jdbc that return Row

Modifier and Type	Method and Description
Row	JDBCInputFormat.nextRecord(Row row) Stores the next resultSet row in a tuple.

Methods in org.apache.flink.api.java.io.jdbc that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Tuple2<Boolean,Row>>	JDBCUpsertTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink<Row>	JDBCAppendTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
StreamTableSink<Tuple2<Boolean,Row>>	JDBCTableSourceSinkFactory.createStreamTableSink(Map<String,String> properties)
StreamTableSource<Row>	JDBCTableSourceSinkFactory.createStreamTableSource(Map<String,String> properties)
AsyncTableFunction<Row>	JDBCTableSource.getAsyncLookupFunction(String[] lookupKeys)
DataStream<Row>	JDBCTableSource.getDataStream(StreamExecutionEnvironment execEnv)
TableFunction<Row>	JDBCTableSource.getLookupFunction(String[] lookupKeys)
TypeInformation<Tuple2<Boolean,Row>>	JDBCUpsertTableSink.getOutputType()
TypeInformation<Row>	JDBCAppendTableSink.getOutputType()
TypeInformation<Row>	JDBCUpsertTableSink.getRecordType()
TypeInformation<Row>	JDBCLookupFunction.getResultType()
TypeInformation<Row>	JDBCTableSource.getReturnType()
TableSource<Row>	JDBCTableSource.projectFields(int[] fields)

Methods in org.apache.flink.api.java.io.jdbc with parameters of type Row

Modifier and Type	Method and Description
Row	JDBCInputFormat.nextRecord(Row row) Stores the next resultSet row in a tuple.
static void	JDBCUtils.setRecordToStatement(PreparedStatement upload, int[] typesArray, Row row) Adds a record to the prepared statement.
void	JDBCOutputFormat.writeRecord(Row row)

Method parameters in org.apache.flink.api.java.io.jdbc with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	JDBCAppendTableSink.consumeDataStream(DataStream<Row> dataStream)
DataStreamSink<?>	JDBCUpsertTableSink.consumeDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
void	JDBCAppendTableSink.emitDataSet(DataSet<Row> dataSet)
void	JDBCAppendTableSink.emitDataStream(DataStream<Row> dataStream)
void	JDBCUpsertTableSink.emitDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
void	JDBCUpsertOutputFormat.writeRecord(Tuple2<Boolean,Row> tuple2)

Uses of Row in org.apache.flink.api.java.io.jdbc.writer

Method parameters in org.apache.flink.api.java.io.jdbc.writer with type arguments of type Row

Modifier and Type	Method and Description
void	JDBCWriter.addRecord(Tuple2<Boolean,Row> record) Add record to writer, the writer may cache the data.
void	AppendOnlyWriter.addRecord(Tuple2<Boolean,Row> record)
void	UpsertWriter.addRecord(Tuple2<Boolean,Row> record)

Uses of Row in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils that return types with arguments of type Row

Modifier and Type	Method and Description
TypeComparator<Row>	RowTypeInfo.createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
TypeSerializer<Row>	RowTypeInfo.createSerializer(ExecutionConfig config)
protected CompositeType.TypeComparatorBuilder<Row>	RowTypeInfo.createTypeComparatorBuilder()

Uses of Row in org.apache.flink.api.java.typeutils.runtime

Methods in org.apache.flink.api.java.typeutils.runtime that return Row

Modifier and Type	Method and Description
Row	RowSerializer.copy(Row from)
Row	RowSerializer.copy(Row from, Row reuse)
Row	RowSerializer.createInstance()
Row	RowSerializer.deserialize(DataInputView source)
Row	RowSerializer.deserialize(Row reuse, DataInputView source)
Row	RowComparator.readWithKeyDenormalization(Row reuse, DataInputView source)

Methods in org.apache.flink.api.java.typeutils.runtime that return types with arguments of type Row

Modifier and Type	Method and Description
TypeSerializer<Row>	RowSerializer.duplicate()
TypeComparator<Row>	RowComparator.duplicate()
TypeSerializerSchemaCompatibility<Row>	RowSerializer.RowSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Row> newSerializer) Deprecated.
TypeSerializerSnapshot<Row>	RowSerializer.snapshotConfiguration()

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type Row

Modifier and Type	Method and Description
int	RowComparator.compare(Row first, Row second)
Row	RowSerializer.copy(Row from)
Row	RowSerializer.copy(Row from, Row reuse)
Row	RowSerializer.deserialize(Row reuse, DataInputView source)
boolean	RowComparator.equalToReference(Row candidate)
int	RowComparator.hash(Row record)
void	RowComparator.putNormalizedKey(Row record, MemorySegment target, int offset, int numBytes)
Row	RowComparator.readWithKeyDenormalization(Row reuse, DataInputView source)
void	RowSerializer.serialize(Row record, DataOutputView target)
void	RowComparator.setReference(Row toCompare)
static void	NullMaskUtils.writeNullMask(int len, Row value, DataOutputView target)
void	RowComparator.writeWithKeyNormalization(Row record, DataOutputView target)

Method parameters in org.apache.flink.api.java.typeutils.runtime with type arguments of type Row

Modifier and Type	Method and Description
int	RowComparator.compareToReference(TypeComparator<Row> referencedComparator)
TypeSerializerSchemaCompatibility<Row>	RowSerializer.RowSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Row> newSerializer) Deprecated.

Uses of Row in org.apache.flink.batch.connectors.cassandra

Methods in org.apache.flink.batch.connectors.cassandra with parameters of type Row

Modifier and Type	Method and Description
protected Object[]	CassandraRowOutputFormat.extractFields(Row record)

Uses of Row in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Row>	HiveTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink<Row>	HiveTableFactory.createTableSink(Map<String,String> properties)
TableSink<Row>	HiveTableFactory.createTableSink(ObjectPath tablePath, CatalogTable table)
OutputFormat<Row>	HiveTableSink.getOutputFormat()

Methods in org.apache.flink.connectors.hive with parameters of type Row

Modifier and Type	Method and Description
LinkedHashMap<String,String>	HivePartitionComputer.generatePartValues(Row in)

Uses of Row in org.apache.flink.formats.avro

Methods in org.apache.flink.formats.avro that return Row

Modifier and Type	Method and Description
Row	AvroRowDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.avro that return types with arguments of type Row

Modifier and Type	Method and Description
DeserializationSchema<Row>	AvroRowFormatFactory.createDeserializationSchema(Map<String,String> properties)
SerializationSchema<Row>	AvroRowFormatFactory.createSerializationSchema(Map<String,String> properties)
TypeInformation<Row>	AvroRowDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.avro with parameters of type Row

Modifier and Type	Method and Description
byte[]	AvroRowSerializationSchema.serialize(Row row)

Uses of Row in org.apache.flink.formats.avro.typeutils

Methods in org.apache.flink.formats.avro.typeutils that return types with arguments of type Row

Modifier and Type	Method and Description
static <T extends org.apache.avro.specific.SpecificRecord> TypeInformation<Row>	AvroSchemaConverter.convertToTypeInfo(Class<T> avroClass) Converts an Avro class into a nested row structure with deterministic field order and data types that are compatible with Flink's Table & SQL API.

Uses of Row in org.apache.flink.formats.csv

Methods in org.apache.flink.formats.csv that return Row

Modifier and Type	Method and Description
Row	CsvRowDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.csv that return types with arguments of type Row

Modifier and Type	Method and Description
DeserializationSchema<Row>	CsvRowFormatFactory.createDeserializationSchema(Map<String,String> properties)
SerializationSchema<Row>	CsvRowFormatFactory.createSerializationSchema(Map<String,String> properties)
TypeInformation<Row>	CsvRowDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.csv with parameters of type Row

Modifier and Type	Method and Description
boolean	CsvRowDeserializationSchema.isEndOfStream(Row nextElement)
byte[]	CsvRowSerializationSchema.serialize(Row row)

Constructor parameters in org.apache.flink.formats.csv with type arguments of type Row

Constructor and Description
Builder(TypeInformation<Row> typeInfo) Creates a CSV deserialization schema for the given TypeInformation with optional parameters.
Builder(TypeInformation<Row> typeInfo) Creates a CsvRowSerializationSchema expecting the given TypeInformation.

Uses of Row in org.apache.flink.formats.json

Methods in org.apache.flink.formats.json that return Row

Modifier and Type	Method and Description
Row	JsonRowDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.json that return types with arguments of type Row

Modifier and Type	Method and Description
DeserializationSchema<Row>	JsonRowFormatFactory.createDeserializationSchema(Map<String,String> properties)
SerializationSchema<Row>	JsonRowFormatFactory.createSerializationSchema(Map<String,String> properties)
TypeInformation<Row>	JsonRowDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.json with parameters of type Row

Modifier and Type	Method and Description
boolean	JsonRowDeserializationSchema.isEndOfStream(Row nextElement)
byte[]	JsonRowSerializationSchema.serialize(Row row)

Constructor parameters in org.apache.flink.formats.json with type arguments of type Row

Constructor and Description
Builder(TypeInformation<Row> typeInfo) Creates a JSON deserialization schema for the given type information.
Builder(TypeInformation<Row> typeInfo) Creates a JSON serialization schema for the given type information.
JsonRowDeserializationSchema(TypeInformation<Row> typeInfo) Deprecated. Use the provided JsonRowDeserializationSchema.Builder instead.
JsonRowSerializationSchema(TypeInformation<Row> typeInfo) Deprecated. Use the provided JsonRowSerializationSchema.Builder instead.

Uses of Row in org.apache.flink.formats.parquet

Methods in org.apache.flink.formats.parquet that return Row

Modifier and Type	Method and Description
protected Row	ParquetRowInputFormat.convert(Row row)

Methods in org.apache.flink.formats.parquet that return types with arguments of type Row

Modifier and Type	Method and Description
TableSource<Row>	ParquetTableSource.applyPredicate(List<Expression> predicates)
DataSet<Row>	ParquetTableSource.getDataSet(ExecutionEnvironment executionEnvironment)
TypeInformation<Row>	ParquetRowInputFormat.getProducedType()
TypeInformation<Row>	ParquetTableSource.getReturnType()
TableSource<Row>	ParquetTableSource.projectFields(int[] fields)

Methods in org.apache.flink.formats.parquet with parameters of type Row

Modifier and Type	Method and Description
protected E	ParquetPojoInputFormat.convert(Row row)
protected Map	ParquetMapInputFormat.convert(Row row)
protected abstract E	ParquetInputFormat.convert(Row row) This ParquetInputFormat read parquet record as Row by default.
protected Row	ParquetRowInputFormat.convert(Row row)

Uses of Row in org.apache.flink.formats.parquet.utils

Methods in org.apache.flink.formats.parquet.utils that return Row

Modifier and Type	Method and Description
Row	RowMaterializer.getCurrentRecord()
Row	RowConverter.getCurrentRow()

Methods in org.apache.flink.formats.parquet.utils that return types with arguments of type Row

Modifier and Type	Method and Description
org.apache.parquet.io.api.RecordMaterializer<Row>	RowReadSupport.prepareForRead(Configuration configuration, Map<String,String> keyValueMetaData, org.apache.parquet.schema.MessageType fileSchema, org.apache.parquet.hadoop.api.ReadSupport.ReadContext readContext)

Uses of Row in org.apache.flink.ml.common.mapper

Methods in org.apache.flink.ml.common.mapper that return Row

Modifier and Type	Method and Description
Row	MapperAdapter.map(Row row)
Row	ModelMapperAdapter.map(Row row)
abstract Row	Mapper.map(Row row) Map a row to a new row.

Methods in org.apache.flink.ml.common.mapper with parameters of type Row

Modifier and Type	Method and Description
Row	MapperAdapter.map(Row row)
Row	ModelMapperAdapter.map(Row row)
abstract Row	Mapper.map(Row row) Map a row to a new row.

Method parameters in org.apache.flink.ml.common.mapper with type arguments of type Row

Modifier and Type	Method and Description
abstract void	ModelMapper.loadModel(List<Row> modelRows) Load the model from the list of rows.

Uses of Row in org.apache.flink.ml.common.model

Methods in org.apache.flink.ml.common.model that return types with arguments of type Row

Modifier and Type	Method and Description
List<Row>	RowsModelSource.getModelRows(RuntimeContext runtimeContext)
List<Row>	BroadcastVariableModelSource.getModelRows(RuntimeContext runtimeContext)
List<Row>	ModelSource.getModelRows(RuntimeContext runtimeContext) Get the rows that containing the model.

Constructor parameters in org.apache.flink.ml.common.model with type arguments of type Row

Constructor and Description
RowsModelSource(List<Row> modelRows) Construct a RowsModelSource with the given rows containing a model.

Uses of Row in org.apache.flink.orc

Methods in org.apache.flink.orc that return Row

Modifier and Type	Method and Description
Row	OrcRowSplitReader.nextRecord(Row reuse)

Methods in org.apache.flink.orc that return types with arguments of type Row

Modifier and Type	Method and Description
TableSource<Row>	OrcTableSource.applyPredicate(List<Expression> predicates)
DataSet<Row>	OrcTableSource.getDataSet(ExecutionEnvironment execEnv)
TypeInformation<Row>	OrcRowInputFormat.getProducedType()
TypeInformation<Row>	OrcTableSource.getReturnType()
TableSource<Row>	OrcTableSource.projectFields(int[] selectedFields)

Methods in org.apache.flink.orc with parameters of type Row

Modifier and Type	Method and Description
Row	OrcRowSplitReader.nextRecord(Row reuse)

Uses of Row in org.apache.flink.sql.tests

Methods in org.apache.flink.sql.tests that return Row

Modifier and Type	Method and Description
Row	StreamSQLTestProgram.KillMapper.map(Row value)
Row	BatchSQLTestProgram.DataGenerator.next()

Methods in org.apache.flink.sql.tests that return types with arguments of type Row

Modifier and Type	Method and Description
DataStream<Row>	StreamSQLTestProgram.GeneratorTableSource.getDataStream(StreamExecutionEnvironment execEnv)
InputFormat<Row,?>	BatchSQLTestProgram.GeneratorTableSource.getInputFormat()
TypeInformation<Row>	StreamSQLTestProgram.Generator.getProducedType()
TypeInformation<Row>	StreamSQLTestProgram.GeneratorTableSource.getReturnType()

Methods in org.apache.flink.sql.tests with parameters of type Row

Modifier and Type	Method and Description
String	StreamSQLTestProgram.KeyBucketAssigner.getBucketId(Row element, BucketAssigner.Context context)
Row	StreamSQLTestProgram.KillMapper.map(Row value)

Method parameters in org.apache.flink.sql.tests with type arguments of type Row

Modifier and Type	Method and Description
void	StreamSQLTestProgram.Generator.run(SourceFunction.SourceContext<Row> ctx)

Uses of Row in org.apache.flink.streaming.connectors.cassandra

Methods in org.apache.flink.streaming.connectors.cassandra that return types with arguments of type Row

Modifier and Type	Method and Description
protected CassandraSink<Row>	CassandraSink.CassandraRowSinkBuilder.createSink()
protected CassandraSink<Row>	CassandraSink.CassandraRowSinkBuilder.createWriteAheadSink()
TypeInformation<Row>	CassandraAppendTableSink.getOutputType()

Methods in org.apache.flink.streaming.connectors.cassandra with parameters of type Row

Modifier and Type	Method and Description
protected Object[]	CassandraRowSink.extract(Row record)

Method parameters in org.apache.flink.streaming.connectors.cassandra with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	CassandraAppendTableSink.consumeDataStream(DataStream<Row> dataStream)
void	CassandraAppendTableSink.emitDataStream(DataStream<Row> dataStream)
protected boolean	CassandraRowWriteAheadSink.sendValues(Iterable<Row> values, long checkpointId, long timestamp)

Constructor parameters in org.apache.flink.streaming.connectors.cassandra with type arguments of type Row

Constructor and Description
CassandraRowSinkBuilder(DataStream<Row> input, TypeInformation<Row> typeInfo, TypeSerializer<Row> serializer)
CassandraRowSinkBuilder(DataStream<Row> input, TypeInformation<Row> typeInfo, TypeSerializer<Row> serializer)
CassandraRowSinkBuilder(DataStream<Row> input, TypeInformation<Row> typeInfo, TypeSerializer<Row> serializer)
CassandraRowWriteAheadSink(String insertQuery, TypeSerializer<Row> serializer, ClusterBuilder builder, CheckpointCommitter committer)

Uses of Row in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkBase.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
protected abstract SinkFunction<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkBase.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertFunction)
StreamTableSink<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkFactoryBase.createStreamTableSink(Map<String,String> properties)
TypeInformation<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkBase.getOutputType()
TypeInformation<Row>	ElasticsearchUpsertTableSinkBase.getRecordType()

Method parameters in org.apache.flink.streaming.connectors.elasticsearch with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	ElasticsearchUpsertTableSinkBase.consumeDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
protected abstract ElasticsearchUpsertTableSinkBase	ElasticsearchUpsertTableSinkBase.copy(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)
protected abstract ElasticsearchUpsertTableSinkBase	ElasticsearchUpsertTableSinkFactoryBase.createElasticsearchUpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)
void	ElasticsearchUpsertTableSinkBase.emitDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
void	ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction.process(Tuple2<Boolean,Row> element, RuntimeContext ctx, RequestIndexer indexer)

Constructor parameters in org.apache.flink.streaming.connectors.elasticsearch with type arguments of type Row

Constructor and Description
ElasticsearchUpsertSinkFunction(String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory, int[] keyFieldIndices)
ElasticsearchUpsertTableSinkBase(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)

Uses of Row in org.apache.flink.streaming.connectors.elasticsearch6

Methods in org.apache.flink.streaming.connectors.elasticsearch6 that return types with arguments of type Row

Modifier and Type	Method and Description
protected SinkFunction<Tuple2<Boolean,Row>>	Elasticsearch6UpsertTableSink.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertSinkFunction)

Method parameters in org.apache.flink.streaming.connectors.elasticsearch6 with type arguments of type Row

Modifier and Type	Method and Description
protected ElasticsearchUpsertTableSinkBase	Elasticsearch6UpsertTableSink.copy(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)
protected ElasticsearchUpsertTableSinkBase	Elasticsearch6UpsertTableSinkFactory.createElasticsearchUpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Constructor parameters in org.apache.flink.streaming.connectors.elasticsearch6 with type arguments of type Row

Constructor and Description

Elasticsearch6UpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Uses of Row in org.apache.flink.streaming.connectors.elasticsearch7

Methods in org.apache.flink.streaming.connectors.elasticsearch7 that return types with arguments of type Row

Modifier and Type	Method and Description
protected SinkFunction<Tuple2<Boolean,Row>>	Elasticsearch7UpsertTableSink.createSinkFunction(List<ElasticsearchUpsertTableSinkBase.Host> hosts, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction upsertSinkFunction)

Method parameters in org.apache.flink.streaming.connectors.elasticsearch7 with type arguments of type Row

Modifier and Type	Method and Description
protected ElasticsearchUpsertTableSinkBase	Elasticsearch7UpsertTableSink.copy(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions, ElasticsearchUpsertTableSinkBase.RequestFactory requestFactory)
protected ElasticsearchUpsertTableSinkBase	Elasticsearch7UpsertTableSinkFactory.createElasticsearchUpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String docType, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Constructor parameters in org.apache.flink.streaming.connectors.elasticsearch7 with type arguments of type Row

Constructor and Description
Elasticsearch7UpsertTableSink(boolean isAppendOnly, TableSchema schema, List<ElasticsearchUpsertTableSinkBase.Host> hosts, String index, String keyDelimiter, String keyNullLiteral, SerializationSchema<Row> serializationSchema, org.elasticsearch.common.xcontent.XContentType contentType, ActionRequestFailureHandler failureHandler, Map<ElasticsearchUpsertTableSinkBase.SinkOption,String> sinkOptions)

Uses of Row in org.apache.flink.streaming.connectors.kafka

Fields in org.apache.flink.streaming.connectors.kafka with type parameters of type Row

Modifier and Type	Field and Description
protected Optional<FlinkKafkaPartitioner<Row>>	KafkaTableSinkBase.partitioner Partitioner to select Kafka partition for each item.
protected SerializationSchema<Row>	KafkaTableSinkBase.serializationSchema Serialization schema for encoding records to Kafka.

Methods in org.apache.flink.streaming.connectors.kafka that return types with arguments of type Row

Modifier and Type	Method and Description
protected FlinkKafkaConsumerBase<Row>	Kafka08TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	KafkaTableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka011TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka010TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka09TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected abstract FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a version-specific Kafka consumer.
protected FlinkKafkaProducerBase<Row>	Kafka08TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	KafkaTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	Kafka011TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka010TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka09TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected abstract SinkFunction<Row>	KafkaTableSinkBase.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner) Returns the version-specific Kafka producer.
StreamTableSink<Row>	KafkaTableSourceSinkFactoryBase.createStreamTableSink(Map<String,String> properties)
StreamTableSource<Row>	KafkaTableSourceSinkFactoryBase.createStreamTableSource(Map<String,String> properties)
DataStream<Row>	KafkaTableSourceBase.getDataStream(StreamExecutionEnvironment env) NOTE: This method is for internal use only for defining a TableSource.
DeserializationSchema<Row>	KafkaTableSourceBase.getDeserializationSchema() Returns the deserialization schema.
protected FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.getKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Returns a version-specific Kafka consumer with the start position configured.
TypeInformation<Row>	KafkaTableSinkBase.getOutputType()
TypeInformation<Row>	KafkaTableSourceBase.getReturnType()

Method parameters in org.apache.flink.streaming.connectors.kafka with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	KafkaTableSinkBase.consumeDataStream(DataStream<Row> dataStream)
protected FlinkKafkaConsumerBase<Row>	Kafka08TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	KafkaTableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka011TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka010TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected FlinkKafkaConsumerBase<Row>	Kafka09TableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema)
protected abstract FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a version-specific Kafka consumer.
protected FlinkKafkaProducerBase<Row>	Kafka08TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka08TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	KafkaTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	KafkaTableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	Kafka011TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected SinkFunction<Row>	Kafka011TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka010TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka010TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka09TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected FlinkKafkaProducerBase<Row>	Kafka09TableSink.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner)
protected abstract SinkFunction<Row>	KafkaTableSinkBase.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner) Returns the version-specific Kafka producer.
protected abstract SinkFunction<Row>	KafkaTableSinkBase.createKafkaProducer(String topic, Properties properties, SerializationSchema<Row> serializationSchema, Optional<FlinkKafkaPartitioner<Row>> partitioner) Returns the version-specific Kafka producer.
protected KafkaTableSinkBase	Kafka08TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka08TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	KafkaTableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	KafkaTableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka011TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka011TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka010TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka010TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka09TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected KafkaTableSinkBase	Kafka09TableSourceSinkFactory.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
protected abstract KafkaTableSinkBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema) Constructs the version-specific Kafka table sink.
protected abstract KafkaTableSinkBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema) Constructs the version-specific Kafka table sink.
protected KafkaTableSourceBase	Kafka08TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets)
protected KafkaTableSourceBase	KafkaTableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets)
protected KafkaTableSourceBase	Kafka011TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets)
protected KafkaTableSourceBase	Kafka010TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets)
protected KafkaTableSourceBase	Kafka09TableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets)
protected abstract KafkaTableSourceBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Constructs the version-specific Kafka table source.
void	KafkaTableSinkBase.emitDataStream(DataStream<Row> dataStream)
protected FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.getKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Returns a version-specific Kafka consumer with the start position configured.

Constructor parameters in org.apache.flink.streaming.connectors.kafka with type arguments of type Row

Constructor and Description
Kafka010TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka010TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka010TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a Kafka 0.10 StreamTableSource.
Kafka010TableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a Kafka 0.10 StreamTableSource.
Kafka011TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka011TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka011TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a Kafka 0.11 StreamTableSource.
Kafka011TableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a Kafka 0.11 StreamTableSource.
Kafka08TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka08TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka08TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a Kafka 0.8 StreamTableSource.
Kafka08TableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a Kafka 0.8 StreamTableSource.
Kafka09TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka09TableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
Kafka09TableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a Kafka 0.9 StreamTableSource.
Kafka09TableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a Kafka 0.9 StreamTableSource.
KafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
KafkaTableSink(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
KafkaTableSinkBase(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
KafkaTableSinkBase(TableSchema schema, String topic, Properties properties, Optional<FlinkKafkaPartitioner<Row>> partitioner, SerializationSchema<Row> serializationSchema)
KafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a generic Kafka StreamTableSource.
KafkaTableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a generic Kafka StreamTableSource.
KafkaTableSourceBase(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets) Creates a generic Kafka StreamTableSource.
KafkaTableSourceBase(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Creates a generic Kafka StreamTableSource.

Uses of Row in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return types with arguments of type Row

Modifier and Type	Method and Description
static List<Row>	TableUtils.collectToList(Table table) Convert Flink table to Java list.
static TypeInformation<Row>	Types.ROW(String[] fieldNames, TypeInformation<?>[] types) Deprecated. Returns type information for Row with fields of the given types and with given names.
static TypeInformation<Row>	Types.ROW(TypeInformation<?>... types) Deprecated. Returns type information for Row with fields of the given types.
TypeInformation<Row>	TableSchema.toRowType() Deprecated. Use TableSchema.toRowDataType() instead.

Uses of Row in org.apache.flink.table.client.cli

Methods in org.apache.flink.table.client.cli with parameters of type Row

Modifier and Type	Method and Description
static String[]	CliUtils.rowToString(Row row)

Uses of Row in org.apache.flink.table.client.gateway

Methods in org.apache.flink.table.client.gateway that return types with arguments of type Row

Modifier and Type	Method and Description
TypedResult<List<Tuple2<Boolean,Row>>>	Executor.retrieveResultChanges(String sessionId, String resultId) Asks for the next changelog results (non-blocking).
List<Row>	Executor.retrieveResultPage(String resultId, int page) Returns the rows that are part of the current page or throws an exception if the snapshot has been expired.

Uses of Row in org.apache.flink.table.client.gateway.local

Methods in org.apache.flink.table.client.gateway.local that return types with arguments of type Row

Modifier and Type	Method and Description
OutputFormat<Row>	CollectBatchTableSink.getOutputFormat()
TupleTypeInfo<Tuple2<Boolean,Row>>	CollectStreamTableSink.getOutputType()
TypeInformation<Row>	CollectStreamTableSink.getRecordType()
TypeSerializer<Row>	CollectBatchTableSink.getSerializer() Returns the serializer for deserializing the collected result.
TypedResult<List<Tuple2<Boolean,Row>>>	LocalExecutor.retrieveResultChanges(String sessionId, String resultId)
List<Row>	LocalExecutor.retrieveResultPage(String resultId, int page)

Method parameters in org.apache.flink.table.client.gateway.local with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	CollectStreamTableSink.consumeDataStream(DataStream<Tuple2<Boolean,Row>> stream)
void	CollectBatchTableSink.emitDataSet(DataSet<Row> dataSet)
void	CollectStreamTableSink.emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)

Constructor parameters in org.apache.flink.table.client.gateway.local with type arguments of type Row

Constructor and Description
CollectBatchTableSink(String accumulatorName, TypeSerializer<Row> serializer, TableSchema tableSchema)
CollectStreamTableSink(InetAddress targetAddress, int targetPort, TypeSerializer<Tuple2<Boolean,Row>> serializer, TableSchema tableSchema)

Uses of Row in org.apache.flink.table.client.gateway.local.result

Methods in org.apache.flink.table.client.gateway.local.result that return types with arguments of type Row

Modifier and Type	Method and Description
protected List<Row>	MaterializedCollectStreamResult.getMaterializedTable()
TypedResult<List<Tuple2<Boolean,Row>>>	ChangelogResult.retrieveChanges() Retrieves the available result records.
TypedResult<List<Tuple2<Boolean,Row>>>	ChangelogCollectStreamResult.retrieveChanges()
List<Row>	MaterializedCollectStreamResult.retrievePage(int page)
List<Row>	MaterializedResult.retrievePage(int page) Retrieves a page of a snapshotted result.
List<Row>	MaterializedCollectBatchResult.retrievePage(int page)

Method parameters in org.apache.flink.table.client.gateway.local.result with type arguments of type Row

Modifier and Type	Method and Description
protected void	MaterializedCollectStreamResult.processRecord(Tuple2<Boolean,Row> change)
protected abstract void	CollectStreamResult.processRecord(Tuple2<Boolean,Row> change)
protected void	ChangelogCollectStreamResult.processRecord(Tuple2<Boolean,Row> change)

Uses of Row in org.apache.flink.table.descriptors

Method parameters in org.apache.flink.table.descriptors with type arguments of type Row

Modifier and Type	Method and Description
Csv	Csv.schema(TypeInformation<Row> schemaType) Sets the format schema with field names and the types.
Json	Json.schema(TypeInformation<Row> schemaType) Sets the schema using type information.

Uses of Row in org.apache.flink.table.filesystem

Methods in org.apache.flink.table.filesystem that return Row

Modifier and Type	Method and Description
Row	RowPartitionComputer.projectColumnsToWrite(Row in)

Methods in org.apache.flink.table.filesystem with parameters of type Row

Modifier and Type	Method and Description
LinkedHashMap<String,String>	RowPartitionComputer.generatePartValues(Row in)
Row	RowPartitionComputer.projectColumnsToWrite(Row in)

Uses of Row in org.apache.flink.table.planner.functions.tablefunctions

Methods in org.apache.flink.table.planner.functions.tablefunctions that return types with arguments of type Row

Modifier and Type	Method and Description
TypeInformation<Row>	ReplicateRows.getResultType()

Uses of Row in org.apache.flink.table.runtime.operators.python

Methods in org.apache.flink.table.runtime.operators.python that return Row

Modifier and Type	Method and Description
Row	PythonScalarFunctionOperator.getUdfInput(org.apache.flink.table.runtime.types.CRow element)

Methods in org.apache.flink.table.runtime.operators.python that return types with arguments of type Row

Modifier and Type	Method and Description
PythonFunctionRunner<Row>	PythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver, PythonEnvironmentManager pythonEnvironmentManager)

Method parameters in org.apache.flink.table.runtime.operators.python with type arguments of type Row

Modifier and Type	Method and Description
PythonFunctionRunner<Row>	PythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver, PythonEnvironmentManager pythonEnvironmentManager)

Uses of Row in org.apache.flink.table.runtime.runners.python

Constructor parameters in org.apache.flink.table.runtime.runners.python with type arguments of type Row

Constructor and Description
PythonScalarFunctionRunner(String taskName, org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver, PythonFunctionInfo[] scalarFunctions, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType)

Uses of Row in org.apache.flink.table.sinks

Methods in org.apache.flink.table.sinks that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Row>	CsvTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
BatchTableSink<Row>	CsvBatchTableSinkFactory.createBatchTableSink(Map<String,String> properties)
StreamTableSink<Row>	CsvAppendTableSinkFactory.createStreamTableSink(Map<String,String> properties)

Methods in org.apache.flink.table.sinks with parameters of type Row

Modifier and Type	Method and Description
String	CsvTableSink.CsvFormatter.map(Row row)

Method parameters in org.apache.flink.table.sinks with type arguments of type Row

Modifier and Type	Method and Description
DataStreamSink<?>	CsvTableSink.consumeDataStream(DataStream<Row> dataStream)
void	CsvTableSink.emitDataSet(DataSet<Row> dataSet)
void	CsvTableSink.emitDataStream(DataStream<Row> dataStream)

Uses of Row in org.apache.flink.table.sources

Methods in org.apache.flink.table.sources that return types with arguments of type Row

Modifier and Type	Method and Description
BatchTableSource<Row>	CsvBatchTableSourceFactory.createBatchTableSource(Map<String,String> properties)
StreamTableSource<Row>	CsvAppendTableSourceFactory.createStreamTableSource(Map<String,String> properties)
AsyncTableFunction<Row>	CsvTableSource.getAsyncLookupFunction(String[] lookupKeys)
DataSet<Row>	CsvTableSource.getDataSet(ExecutionEnvironment execEnv)
DataStream<Row>	CsvTableSource.getDataStream(StreamExecutionEnvironment execEnv)
TableFunction<Row>	CsvTableSource.getLookupFunction(String[] lookupKeys)
TypeInformation<Row>	CsvTableSource.CsvLookupFunction.getResultType()

Uses of Row in org.apache.flink.table.sources.wmstrategies

Methods in org.apache.flink.table.sources.wmstrategies with parameters of type Row

Modifier and Type	Method and Description
abstract Watermark	PunctuatedWatermarkAssigner.getWatermark(Row row, long timestamp) Returns the watermark for the current row or null if no watermark should be generated.

Uses of Row in org.apache.flink.types

Methods in org.apache.flink.types that return Row

Modifier and Type	Method and Description
static Row	Row.copy(Row row) Creates a new Row which copied from another row.
static Row	Row.join(Row first, Row... remainings) Creates a new Row which fields are copied from the other rows.
static Row	Row.of(Object... values) Creates a new Row and assigns the given values to the Row's fields.
static Row	Row.project(Row row, int[] fields) Creates a new Row with projected fields from another row.

Methods in org.apache.flink.types with parameters of type Row

Modifier and Type	Method and Description
static Row	Row.copy(Row row) Creates a new Row which copied from another row.
static Row	Row.join(Row first, Row... remainings) Creates a new Row which fields are copied from the other rows.
static Row	Row.join(Row first, Row... remainings) Creates a new Row which fields are copied from the other rows.
static Row	Row.project(Row row, int[] fields) Creates a new Row with projected fields from another row.

Uses of Row in org.apache.flink.walkthrough.common.source

Methods in org.apache.flink.walkthrough.common.source that return Row

Modifier and Type	Method and Description
Row	TransactionRowInputFormat.nextRecord(Row reuse)

Methods in org.apache.flink.walkthrough.common.source with parameters of type Row

Modifier and Type	Method and Description
Row	TransactionRowInputFormat.nextRecord(Row reuse)

Uses of Row in org.apache.flink.walkthrough.common.table

Methods in org.apache.flink.walkthrough.common.table that return types with arguments of type Row

Modifier and Type	Method and Description
TableSink<Row>	SpendReportTableSink.configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
DataStream<Row>	UnboundedTransactionTableSource.getDataStream(StreamExecutionEnvironment execEnv)
InputFormat<Row,?>	BoundedTransactionTableSource.getInputFormat()

Method parameters in org.apache.flink.walkthrough.common.table with type arguments of type Row

Modifier and Type	Method and Description
void	SpendReportTableSink.emitDataSet(DataSet<Row> dataSet)
void	SpendReportTableSink.emitDataStream(DataStream<Row> dataStream)