Uses of Interface
org.apache.flink.table.data.RowData

Packages that use RowData

Package	Description
org.apache.flink.connector.base.table
org.apache.flink.connector.datagen.table
org.apache.flink.connector.datagen.table.types
org.apache.flink.connector.file.table
org.apache.flink.connector.file.table.batch
org.apache.flink.connector.file.table.factories
org.apache.flink.connector.testframe.external.sink
org.apache.flink.connector.testframe.external.source
org.apache.flink.formats.avro
org.apache.flink.formats.avro.registry.confluent
org.apache.flink.formats.avro.registry.confluent.debezium
org.apache.flink.formats.csv
org.apache.flink.formats.json
org.apache.flink.formats.json.canal
org.apache.flink.formats.json.debezium
org.apache.flink.formats.json.maxwell
org.apache.flink.formats.json.ogg
org.apache.flink.formats.parquet
org.apache.flink.formats.parquet.row
org.apache.flink.formats.protobuf
org.apache.flink.formats.protobuf.deserialize
org.apache.flink.formats.protobuf.serialize
org.apache.flink.formats.raw
org.apache.flink.legacy.table.connector.source
org.apache.flink.orc
org.apache.flink.orc.nohive
org.apache.flink.orc.vector
org.apache.flink.python.util
org.apache.flink.streaming.api.utils
org.apache.flink.table.api.internal
org.apache.flink.table.client.gateway
org.apache.flink.table.client.gateway.result
org.apache.flink.table.connector.sink
org.apache.flink.table.connector.sink.legacy
org.apache.flink.table.connector.source
org.apache.flink.table.connector.source.abilities
org.apache.flink.table.connector.source.lookup.cache
org.apache.flink.table.data
org.apache.flink.table.data.binary
org.apache.flink.table.data.columnar
org.apache.flink.table.data.columnar.vector
org.apache.flink.table.data.conversion
org.apache.flink.table.data.util
org.apache.flink.table.data.utils
org.apache.flink.table.data.writer
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.examples.java.functions
org.apache.flink.table.functions
org.apache.flink.table.gateway.api.results
org.apache.flink.table.gateway.rest.serde
org.apache.flink.table.gateway.rest.util
org.apache.flink.table.gateway.service.result
org.apache.flink.table.jdbc
org.apache.flink.table.jdbc.utils
org.apache.flink.table.planner.codegen
org.apache.flink.table.planner.connectors
org.apache.flink.table.planner.functions.casting
org.apache.flink.table.planner.plan.fusion
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream
org.apache.flink.table.planner.plan.utils
org.apache.flink.table.runtime.arrow
org.apache.flink.table.runtime.arrow.serializers
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.table.runtime.arrow.writers
org.apache.flink.table.runtime.context
org.apache.flink.table.runtime.functions.aggregate
org.apache.flink.table.runtime.functions.table.lookup
org.apache.flink.table.runtime.functions.table.lookup.fullcache
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat
org.apache.flink.table.runtime.generated
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.keyselector
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.aggregate.window
org.apache.flink.table.runtime.operators.aggregate.window.buffers
org.apache.flink.table.runtime.operators.aggregate.window.combines
org.apache.flink.table.runtime.operators.aggregate.window.processors
org.apache.flink.table.runtime.operators.calc.async
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.deduplicate.window
org.apache.flink.table.runtime.operators.deduplicate.window.combines
org.apache.flink.table.runtime.operators.deduplicate.window.processors
org.apache.flink.table.runtime.operators.dynamicfiltering
org.apache.flink.table.runtime.operators.fusion
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.join.interval
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.join.stream
org.apache.flink.table.runtime.operators.join.stream.asyncprocessing
org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state
org.apache.flink.table.runtime.operators.join.stream.bundle
org.apache.flink.table.runtime.operators.join.stream.state
org.apache.flink.table.runtime.operators.join.stream.utils
org.apache.flink.table.runtime.operators.join.temporal
org.apache.flink.table.runtime.operators.join.window
org.apache.flink.table.runtime.operators.match
org.apache.flink.table.runtime.operators.misc
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.multipleinput.input
org.apache.flink.table.runtime.operators.multipleinput.output
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.over.frame
org.apache.flink.table.runtime.operators.python.aggregate
org.apache.flink.table.runtime.operators.python.aggregate.arrow
org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.scalar.arrow
org.apache.flink.table.runtime.operators.python.table
org.apache.flink.table.runtime.operators.python.utils
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.rank.window
org.apache.flink.table.runtime.operators.rank.window.combines
org.apache.flink.table.runtime.operators.rank.window.processors
org.apache.flink.table.runtime.operators.runtimefilter
org.apache.flink.table.runtime.operators.runtimefilter.util
org.apache.flink.table.runtime.operators.sink
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.operators.values
org.apache.flink.table.runtime.operators.window.groupwindow.assigners
org.apache.flink.table.runtime.operators.window.groupwindow.internal
org.apache.flink.table.runtime.operators.window.groupwindow.operator
org.apache.flink.table.runtime.operators.window.tvf.combines
org.apache.flink.table.runtime.operators.window.tvf.common
org.apache.flink.table.runtime.operators.window.tvf.operator
org.apache.flink.table.runtime.operators.window.tvf.slicing
org.apache.flink.table.runtime.operators.window.tvf.state
org.apache.flink.table.runtime.operators.window.tvf.unslicing
org.apache.flink.table.runtime.operators.wmassigners
org.apache.flink.table.runtime.partitioner
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.runtime.typeutils.serializers.python
org.apache.flink.table.runtime.util
org.apache.flink.table.runtime.util.collections.binary
org.apache.flink.table.toolbox
org.apache.flink.table.utils.print
org.apache.flink.table.utils.python
org.apache.flink.tests.util.flink

Uses of RowData in org.apache.flink.connector.base.table

Methods in org.apache.flink.connector.base.table that return types with arguments of type RowData

Modifier and Type	Method	Description
EncodingFormat<SerializationSchema<RowData>>	AsyncDynamicTableSinkFactory.AsyncDynamicSinkContext.getEncodingFormat()

Uses of RowData in org.apache.flink.connector.datagen.table

Methods in org.apache.flink.connector.datagen.table that return types with arguments of type RowData

Modifier and Type	Method	Description
DataGeneratorSource<RowData>	DataGenTableSource.createSource()

Uses of RowData in org.apache.flink.connector.datagen.table.types

Methods in org.apache.flink.connector.datagen.table.types that return RowData

Modifier and Type	Method	Description
RowData	RowDataGenerator.next()

Uses of RowData in org.apache.flink.connector.file.table

Classes in org.apache.flink.connector.file.table that implement RowData

Modifier and Type	Class	Description
class	EnrichedRowData	An implementation of RowData which is backed by two RowData with a well-defined index mapping, One of the rows is fixed, while the other can be swapped for performant changes in hot code paths.

Methods in org.apache.flink.connector.file.table that return RowData

Modifier and Type	Method	Description
RowData	EnrichedRowData.getRow(int pos, int numFields)
RowData	RowDataPartitionComputer.projectColumnsToWrite(RowData in)

Methods in org.apache.flink.connector.file.table that return types with arguments of type RowData

Modifier and Type	Method	Description
BulkWriter<RowData>	FileSystemTableSink.ProjectionBulkFactory.create(FSDataOutputStream out)
TypeInformation<RowData>	DeserializationSchemaAdapter.getProducedType()
RecordAndPosition<RowData>	ColumnarRowIterator.next()

Methods in org.apache.flink.connector.file.table with parameters of type RowData

Modifier and Type	Method	Description
void	SerializationSchemaAdapter.encode(RowData element, OutputStream stream)
static EnrichedRowData	EnrichedRowData.from(RowData fixedRow, List<String> producedRowFields, List<String> mutableRowFields, List<String> fixedRowFields)	Creates a new EnrichedRowData with the provided fixedRow as the immutable static row, and uses the producedRowFields, fixedRowFields and mutableRowFields arguments to compute the indexes mapping.
LinkedHashMap<String,String>	RowDataPartitionComputer.generatePartValues(RowData in)
String	FileSystemTableSink.TableBucketAssigner.getBucketId(RowData element, BucketAssigner.Context context)
RowData	RowDataPartitionComputer.projectColumnsToWrite(RowData in)
EnrichedRowData	EnrichedRowData.replaceMutableRow(RowData mutableRow)	Replaces the mutable RowData backing this EnrichedRowData.
boolean	FileSystemTableSink.TableRollingPolicy.shouldRollOnEvent(PartFileInfo<String> partFileState, RowData element)

Constructors in org.apache.flink.connector.file.table with parameters of type RowData

Constructor	Description
EnrichedRowData(RowData fixedRow, int[] indexMapping)

Constructor parameters in org.apache.flink.connector.file.table with type arguments of type RowData

Constructor	Description
DeserializationSchemaAdapter(DeserializationSchema<RowData> deserializationSchema)
FileSystemTableSource(ObjectIdentifier tableIdentifier, DataType physicalRowDataType, List<String> partitionKeys, ReadableConfig tableOptions, DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, DecodingFormat<DeserializationSchema<RowData>> deserializationFormat)
ProjectionBulkFactory(BulkWriter.Factory<RowData> factory, RowDataPartitionComputer computer)
SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema)
TableBucketAssigner(PartitionComputer<RowData> computer)

Uses of RowData in org.apache.flink.connector.file.table.batch

Method parameters in org.apache.flink.connector.file.table.batch with type arguments of type RowData

Modifier and Type	Method	Description
static DataStreamSink<Row>	BatchSink.createBatchNoCompactSink(DataStream<RowData> dataStream, DynamicTableSink.DataStructureConverter converter, FileSystemOutputFormat<Row> fileSystemOutputFormat, int parallelism, boolean parallelismConfigured)

Uses of RowData in org.apache.flink.connector.file.table.factories

Methods in org.apache.flink.connector.file.table.factories that return types with arguments of type RowData

Modifier and Type	Method	Description
BulkDecodingFormat<RowData>	BulkReaderFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)	Creates a BulkDecodingFormat from the given context and format options.

Uses of RowData in org.apache.flink.connector.testframe.external.sink

Methods in org.apache.flink.connector.testframe.external.sink that return types with arguments of type RowData

Modifier and Type	Method	Description
ExternalSystemDataReader<RowData>	TableSinkExternalContext.createSinkRowDataReader(TestingSinkSettings sinkOptions, DataType dataType)	Create a new split in the external system and return a data writer corresponding to the new split.

Uses of RowData in org.apache.flink.connector.testframe.external.source

Methods in org.apache.flink.connector.testframe.external.source that return types with arguments of type RowData

Modifier and Type	Method	Description
ExternalSystemSplitDataWriter<RowData>	TableSourceExternalContext.createSplitRowDataWriter(TestingSourceSettings sourceOptions, DataType dataType)	Create a new split in the external system and return a data writer for writing RowData corresponding to the new split.

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

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

Modifier and Type	Method	Description
RowData	AvroRowDataDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
BulkDecodingFormat<RowData>	AvroFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DecodingFormat<DeserializationSchema<RowData>>	AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<BulkWriter.Factory<RowData>>	AvroFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
TypeInformation<RowData>	AvroRowDataDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	AvroRowDataDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	AvroRowDataSerializationSchema.serialize(RowData row)

Constructor parameters in org.apache.flink.formats.avro with type arguments of type RowData

Constructor	Description
AvroRowDataDeserializationSchema(DeserializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema, AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter, TypeInformation<RowData> typeInfo)	Creates a Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> typeInfo)	Creates an Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> typeInfo, AvroFormatOptions.AvroEncoding encoding)	Creates an Avro deserialization schema for the given logical type.
AvroRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> typeInfo, AvroFormatOptions.AvroEncoding encoding, boolean legacyTimestampMapping)	Creates an Avro deserialization schema for the given logical type.

Uses of RowData in org.apache.flink.formats.avro.registry.confluent

Methods in org.apache.flink.formats.avro.registry.confluent that return types with arguments of type RowData

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	RegistryAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of RowData in org.apache.flink.formats.avro.registry.confluent.debezium

Methods in org.apache.flink.formats.avro.registry.confluent.debezium that return RowData

Modifier and Type	Method	Description
RowData	DebeziumAvroDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.avro.registry.confluent.debezium that return types with arguments of type RowData

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	DebeziumAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
TypeInformation<RowData>	DebeziumAvroDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.avro.registry.confluent.debezium with parameters of type RowData

Modifier and Type	Method	Description
boolean	DebeziumAvroDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	DebeziumAvroSerializationSchema.serialize(RowData rowData)

Method parameters in org.apache.flink.formats.avro.registry.confluent.debezium with type arguments of type RowData

Modifier and Type	Method	Description
void	DebeziumAvroDeserializationSchema.deserialize(byte[] message, Collector<RowData> out)

Constructor parameters in org.apache.flink.formats.avro.registry.confluent.debezium with type arguments of type RowData

Constructor	Description
DebeziumAvroDeserializationSchema(RowType rowType, TypeInformation<RowData> producedTypeInfo, String schemaRegistryUrl, String schemaString, Map<String,?> registryConfigs)

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

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

Modifier and Type	Method	Description
RowData	CsvRowDataDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
static BulkWriter.Factory<RowData>	PythonCsvUtils.createCsvBulkWriterFactory(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema schema, DataType physicalDataType)	Util for creating a BulkWriter.Factory that wraps CsvBulkWriter.forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema, org.apache.flink.formats.common.Converter<T, R, C>, C, org.apache.flink.core.fs.FSDataOutputStream).
BulkDecodingFormat<RowData>	CsvFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DecodingFormat<DeserializationSchema<RowData>>	CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<BulkWriter.Factory<RowData>>	CsvFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
BulkFormat<RowData,FileSourceSplit>	CsvFileFormatFactory.CsvBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)
TypeInformation<RowData>	CsvRowDataDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	CsvRowDataDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	CsvRowDataSerializationSchema.serialize(RowData row)

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

Constructor	Description
Builder(RowType rowType, TypeInformation<RowData> resultTypeInfo)	Creates a CSV deserialization schema for the given TypeInformation with optional parameters.
Builder(RowType rowReadType, RowType rowResultType, TypeInformation<RowData> resultTypeInfo)	Creates a CSV deserialization schema for the given TypeInformation with optional parameters.

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

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

Modifier and Type	Method	Description
RowData	JsonRowDataDeserializationSchema.convertToRowData(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode message)
RowData	JsonParserRowDataDeserializationSchema.deserialize(byte[] message)
RowData	JsonRowDataDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
TypeInformation<RowData>	AbstractJsonDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	AbstractJsonDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	JsonRowDataSerializationSchema.serialize(RowData row)

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

Constructor	Description
AbstractJsonDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat)
JsonParserRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat)
JsonParserRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat, String[][] projectedFields)
JsonRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat)

Uses of RowData in org.apache.flink.formats.json.canal

Methods in org.apache.flink.formats.json.canal that return RowData

Modifier and Type	Method	Description
RowData	CanalJsonDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DeserializationSchema<RowData>	CanalJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)
TypeInformation<RowData>	CanalJsonDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	CanalJsonDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	CanalJsonSerializationSchema.serialize(RowData row)

Method parameters in org.apache.flink.formats.json.canal with type arguments of type RowData

Modifier and Type	Method	Description
static CanalJsonDeserializationSchema.Builder	CanalJsonDeserializationSchema.builder(DataType physicalDataType, List<org.apache.flink.formats.json.canal.CanalJsonDecodingFormat.ReadableMetadata> requestedMetadata, TypeInformation<RowData> producedTypeInfo)	Creates A builder for building a CanalJsonDeserializationSchema.
void	CanalJsonDeserializationSchema.deserialize(byte[] message, Collector<RowData> out)

Uses of RowData in org.apache.flink.formats.json.debezium

Methods in org.apache.flink.formats.json.debezium that return RowData

Modifier and Type	Method	Description
RowData	DebeziumJsonDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DeserializationSchema<RowData>	DebeziumJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)
TypeInformation<RowData>	DebeziumJsonDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	DebeziumJsonDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	DebeziumJsonSerializationSchema.serialize(RowData rowData)

Method parameters in org.apache.flink.formats.json.debezium with type arguments of type RowData

Modifier and Type	Method	Description
void	DebeziumJsonDeserializationSchema.deserialize(byte[] message, Collector<RowData> out)

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

Constructor	Description
DebeziumJsonDeserializationSchema(DataType physicalDataType, List<org.apache.flink.formats.json.debezium.DebeziumJsonDecodingFormat.ReadableMetadata> requestedMetadata, TypeInformation<RowData> producedTypeInfo, boolean schemaInclude, boolean ignoreParseErrors, TimestampFormat timestampFormat)

Uses of RowData in org.apache.flink.formats.json.maxwell

Methods in org.apache.flink.formats.json.maxwell that return RowData

Modifier and Type	Method	Description
RowData	MaxwellJsonDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	MaxwellJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DeserializationSchema<RowData>	MaxwellJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)
TypeInformation<RowData>	MaxwellJsonDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	MaxwellJsonDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	MaxwellJsonSerializationSchema.serialize(RowData element)

Method parameters in org.apache.flink.formats.json.maxwell with type arguments of type RowData

Modifier and Type	Method	Description
void	MaxwellJsonDeserializationSchema.deserialize(byte[] message, Collector<RowData> out)

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

Constructor	Description
MaxwellJsonDeserializationSchema(DataType physicalDataType, List<org.apache.flink.formats.json.maxwell.MaxwellJsonDecodingFormat.ReadableMetadata> requestedMetadata, TypeInformation<RowData> producedTypeInfo, boolean ignoreParseErrors, TimestampFormat timestampFormat)

Uses of RowData in org.apache.flink.formats.json.ogg

Methods in org.apache.flink.formats.json.ogg that return RowData

Modifier and Type	Method	Description
RowData	OggJsonDeserializationSchema.deserialize(byte[] message)

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

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	OggJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	OggJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DeserializationSchema<RowData>	OggJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType)
TypeInformation<RowData>	OggJsonDeserializationSchema.getProducedType()

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

Modifier and Type	Method	Description
boolean	OggJsonDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	OggJsonSerializationSchema.serialize(RowData rowData)

Method parameters in org.apache.flink.formats.json.ogg with type arguments of type RowData

Modifier and Type	Method	Description
void	OggJsonDeserializationSchema.deserialize(byte[] message, Collector<RowData> out)

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

Constructor	Description
OggJsonDeserializationSchema(DataType physicalDataType, List<org.apache.flink.formats.json.ogg.OggJsonDecodingFormat.ReadableMetadata> requestedMetadata, TypeInformation<RowData> producedTypeInfo, boolean ignoreParseErrors, TimestampFormat timestampFormat)

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

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

Modifier and Type	Method	Description
BulkDecodingFormat<RowData>	ParquetFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<BulkWriter.Factory<RowData>>	ParquetFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
protected ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>	ParquetColumnarRowInputFormat.createReaderBatch(WritableColumnVector[] writableVectors, VectorizedColumnBatch columnarBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>> recycler)
BulkFormat<RowData,FileSourceSplit>	ParquetFileFormatFactory.ParquetBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context sourceContext, DataType producedDataType, int[][] projections)
TypeInformation<RowData>	ParquetColumnarRowInputFormat.getProducedType()

Method parameters in org.apache.flink.formats.parquet with type arguments of type RowData

Modifier and Type	Method	Description
static <SplitT extends FileSourceSplit> ParquetColumnarRowInputFormat<SplitT>	ParquetColumnarRowInputFormat.createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig, RowType producedRowType, TypeInformation<RowData> producedTypeInfo, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive)	Create a partitioned ParquetColumnarRowInputFormat, the partition columns can be generated by Path.
protected ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>	ParquetColumnarRowInputFormat.createReaderBatch(WritableColumnVector[] writableVectors, VectorizedColumnBatch columnarBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>> recycler)

Constructor parameters in org.apache.flink.formats.parquet with type arguments of type RowData

Constructor	Description
ParquetColumnarRowInputFormat(org.apache.hadoop.conf.Configuration hadoopConfig, RowType projectedType, TypeInformation<RowData> producedTypeInfo, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive)	Constructor to create parquet format without extra fields.

Uses of RowData in org.apache.flink.formats.parquet.row

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

Modifier and Type	Method	Description
org.apache.parquet.hadoop.ParquetWriter<RowData>	ParquetRowDataBuilder.FlinkParquetBuilder.createWriter(org.apache.parquet.io.OutputFile out)
static ParquetWriterFactory<RowData>	ParquetRowDataBuilder.createWriterFactory(RowType rowType, org.apache.hadoop.conf.Configuration conf, boolean utcTimestamp)	Create a parquet BulkWriter.Factory.
protected org.apache.parquet.hadoop.api.WriteSupport<RowData>	ParquetRowDataBuilder.getWriteSupport(org.apache.hadoop.conf.Configuration conf)

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

Modifier and Type	Method	Description
void	ParquetRowDataWriter.write(RowData record)	It writes a record to Parquet.

Uses of RowData in org.apache.flink.formats.protobuf

Methods in org.apache.flink.formats.protobuf that return types with arguments of type RowData

Modifier and Type	Method	Description
BulkDecodingFormat<RowData>	PbFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DecodingFormat<DeserializationSchema<RowData>>	PbFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<BulkWriter.Factory<RowData>>	PbFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	PbFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
DeserializationSchema<RowData>	PbDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)
SerializationSchema<RowData>	PbEncodingFormat.createRuntimeEncoder(DynamicTableSink.Context context, DataType consumedDataType)

Uses of RowData in org.apache.flink.formats.protobuf.deserialize

Methods in org.apache.flink.formats.protobuf.deserialize that return RowData

Modifier and Type	Method	Description
RowData	ProtoToRowConverter.convertProtoBinaryToRow(byte[] data)
RowData	PbRowDataDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.protobuf.deserialize that return types with arguments of type RowData

Modifier and Type	Method	Description
TypeInformation<RowData>	PbRowDataDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.protobuf.deserialize with parameters of type RowData

Modifier and Type	Method	Description
boolean	PbRowDataDeserializationSchema.isEndOfStream(RowData nextElement)

Constructor parameters in org.apache.flink.formats.protobuf.deserialize with type arguments of type RowData

Constructor	Description
PbRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, PbFormatConfig formatConfig)

Uses of RowData in org.apache.flink.formats.protobuf.serialize

Methods in org.apache.flink.formats.protobuf.serialize with parameters of type RowData

Modifier and Type	Method	Description
byte[]	RowToProtoConverter.convertRowToProtoBinary(RowData rowData)
byte[]	PbRowDataSerializationSchema.serialize(RowData element)

Uses of RowData in org.apache.flink.formats.raw

Methods in org.apache.flink.formats.raw that return RowData

Modifier and Type	Method	Description
RowData	RawFormatDeserializationSchema.deserialize(byte[] message)

Methods in org.apache.flink.formats.raw that return types with arguments of type RowData

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>	RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
TypeInformation<RowData>	RawFormatDeserializationSchema.getProducedType()

Methods in org.apache.flink.formats.raw with parameters of type RowData

Modifier and Type	Method	Description
boolean	RawFormatDeserializationSchema.isEndOfStream(RowData nextElement)
byte[]	RawFormatSerializationSchema.serialize(RowData row)

Constructor parameters in org.apache.flink.formats.raw with type arguments of type RowData

Constructor	Description
RawFormatDeserializationSchema(LogicalType deserializedType, TypeInformation<RowData> producedTypeInfo, String charsetName, boolean isBigEndian)

Uses of RowData in org.apache.flink.legacy.table.connector.source

Methods in org.apache.flink.legacy.table.connector.source that return types with arguments of type RowData

Modifier and Type	Method	Description
SourceFunction<RowData>	SourceFunctionProvider.createSourceFunction()	Deprecated. Creates a SourceFunction instance.

Method parameters in org.apache.flink.legacy.table.connector.source with type arguments of type RowData

Modifier and Type	Method	Description
static SourceFunctionProvider	SourceFunctionProvider.of(SourceFunction<RowData> sourceFunction, boolean isBounded)	Deprecated. Helper method for creating a static provider.
static SourceFunctionProvider	SourceFunctionProvider.of(SourceFunction<RowData> sourceFunction, boolean isBounded, Integer sourceParallelism)	Deprecated. Helper method for creating a Source provider with a provided source parallelism.

Uses of RowData in org.apache.flink.orc

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

Modifier and Type	Method	Description
RowData	OrcColumnarRowSplitReader.nextRecord(RowData reuse)

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

Modifier and Type	Method	Description
BulkDecodingFormat<RowData>	OrcFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<BulkWriter.Factory<RowData>>	OrcFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>	OrcColumnarRowInputFormat.createReaderBatch(SplitT split, OrcVectorizedBatchWrapper<BatchT> orcBatch, Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>> recycler, int batchSize)
BulkFormat<RowData,FileSourceSplit>	OrcFileFormatFactory.OrcBulkDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context sourceContext, DataType producedDataType, int[][] projections)
TypeInformation<RowData>	OrcColumnarRowInputFormat.getProducedType()

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

Modifier and Type	Method	Description
RowData	OrcColumnarRowSplitReader.nextRecord(RowData reuse)

Method parameters in org.apache.flink.orc with type arguments of type RowData

Modifier and Type	Method	Description
static <SplitT extends FileSourceSplit> OrcColumnarRowInputFormat<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch,SplitT>	OrcColumnarRowInputFormat.createPartitionedFormat(OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> shim, org.apache.hadoop.conf.Configuration hadoopConfig, RowType tableType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory)	Create a partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.
AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>	OrcColumnarRowInputFormat.createReaderBatch(SplitT split, OrcVectorizedBatchWrapper<BatchT> orcBatch, Pool.Recycler<AbstractOrcFileInputFormat.OrcReaderBatch<RowData,BatchT>> recycler, int batchSize)

Constructor parameters in org.apache.flink.orc with type arguments of type RowData

Constructor	Description
OrcColumnarRowInputFormat(OrcShim<BatchT> shim, org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, ColumnBatchFactory<BatchT,SplitT> batchFactory, TypeInformation<RowData> producedTypeInfo)

Uses of RowData in org.apache.flink.orc.nohive

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

Modifier and Type	Method	Description
BulkWriter<RowData>	OrcNoHiveBulkWriterFactory.create(FSDataOutputStream out)

Method parameters in org.apache.flink.orc.nohive with type arguments of type RowData

Modifier and Type	Method	Description
static <SplitT extends FileSourceSplit> OrcColumnarRowInputFormat<?,SplitT>	OrcNoHiveColumnarRowInputFormat.createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig, RowType tableType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory)	Create a partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.

Uses of RowData in org.apache.flink.orc.vector

Methods in org.apache.flink.orc.vector with parameters of type RowData

Modifier and Type	Method	Description
void	RowDataVectorizer.vectorize(RowData row, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)

Uses of RowData in org.apache.flink.python.util

Method parameters in org.apache.flink.python.util with type arguments of type RowData

Modifier and Type	Method	Description
void	PythonConnectorUtils.RowRowMapper.processElement(Row row, ProcessFunction.Context ctx, Collector<RowData> out)

Uses of RowData in org.apache.flink.streaming.api.utils

Methods in org.apache.flink.streaming.api.utils that return RowData

Modifier and Type	Method	Description
RowData	PythonTypeUtils.RowDataDataConverter.toInternal(Object[] value)

Methods in org.apache.flink.streaming.api.utils with parameters of type RowData

Modifier and Type	Method	Description
Object[]	PythonTypeUtils.RowDataDataConverter.toExternal(RowData value)

Uses of RowData in org.apache.flink.table.api.internal

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

Modifier and Type	Method	Description
CloseableIterator<RowData>	TableResultImpl.collectInternal()
CloseableIterator<RowData>	TableResultInternal.collectInternal()	Returns an iterator that returns the iterator with the internal row data type.
CloseableIterator<RowData>	ResultProvider.toInternalIterator()	Returns the select result as row iterator using internal data types.
CloseableIterator<RowData>	StaticResultProvider.toInternalIterator()

Constructor parameters in org.apache.flink.table.api.internal with type arguments of type RowData

Constructor	Description
StaticResultProvider(List<Row> rows, Function<Row,RowData> externalToInternalConverter)

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

Methods in org.apache.flink.table.client.gateway that return RowData

Modifier and Type	Method	Description
RowData	StatementResult.next()

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

Constructor	Description
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID)
StatementResult(ResolvedSchema resultSchema, CloseableIterator<RowData> resultProvider, boolean isQueryResult, ResultKind resultKind, JobID jobID, RowDataToStringConverter toStringConverter)

Uses of RowData in org.apache.flink.table.client.gateway.result

Fields in org.apache.flink.table.client.gateway.result with type parameters of type RowData

Modifier and Type	Field	Description
protected List<RowData>	MaterializedCollectResultBase.materializedTable	Materialized table that is continuously updated by inserts and deletes.

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

Modifier and Type	Method	Description
protected List<RowData>	MaterializedCollectResultBase.getMaterializedTable()
TypedResult<List<RowData>>	ChangelogCollectResult.retrieveChanges()
TypedResult<List<RowData>>	ChangelogResult.retrieveChanges()	Retrieves the available result records.
List<RowData>	MaterializedCollectResultBase.retrievePage(int page)
List<RowData>	MaterializedResult.retrievePage(int page)	Retrieves a page of a snapshotted result.

Methods in org.apache.flink.table.client.gateway.result with parameters of type RowData

Modifier and Type	Method	Description
protected void	ChangelogCollectResult.processRecord(RowData row)
protected abstract void	CollectResultBase.processRecord(RowData row)
protected void	MaterializedCollectBatchResult.processRecord(RowData row)
protected void	MaterializedCollectStreamResult.processRecord(RowData row)

Uses of RowData in org.apache.flink.table.connector.sink

Methods in org.apache.flink.table.connector.sink that return types with arguments of type RowData

Modifier and Type	Method	Description
OutputFormat<RowData>	OutputFormatProvider.createOutputFormat()	Creates an OutputFormat instance.
Sink<RowData>	SinkV2Provider.createSink()

Method parameters in org.apache.flink.table.connector.sink with type arguments of type RowData

Modifier and Type	Method	Description
default DataStreamSink<?>	DataStreamSinkProvider.consumeDataStream(DataStream<RowData> dataStream)	Deprecated. Use DataStreamSinkProvider.consumeDataStream(ProviderContext, DataStream) and correctly set a unique identifier for each data stream transformation.
default DataStreamSink<?>	DataStreamSinkProvider.consumeDataStream(ProviderContext providerContext, DataStream<RowData> dataStream)	Consumes the given Java DataStream and returns the sink transformation DataStreamSink.
static OutputFormatProvider	OutputFormatProvider.of(OutputFormat<RowData> outputFormat)	Helper method for creating a static provider.
static OutputFormatProvider	OutputFormatProvider.of(OutputFormat<RowData> outputFormat, Integer sinkParallelism)	Helper method for creating a static provider with a provided sink parallelism.
static SinkV2Provider	SinkV2Provider.of(Sink<RowData> sink)	Helper method for creating a static provider.
static SinkV2Provider	SinkV2Provider.of(Sink<RowData> sink, Integer sinkParallelism)	Helper method for creating a Sink provider with a provided sink parallelism.

Uses of RowData in org.apache.flink.table.connector.sink.legacy

Methods in org.apache.flink.table.connector.sink.legacy that return types with arguments of type RowData

Modifier and Type	Method	Description
SinkFunction<RowData>	SinkFunctionProvider.createSinkFunction()	Deprecated. Creates a SinkFunction instance.

Method parameters in org.apache.flink.table.connector.sink.legacy with type arguments of type RowData

Modifier and Type	Method	Description
static SinkFunctionProvider	SinkFunctionProvider.of(SinkFunction<RowData> sinkFunction)	Deprecated. Helper method for creating a static provider.
static SinkFunctionProvider	SinkFunctionProvider.of(SinkFunction<RowData> sinkFunction, Integer sinkParallelism)	Deprecated. Helper method for creating a SinkFunction provider with a provided sink parallelism.

Uses of RowData in org.apache.flink.table.connector.source

Methods in org.apache.flink.table.connector.source that return types with arguments of type RowData

Modifier and Type	Method	Description
InputFormat<RowData,?>	InputFormatProvider.createInputFormat()	Creates an InputFormat instance.
Source<RowData,?,?>	SourceProvider.createSource()	Creates a Source instance.
Collection<RowData>	DynamicFilteringData.getData()
default DataStream<RowData>	DataStreamScanProvider.produceDataStream(StreamExecutionEnvironment execEnv)	Deprecated.
default DataStream<RowData>	DataStreamScanProvider.produceDataStream(ProviderContext providerContext, StreamExecutionEnvironment execEnv)	Creates a scan Java DataStream from a StreamExecutionEnvironment.

Methods in org.apache.flink.table.connector.source with parameters of type RowData

Modifier and Type	Method	Description
boolean	DynamicFilteringData.contains(RowData row)	Returns true if the dynamic filtering data contains the specific row.

Method parameters in org.apache.flink.table.connector.source with type arguments of type RowData

Modifier and Type	Method	Description
static InputFormatProvider	InputFormatProvider.of(InputFormat<RowData,?> inputFormat)	Helper method for creating a static provider.
static InputFormatProvider	InputFormatProvider.of(InputFormat<RowData,?> inputFormat, Integer sourceParallelism)	Helper method for creating a static provider with a provided source parallelism.
static SourceProvider	SourceProvider.of(Source<RowData,?,?> source)	Helper method for creating a static provider.
static SourceProvider	SourceProvider.of(Source<RowData,?,?> source, Integer sourceParallelism)	Helper method for creating a Source provider with a provided source parallelism.

Constructor parameters in org.apache.flink.table.connector.source with type arguments of type RowData

Constructor	Description
DynamicFilteringData(TypeInformation<RowData> typeInfo, RowType rowType, List<byte[]> serializedData, boolean isFiltering)

Uses of RowData in org.apache.flink.table.connector.source.abilities

Method parameters in org.apache.flink.table.connector.source.abilities with type arguments of type RowData

Modifier and Type	Method	Description
void	SupportsWatermarkPushDown.applyWatermark(WatermarkStrategy<RowData> watermarkStrategy)	Provides a WatermarkStrategy which defines how to generate Watermarks in the stream source.

Uses of RowData in org.apache.flink.table.connector.source.lookup.cache

Methods in org.apache.flink.table.connector.source.lookup.cache that return types with arguments of type RowData

Modifier and Type	Method	Description
Collection<RowData>	DefaultLookupCache.getIfPresent(RowData key)
Collection<RowData>	LookupCache.getIfPresent(RowData key)	Returns the value associated with key in this cache, or null if there is no cached value for key.
Collection<RowData>	DefaultLookupCache.put(RowData key, Collection<RowData> value)
Collection<RowData>	LookupCache.put(RowData key, Collection<RowData> value)	Associates the specified value rows with the specified key row in the cache.

Methods in org.apache.flink.table.connector.source.lookup.cache with parameters of type RowData

Modifier and Type	Method	Description
Collection<RowData>	DefaultLookupCache.getIfPresent(RowData key)
Collection<RowData>	LookupCache.getIfPresent(RowData key)	Returns the value associated with key in this cache, or null if there is no cached value for key.
void	DefaultLookupCache.invalidate(RowData key)
void	LookupCache.invalidate(RowData key)	Discards any cached value for the specified key.
Collection<RowData>	DefaultLookupCache.put(RowData key, Collection<RowData> value)
Collection<RowData>	LookupCache.put(RowData key, Collection<RowData> value)	Associates the specified value rows with the specified key row in the cache.

Method parameters in org.apache.flink.table.connector.source.lookup.cache with type arguments of type RowData

Modifier and Type	Method	Description
Collection<RowData>	DefaultLookupCache.put(RowData key, Collection<RowData> value)
Collection<RowData>	LookupCache.put(RowData key, Collection<RowData> value)	Associates the specified value rows with the specified key row in the cache.

Uses of RowData in org.apache.flink.table.data

Classes in org.apache.flink.table.data that implement RowData

Modifier and Type	Class	Description
class	BoxedWrapperRowData	An implementation of RowData which also is also backed by an array of Java Object, just similar to GenericRowData.
class	GenericRowData	An internal data structure representing data of RowType and other (possibly nested) structured types such as StructuredType.
class	UpdatableRowData	An implementation of RowData which is backed by a RowData and an updated Java object array.

Methods in org.apache.flink.table.data that return RowData

Modifier and Type	Method	Description
RowData	ArrayData.getRow(int pos, int numFields)	Returns the row value at the given position.
RowData	BoxedWrapperRowData.getRow(int pos, int numFields)
RowData	GenericArrayData.getRow(int pos, int numFields)
RowData	GenericRowData.getRow(int pos, int numFields)
RowData	RowData.getRow(int pos, int numFields)	Returns the row value at the given position.
RowData	UpdatableRowData.getRow()
RowData	UpdatableRowData.getRow(int pos, int numFields)

Methods in org.apache.flink.table.data with parameters of type RowData

Modifier and Type	Method	Description
Object	RowData.FieldGetter.getFieldOrNull(RowData row)

Constructors in org.apache.flink.table.data with parameters of type RowData

Constructor	Description
UpdatableRowData(RowData row, int arity)

Uses of RowData in org.apache.flink.table.data.binary

Classes in org.apache.flink.table.data.binary that implement RowData

Modifier and Type	Class	Description
class	BinaryRowData	An implementation of RowData which is backed by MemorySegment instead of Object.
class	NestedRowData	Its memory storage structure is exactly the same with BinaryRowData.

Methods in org.apache.flink.table.data.binary that return RowData

Modifier and Type	Method	Description
RowData	BinaryArrayData.getRow(int pos, int numFields)
RowData	BinaryRowData.getRow(int pos, int numFields)
RowData	NestedRowData.getRow(int pos, int numFields)
static RowData	BinarySegmentUtils.readRowData(MemorySegment[] segments, int numFields, int baseOffset, long offsetAndSize)	Gets an instance of RowData from underlying MemorySegment.

Methods in org.apache.flink.table.data.binary with parameters of type RowData

Modifier and Type	Method	Description
NestedRowData	NestedRowData.copy(RowData reuse)

Uses of RowData in org.apache.flink.table.data.columnar

Classes in org.apache.flink.table.data.columnar that implement RowData

Modifier and Type	Class	Description
class	ColumnarRowData	Columnar row to support access to vector column data.

Methods in org.apache.flink.table.data.columnar that return RowData

Modifier and Type	Method	Description
RowData	ColumnarArrayData.getRow(int pos, int numFields)
RowData	ColumnarRowData.getRow(int pos, int numFields)

Uses of RowData in org.apache.flink.table.data.columnar.vector

Methods in org.apache.flink.table.data.columnar.vector that return RowData

Modifier and Type	Method	Description
RowData	VectorizedColumnBatch.getRow(int rowId, int colId)

Uses of RowData in org.apache.flink.table.data.conversion

Methods in org.apache.flink.table.data.conversion that return RowData

Modifier and Type	Method	Description
RowData	RowRowConverter.toInternal(Row external)
RowData	StructuredObjectConverter.toInternal(T external)

Methods in org.apache.flink.table.data.conversion with parameters of type RowData

Modifier and Type	Method	Description
Row	RowRowConverter.toExternal(RowData internal)
T	StructuredObjectConverter.toExternal(RowData internal)

Uses of RowData in org.apache.flink.table.data.util

Methods in org.apache.flink.table.data.util with parameters of type RowData

Modifier and Type	Method	Description
static boolean	RowDataUtil.isAccumulateMsg(RowData row)	Returns true if the message is either RowKind.INSERT or RowKind.UPDATE_AFTER, which refers to an accumulate operation of aggregation.
static boolean	RowDataUtil.isRetractMsg(RowData row)	Returns true if the message is either RowKind.DELETE or RowKind.UPDATE_BEFORE, which refers to a retract operation of aggregation.
External	DataFormatConverters.DataFormatConverter.toExternal(RowData row, int column)	Given a internalType row, convert the value at column `column` to its external(Java) equivalent.

Uses of RowData in org.apache.flink.table.data.utils

Classes in org.apache.flink.table.data.utils that implement RowData

Modifier and Type	Class	Description
class	JoinedRowData	An implementation of RowData which is backed by two concatenated RowData.
class	ProjectedRowData	An implementation of RowData which provides a projected view of the underlying RowData.

Methods in org.apache.flink.table.data.utils that return RowData

Modifier and Type	Method	Description
RowData	JoinedRowData.getRow(int pos, int numFields)
RowData	ProjectedRowData.getRow(int pos, int numFields)

Methods in org.apache.flink.table.data.utils with parameters of type RowData

Modifier and Type	Method	Description
JoinedRowData	JoinedRowData.replace(RowData row1, RowData row2)	Replaces the RowData backing this JoinedRowData.
ProjectedRowData	ProjectedRowData.replaceRow(RowData row)	Replaces the underlying RowData backing this ProjectedRowData.

Constructors in org.apache.flink.table.data.utils with parameters of type RowData

Constructor	Description
JoinedRowData(RowData row1, RowData row2)	Creates a new JoinedRowData of kind RowKind.INSERT backed by {@param row1} and {@param row2}.
JoinedRowData(RowKind rowKind, RowData row1, RowData row2)	Creates a new JoinedRowData of kind {@param rowKind} backed by {@param row1} and {@param row2}.

Uses of RowData in org.apache.flink.table.data.writer

Methods in org.apache.flink.table.data.writer with parameters of type RowData

Modifier and Type	Method	Description
void	BinaryWriter.writeRow(int pos, RowData value, RowDataSerializer serializer)

Uses of RowData in org.apache.flink.table.examples.java.connectors

Methods in org.apache.flink.table.examples.java.connectors that return RowData

Modifier and Type	Method	Description
RowData	ChangelogCsvDeserializer.deserialize(byte[] message)

Methods in org.apache.flink.table.examples.java.connectors that return types with arguments of type RowData

Modifier and Type	Method	Description
DecodingFormat<DeserializationSchema<RowData>>	ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
SourceReader<RowData,SocketSource.DummySplit>	SocketSource.createReader(SourceReaderContext readerContext)
DeserializationSchema<RowData>	ChangelogCsvFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)
TypeInformation<RowData>	ChangelogCsvDeserializer.getProducedType()
TypeInformation<RowData>	SocketSource.getProducedType()

Methods in org.apache.flink.table.examples.java.connectors with parameters of type RowData

Modifier and Type	Method	Description
boolean	ChangelogCsvDeserializer.isEndOfStream(RowData nextElement)

Constructor parameters in org.apache.flink.table.examples.java.connectors with type arguments of type RowData

Constructor	Description
ChangelogCsvDeserializer(List<LogicalType> parsingTypes, DynamicTableSource.DataStructureConverter converter, TypeInformation<RowData> producedTypeInfo, String columnDelimiter)
SocketDynamicTableSource(String hostname, int port, byte byteDelimiter, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType)
SocketSource(String hostname, int port, byte byteDelimiter, DeserializationSchema<RowData> deserializer)

Uses of RowData in org.apache.flink.table.examples.java.functions

Methods in org.apache.flink.table.examples.java.functions that return RowData

Modifier and Type	Method	Description
RowData	InternalRowMergerFunction.eval(RowData r1, RowData r2)

Methods in org.apache.flink.table.examples.java.functions with parameters of type RowData

Modifier and Type	Method	Description
RowData	InternalRowMergerFunction.eval(RowData r1, RowData r2)

Uses of RowData in org.apache.flink.table.functions

Methods in org.apache.flink.table.functions that return types with arguments of type RowData

Modifier and Type	Method	Description
abstract CompletableFuture<Collection<RowData>>	AsyncLookupFunction.asyncLookup(RowData keyRow)	Asynchronously lookup rows matching the lookup keys.
abstract Collection<RowData>	LookupFunction.lookup(RowData keyRow)	Synchronously lookup rows matching the lookup keys.

Methods in org.apache.flink.table.functions with parameters of type RowData

Modifier and Type	Method	Description
abstract CompletableFuture<Collection<RowData>>	AsyncLookupFunction.asyncLookup(RowData keyRow)	Asynchronously lookup rows matching the lookup keys.
abstract Collection<RowData>	LookupFunction.lookup(RowData keyRow)	Synchronously lookup rows matching the lookup keys.

Method parameters in org.apache.flink.table.functions with type arguments of type RowData

Modifier and Type	Method	Description
void	AsyncLookupFunction.eval(CompletableFuture<Collection<RowData>> future, Object... keys)	Invokes AsyncLookupFunction.asyncLookup(org.apache.flink.table.data.RowData) and chains futures.

Uses of RowData in org.apache.flink.table.gateway.api.results

Methods in org.apache.flink.table.gateway.api.results that return types with arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	ResultSet.getData()	All the data in the current results.
List<RowData>	ResultSetImpl.getData()

Constructor parameters in org.apache.flink.table.gateway.api.results with type arguments of type RowData

Constructor	Description
ResultSetImpl(ResultSet.ResultType resultType, Long nextToken, ResolvedSchema resultSchema, List<RowData> data, RowDataToStringConverter converter, boolean isQueryResult, JobID jobID, ResultKind resultKind)

Uses of RowData in org.apache.flink.table.gateway.rest.serde

Methods in org.apache.flink.table.gateway.rest.serde that return types with arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	ResultInfo.getData()	Get the data.

Uses of RowData in org.apache.flink.table.gateway.rest.util

Methods in org.apache.flink.table.gateway.rest.util that return RowData

Modifier and Type	Method	Description
RowData	RowDataLocalTimeZoneConverter.convertTimeZoneRowData(RowData rowData)

Methods in org.apache.flink.table.gateway.rest.util with parameters of type RowData

Modifier and Type	Method	Description
RowData	RowDataLocalTimeZoneConverter.convertTimeZoneRowData(RowData rowData)

Uses of RowData in org.apache.flink.table.gateway.service.result

Methods in org.apache.flink.table.gateway.service.result that return types with arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	NotReadyResult.getData()
Optional<List<RowData>>	ResultStore.retrieveRecords()

Method parameters in org.apache.flink.table.gateway.service.result with type arguments of type RowData

Modifier and Type	Method	Description
static ResultFetcher	ResultFetcher.fromResults(OperationHandle operationHandle, ResolvedSchema resultSchema, List<RowData> results)
static ResultFetcher	ResultFetcher.fromResults(OperationHandle operationHandle, ResolvedSchema resultSchema, List<RowData> results, JobID jobID, ResultKind resultKind)

Constructor parameters in org.apache.flink.table.gateway.service.result with type arguments of type RowData

Constructor	Description
ResultStore(CloseableIterator<RowData> result, int maxBufferSize)

Uses of RowData in org.apache.flink.table.jdbc

Constructor parameters in org.apache.flink.table.jdbc with type arguments of type RowData

Constructor	Description
FlinkResultSet(Statement statement, CloseableResultIterator<RowData> iterator, ResolvedSchema schema)

Uses of RowData in org.apache.flink.table.jdbc.utils

Methods in org.apache.flink.table.jdbc.utils that return RowData

Modifier and Type	Method	Description
RowData	CollectionResultIterator.next()
RowData	StatementResultIterator.next()

Constructor parameters in org.apache.flink.table.jdbc.utils with type arguments of type RowData

Constructor	Description
CollectionResultIterator(Iterator<RowData> iterator)

Uses of RowData in org.apache.flink.table.planner.codegen

Methods in org.apache.flink.table.planner.codegen that return types with arguments of type RowData

Modifier and Type	Method	Description
static GeneratedFunction<AsyncFunction<RowData,RowData>>	AsyncCodeGenerator.generateFunction(String name, RowType inputType, RowType returnType, List<org.apache.calcite.rex.RexNode> calcProjection, boolean retainHeader, ReadableConfig tableConfig, ClassLoader classLoader)	Creates a generated function which produces an AsyncFunction which executes the calc projections.
static GeneratedFunction<AsyncFunction<RowData,RowData>>	AsyncCodeGenerator.generateFunction(String name, RowType inputType, RowType returnType, List<org.apache.calcite.rex.RexNode> calcProjection, boolean retainHeader, ReadableConfig tableConfig, ClassLoader classLoader)	Creates a generated function which produces an AsyncFunction which executes the calc projections.

Uses of RowData in org.apache.flink.table.planner.connectors

Methods in org.apache.flink.table.planner.connectors that return types with arguments of type RowData

Modifier and Type	Method	Description
Transformation<RowData>	TransformationScanProvider.createTransformation(ProviderContext providerContext)	Creates a Transformation instance.
Transformation<RowData>	TransformationSinkProvider.Context.getInputTransformation()	Input transformation to transform.

Uses of RowData in org.apache.flink.table.planner.functions.casting

Methods in org.apache.flink.table.planner.functions.casting with parameters of type RowData

Modifier and Type	Method	Description
String[]	RowDataToStringConverterImpl.convert(RowData rowData)

Uses of RowData in org.apache.flink.table.planner.plan.fusion

Methods in org.apache.flink.table.planner.plan.fusion that return types with arguments of type RowData

Modifier and Type	Method	Description
Class<? extends RowData>	OpFusionCodegenSpec.getInputRowDataClass(int inputId)	Specific inputId of current operator needed RowData type, this is used to notify the upstream operator wrap the proper RowData we needed before call doProcessConsume method.

Uses of RowData in org.apache.flink.table.planner.plan.nodes.exec.batch

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch that return types with arguments of type RowData

Modifier and Type	Method	Description
protected Transformation<RowData>	BatchExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
protected Transformation<RowData>	BatchExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
Transformation<RowData>	BatchExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
protected Transformation<RowData>	BatchExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected Transformation<RowData>	BatchExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecBoundedStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecExecutionOrderEnforcer.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecHashAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecHashJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecHashWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecInputAdapter.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
Transformation<RowData>	BatchExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecNestedLoopJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecScriptTransform.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecSortAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecSortMergeJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecSortWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.batch with type arguments of type RowData

Modifier and Type	Method	Description
protected Transformation<RowData>	BatchExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
Transformation<RowData>	BatchExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
Transformation<RowData>	BatchExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
protected Transformation<RowData>	BatchExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected Transformation<RowData>	BatchExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Uses of RowData in org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch.runtimefilter that return types with arguments of type RowData

Modifier and Type	Method	Description
protected Transformation<RowData>	BatchExecGlobalRuntimeFilterBuilder.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecLocalRuntimeFilterBuilder.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	BatchExecRuntimeFilter.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)

Uses of RowData in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common that return types with arguments of type RowData

Modifier and Type	Method	Description
protected abstract Transformation<RowData>	CommonExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
protected abstract Transformation<RowData>	CommonExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
protected abstract Transformation<RowData>	CommonExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)	Creates a Transformation based on the given InputFormat.
protected Transformation<RowData>	CommonExecLookupJoin.createJoinTransformation(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, boolean upsertMaterialize, boolean lookupKeyContainsPrimaryKey)
protected Transformation<RowData>	CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment env, SourceFunction<RowData> function, boolean isBounded, String operatorName, TypeInformation<RowData> outputTypeInfo, int sourceParallelism, boolean sourceParallelismConfigured)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
protected ProcessFunction<RowData,RowData>	CommonExecLookupJoin.createSyncLookupJoinFunction(org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled)
protected ProcessFunction<RowData,RowData>	CommonExecLookupJoin.createSyncLookupJoinFunction(org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled)
protected abstract Transformation<RowData>	CommonExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected abstract Transformation<RowData>	CommonExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
static Tuple2<Pattern<RowData,RowData>,List<String>>	CommonExecMatch.translatePattern(MatchSpec matchSpec, ReadableConfig config, ClassLoader classLoader, RelBuilder relBuilder, RowType inputRowType)
static Tuple2<Pattern<RowData,RowData>,List<String>>	CommonExecMatch.translatePattern(MatchSpec matchSpec, ReadableConfig config, ClassLoader classLoader, RelBuilder relBuilder, RowType inputRowType)
protected Transformation<RowData>	CommonExecAsyncCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecExpand.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecLegacyTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecMatch.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecPythonCalc.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecPythonCorrelate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecTableSourceScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecUnion.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecValues.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	CommonExecWindowTableFunction.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected abstract Transformation<RowData>	CommonExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.common with type arguments of type RowData

Modifier and Type	Method	Description
protected abstract Transformation<RowData>	CommonExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
protected abstract Transformation<RowData>	CommonExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)	Creates a Transformation based on the given InputFormat.
protected abstract Transformation<RowData>	CommonExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)	Creates a Transformation based on the given InputFormat.
protected Transformation<Object>	CommonExecSink.createSinkTransformation(StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, Transformation<RowData> inputTransform, DynamicTableSink tableSink, int rowtimeFieldIndex, boolean upsertMaterialize, int[] inputUpsertKey)
protected Transformation<RowData>	CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment env, SourceFunction<RowData> function, boolean isBounded, String operatorName, TypeInformation<RowData> outputTypeInfo, int sourceParallelism, boolean sourceParallelismConfigured)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
protected Transformation<RowData>	CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment env, SourceFunction<RowData> function, boolean isBounded, String operatorName, TypeInformation<RowData> outputTypeInfo, int sourceParallelism, boolean sourceParallelismConfigured)	Deprecated. This method relies on the SourceFunction API, which is due to be removed.
protected abstract Transformation<RowData>	CommonExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected abstract Transformation<RowData>	CommonExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
protected abstract Transformation<RowData>	CommonExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Uses of RowData in org.apache.flink.table.planner.plan.nodes.exec.stream

Methods in org.apache.flink.table.planner.plan.nodes.exec.stream that return types with arguments of type RowData

Modifier and Type	Method	Description
protected Transformation<RowData>	StreamExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
protected Transformation<RowData>	StreamExecLegacyTableSourceScan.createConversionTransformationIfNeeded(StreamExecutionEnvironment streamExecEnv, ExecNodeConfig config, ClassLoader classLoader, Transformation<?> sourceTransform, org.apache.calcite.rex.RexNode rowtimeExpression)
Transformation<RowData>	StreamExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
protected Transformation<RowData>	StreamExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
Transformation<RowData>	StreamExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecChangelogNormalize.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecDataStreamScan.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecDropUpdateBefore.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecExchange.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecGlobalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecGlobalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecIncrementalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecIntervalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecLocalGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecLocalWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
Transformation<RowData>	StreamExecLookupJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecMiniBatchAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecMultipleInput.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecPythonGroupAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecPythonGroupTableAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecPythonGroupWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecPythonOverAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecSortLimit.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecTemporalJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecTemporalSort.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWatermarkAssigner.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowAggregate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowDeduplicate.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowJoin.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowRank.translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.stream with type arguments of type RowData

Modifier and Type	Method	Description
protected Transformation<RowData>	StreamExecSink.applyUpsertMaterialize(Transformation<RowData> inputTransform, int[] primaryKeys, int sinkParallelism, ExecNodeConfig config, ClassLoader classLoader, RowType physicalRowType, int[] inputUpsertKey)
Transformation<RowData>	StreamExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
Transformation<RowData>	StreamExecTableSourceScan.createInputFormatTransformation(StreamExecutionEnvironment env, InputFormat<RowData,?> inputFormat, InternalTypeInfo<RowData> outputTypeInfo, String operatorName)
protected Transformation<RowData>	StreamExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
Transformation<RowData>	StreamExecMatch.translateOrder(org.apache.flink.table.planner.delegation.PlannerBase planner, Transformation<RowData> inputTransform, RowType inputRowType, ExecEdge inputEdge, ExecNodeConfig config)
protected Transformation<RowData>	StreamExecWindowTableFunction.translateWithUnalignedWindow(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, RowType inputRowType, Transformation<RowData> inputTransform)

Uses of RowData in org.apache.flink.table.planner.plan.utils

Fields in org.apache.flink.table.planner.plan.utils with type parameters of type RowData

Modifier and Type	Field	Description
AsyncRetryStrategy<RowData>	AsyncUtil.Options.asyncRetryStrategy

Methods in org.apache.flink.table.planner.plan.utils that return types with arguments of type RowData

Modifier and Type	Method	Description
static CoBundleTrigger<RowData,RowData>	MinibatchUtil.createMiniBatchCoTrigger(ReadableConfig config)	Creates a MiniBatch trigger depends on the config for two input.
static CoBundleTrigger<RowData,RowData>	MinibatchUtil.createMiniBatchCoTrigger(ReadableConfig config)	Creates a MiniBatch trigger depends on the config for two input.
static CountBundleTrigger<RowData>	MinibatchUtil.createMiniBatchTrigger(ReadableConfig config)	Creates a MiniBatch trigger depends on the config for one input.

Method parameters in org.apache.flink.table.planner.plan.utils with type arguments of type RowData

Modifier and Type	Method	Description
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(ClassLoader classLoader, int[] keyFields, InternalTypeInfo<RowData> rowType)
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(ClassLoader classLoader, int[] keyFields, InternalTypeInfo<RowData> rowType, Class<? extends RowData> outClass)	Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.
static RowDataKeySelector	KeySelectorUtil.getRowDataSelector(ClassLoader classLoader, int[] keyFields, InternalTypeInfo<RowData> rowType, Class<? extends RowData> outClass)	Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.

Constructor parameters in org.apache.flink.table.planner.plan.utils with type arguments of type RowData

Constructor	Description
Options(int asyncBufferCapacity, long asyncTimeout, AsyncDataStream.OutputMode asyncOutputMode, AsyncRetryStrategy<RowData> asyncRetryStrategy)

Uses of RowData in org.apache.flink.table.runtime.arrow

Methods in org.apache.flink.table.runtime.arrow that return RowData

Modifier and Type	Method	Description
RowData	ArrowReader.read(int rowId)	Read the specified row from underlying Arrow format data.

Methods in org.apache.flink.table.runtime.arrow that return types with arguments of type RowData

Modifier and Type	Method	Description
static ArrowWriter<RowData>	ArrowUtils.createRowDataArrowWriter(org.apache.arrow.vector.VectorSchemaRoot root, RowType rowType)	Creates an ArrowWriter for the specified VectorSchemaRoot.

Uses of RowData in org.apache.flink.table.runtime.arrow.serializers

Methods in org.apache.flink.table.runtime.arrow.serializers that return RowData

Modifier and Type	Method	Description
RowData	ArrowSerializer.read(int i)

Methods in org.apache.flink.table.runtime.arrow.serializers that return types with arguments of type RowData

Modifier and Type	Method	Description
ArrowWriter<RowData>	ArrowSerializer.createArrowWriter()	Creates an ArrowWriter.

Methods in org.apache.flink.table.runtime.arrow.serializers with parameters of type RowData

Modifier and Type	Method	Description
void	ArrowSerializer.write(RowData element)

Uses of RowData in org.apache.flink.table.runtime.arrow.sources

Methods in org.apache.flink.table.runtime.arrow.sources that return types with arguments of type RowData

Modifier and Type	Method	Description
DataStream<RowData>	ArrowTableSource.getDataStream(StreamExecutionEnvironment execEnv)
TypeInformation<RowData>	ArrowSourceFunction.getProducedType()	Deprecated.

Method parameters in org.apache.flink.table.runtime.arrow.sources with type arguments of type RowData

Modifier and Type	Method	Description
void	ArrowSourceFunction.run(SourceFunction.SourceContext<RowData> ctx)	Deprecated.

Uses of RowData in org.apache.flink.table.runtime.arrow.writers

Methods in org.apache.flink.table.runtime.arrow.writers that return types with arguments of type RowData

Modifier and Type	Method	Description
static ArrayWriter<RowData>	ArrayWriter.forRow(org.apache.arrow.vector.complex.ListVector listVector, ArrowFieldWriter<ArrayData> elementWriter)
static BigIntWriter<RowData>	BigIntWriter.forRow(org.apache.arrow.vector.BigIntVector bigIntVector)
static BinaryWriter<RowData>	BinaryWriter.forRow(org.apache.arrow.vector.FixedSizeBinaryVector fixedSizeBinaryVector)
static BooleanWriter<RowData>	BooleanWriter.forRow(org.apache.arrow.vector.BitVector bitVector)
static DateWriter<RowData>	DateWriter.forRow(org.apache.arrow.vector.DateDayVector dateDayVector)
static DecimalWriter<RowData>	DecimalWriter.forRow(org.apache.arrow.vector.DecimalVector decimalVector, int precision, int scale)
static DoubleWriter<RowData>	DoubleWriter.forRow(org.apache.arrow.vector.Float8Vector doubleVector)
static FloatWriter<RowData>	FloatWriter.forRow(org.apache.arrow.vector.Float4Vector floatVector)
static IntWriter<RowData>	IntWriter.forRow(org.apache.arrow.vector.IntVector intVector)
static MapWriter<RowData>	MapWriter.forRow(org.apache.arrow.vector.complex.MapVector mapVector, ArrowFieldWriter<ArrayData> keyWriter, ArrowFieldWriter<ArrayData> valueWriter)
static RowWriter<RowData>	RowWriter.forRow(org.apache.arrow.vector.complex.StructVector structVector, ArrowFieldWriter<RowData>[] fieldsWriters)
static SmallIntWriter<RowData>	SmallIntWriter.forRow(org.apache.arrow.vector.SmallIntVector intVector)
static TimestampWriter<RowData>	TimestampWriter.forRow(org.apache.arrow.vector.ValueVector valueVector, int precision)
static TimeWriter<RowData>	TimeWriter.forRow(org.apache.arrow.vector.ValueVector valueVector)
static TinyIntWriter<RowData>	TinyIntWriter.forRow(org.apache.arrow.vector.TinyIntVector tinyIntVector)
static VarBinaryWriter<RowData>	VarBinaryWriter.forRow(org.apache.arrow.vector.VarBinaryVector varBinaryVector)
static VarCharWriter<RowData>	VarCharWriter.forRow(org.apache.arrow.vector.VarCharVector varCharVector)

Uses of RowData in org.apache.flink.table.runtime.context

Methods in org.apache.flink.table.runtime.context that return RowData

Modifier and Type	Method	Description
RowData	ExecutionContext.currentKey()
RowData	ExecutionContextImpl.currentKey()

Methods in org.apache.flink.table.runtime.context with parameters of type RowData

Modifier and Type	Method	Description
void	ExecutionContext.setCurrentKey(RowData key)	Sets current key.
void	ExecutionContextImpl.setCurrentKey(RowData key)

Uses of RowData in org.apache.flink.table.runtime.functions.aggregate

Methods in org.apache.flink.table.runtime.functions.aggregate that return RowData

Modifier and Type	Method	Description
RowData	FirstValueAggFunction.createAccumulator()
RowData	LastValueAggFunction.createAccumulator()

Methods in org.apache.flink.table.runtime.functions.aggregate with parameters of type RowData

Modifier and Type	Method	Description
void	FirstValueAggFunction.accumulate(RowData rowData, Object value)
void	FirstValueAggFunction.accumulate(RowData rowData, Object value, Long order)
void	FirstValueAggFunction.accumulate(RowData rowData, StringData value)
void	FirstValueAggFunction.accumulate(RowData rowData, StringData value, Long order)
void	LastValueAggFunction.accumulate(RowData rowData, Object value)
void	LastValueAggFunction.accumulate(RowData rowData, Object value, Long order)
T	FirstValueAggFunction.getValue(RowData acc)
T	LastValueAggFunction.getValue(RowData rowData)
void	FirstValueAggFunction.resetAccumulator(RowData rowData)
void	LastValueAggFunction.resetAccumulator(RowData rowData)

Uses of RowData in org.apache.flink.table.runtime.functions.table.lookup

Methods in org.apache.flink.table.runtime.functions.table.lookup that return types with arguments of type RowData

Modifier and Type	Method	Description
CompletableFuture<Collection<RowData>>	CachingAsyncLookupFunction.asyncLookup(RowData keyRow)
Collection<RowData>	CachingLookupFunction.lookup(RowData keyRow)

Methods in org.apache.flink.table.runtime.functions.table.lookup with parameters of type RowData

Modifier and Type	Method	Description
CompletableFuture<Collection<RowData>>	CachingAsyncLookupFunction.asyncLookup(RowData keyRow)
Collection<RowData>	CachingLookupFunction.lookup(RowData keyRow)

Uses of RowData in org.apache.flink.table.runtime.functions.table.lookup.fullcache

Fields in org.apache.flink.table.runtime.functions.table.lookup.fullcache with type parameters of type RowData

Modifier and Type	Field	Description
protected ConcurrentHashMap<RowData,Collection<RowData>>	CacheLoader.cache
protected ConcurrentHashMap<RowData,Collection<RowData>>	CacheLoader.cache

Methods in org.apache.flink.table.runtime.functions.table.lookup.fullcache that return types with arguments of type RowData

Modifier and Type	Method	Description
ConcurrentHashMap<RowData,Collection<RowData>>	CacheLoader.getCache()
ConcurrentHashMap<RowData,Collection<RowData>>	CacheLoader.getCache()
Collection<RowData>	LookupFullCache.getIfPresent(RowData key)
Collection<RowData>	LookupFullCache.put(RowData key, Collection<RowData> value)

Methods in org.apache.flink.table.runtime.functions.table.lookup.fullcache with parameters of type RowData

Modifier and Type	Method	Description
Collection<RowData>	LookupFullCache.getIfPresent(RowData key)
void	LookupFullCache.invalidate(RowData key)
Collection<RowData>	LookupFullCache.put(RowData key, Collection<RowData> value)

Method parameters in org.apache.flink.table.runtime.functions.table.lookup.fullcache with type arguments of type RowData

Modifier and Type	Method	Description
Collection<RowData>	LookupFullCache.put(RowData key, Collection<RowData> value)

Uses of RowData in org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat

Constructor parameters in org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat with type arguments of type RowData

Constructor	Description
InputFormatCacheLoader(InputFormat<RowData,?> initialInputFormat, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer)
InputSplitCacheLoadTask(ConcurrentHashMap<RowData,Collection<RowData>> cache, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer, InputFormat<RowData,InputSplit> inputFormat, InputSplit inputSplit)
InputSplitCacheLoadTask(ConcurrentHashMap<RowData,Collection<RowData>> cache, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer, InputFormat<RowData,InputSplit> inputFormat, InputSplit inputSplit)
InputSplitCacheLoadTask(ConcurrentHashMap<RowData,Collection<RowData>> cache, GenericRowDataKeySelector keySelector, RowDataSerializer cacheEntriesSerializer, InputFormat<RowData,InputSplit> inputFormat, InputSplit inputSplit)

Uses of RowData in org.apache.flink.table.runtime.generated

Classes in org.apache.flink.table.runtime.generated with type parameters of type RowData

Modifier and Type	Interface	Description
interface	Projection<IN extends RowData,OUT extends RowData>	Interface for code generated projection, which will map a RowData to another one.
interface	Projection<IN extends RowData,OUT extends RowData>	Interface for code generated projection, which will map a RowData to another one.

Methods in org.apache.flink.table.runtime.generated that return RowData

Modifier and Type	Method	Description
RowData	AggsHandleFunctionBase.createAccumulators()	Initializes the accumulators and save them to a accumulators row.
RowData	NamespaceAggsHandleFunctionBase.createAccumulators()	Initializes the accumulators and save them to a accumulators row.
RowData	AggsHandleFunctionBase.getAccumulators()	Gets the current accumulators (saved in a row) which contains the current aggregated results.
RowData	NamespaceAggsHandleFunctionBase.getAccumulators()	Gets the current accumulators (saved in a row) which contains the current aggregated results.
RowData	AggsHandleFunction.getValue()	Gets the result of the aggregation from the current accumulators.
RowData	NamespaceAggsHandleFunction.getValue(N namespace)	Gets the result of the aggregation from the current accumulators and namespace properties (like window start).

Methods in org.apache.flink.table.runtime.generated that return types with arguments of type RowData

Modifier and Type	Method	Description
WatermarkGenerator<RowData>	GeneratedWatermarkGeneratorSupplier.createWatermarkGenerator(WatermarkGeneratorSupplier.Context context)

Methods in org.apache.flink.table.runtime.generated with parameters of type RowData

Modifier and Type	Method	Description
void	AggsHandleFunctionBase.accumulate(RowData input)	Accumulates the input values to the accumulators.
void	NamespaceAggsHandleFunctionBase.accumulate(RowData inputRow)	Accumulates the input values to the accumulators.
boolean	FilterCondition.apply(RowData in)
boolean	JoinCondition.apply(RowData in1, RowData in2)
int	RecordComparator.compare(RowData o1, RowData o2)
abstract Long	WatermarkGenerator.currentWatermark(RowData row)	Returns the watermark for the current row or null if no watermark should be generated.
void	NamespaceTableAggsHandleFunction.emitValue(N namespace, RowData key, Collector<RowData> out)	Emits the result of the aggregation from the current accumulators and namespace properties (like window start).
void	TableAggsHandleFunction.emitValue(Collector<RowData> out, RowData currentKey, boolean isRetract)	Emit the result of the table aggregation through the collector.
boolean	RecordEqualiser.equals(RowData row1, RowData row2)	Returns true if the rows are equal to each other and false otherwise.
void	AggsHandleFunctionBase.merge(RowData accumulators)	Merges the other accumulators into current accumulators.
void	NamespaceAggsHandleFunctionBase.merge(N namespace, RowData otherAcc)	Merges the other accumulators into current accumulators.
void	GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator.onEvent(RowData event, long eventTimestamp, WatermarkOutput output)
void	NormalizedKeyComputer.putKey(RowData record, MemorySegment target, int offset)	Writes a normalized key for the given record into the target MemorySegment.
void	AggsHandleFunctionBase.retract(RowData input)	Retracts the input values from the accumulators.
void	NamespaceAggsHandleFunctionBase.retract(RowData inputRow)	Retracts the input values from the accumulators.
void	AggsHandleFunctionBase.setAccumulators(RowData accumulators)	Set the current accumulators (saved in a row) which contains the current aggregated results.
void	NamespaceAggsHandleFunctionBase.setAccumulators(N namespace, RowData accumulators)	Set the current accumulators (saved in a row) which contains the current aggregated results.

Method parameters in org.apache.flink.table.runtime.generated with type arguments of type RowData

Modifier and Type	Method	Description
void	NamespaceTableAggsHandleFunction.emitValue(N namespace, RowData key, Collector<RowData> out)	Emits the result of the aggregation from the current accumulators and namespace properties (like window start).
void	TableAggsHandleFunction.emitValue(Collector<RowData> out, RowData currentKey, boolean isRetract)	Emit the result of the table aggregation through the collector.

Uses of RowData in org.apache.flink.table.runtime.hashtable

Classes in org.apache.flink.table.runtime.hashtable with type parameters of type RowData

Modifier and Type	Class	Description
class	WrappedRowIterator<T extends RowData>	Wrap MutableObjectIterator to java RowIterator.

Methods in org.apache.flink.table.runtime.hashtable that return RowData

Modifier and Type	Method	Description
RowData	ProbeIterator.current()
RowData	BinaryHashTable.getCurrentProbeRow()
RowData	LongHybridHashTable.getCurrentProbeRow()

Methods in org.apache.flink.table.runtime.hashtable with parameters of type RowData

Modifier and Type	Method	Description
abstract long	LongHybridHashTable.getBuildLongKey(RowData row)	For code gen get build side long key.
abstract long	LongHybridHashTable.getProbeLongKey(RowData row)	For code gen get probe side long key.
void	LongHybridHashTable.insertIntoProbeBuffer(RowData probeRecord)	If the probe row corresponding partition has been spilled to disk, just call this method spill probe row to disk.
abstract BinaryRowData	LongHybridHashTable.probeToBinary(RowData row)	For code gen probe side to BinaryRowData.
void	BinaryHashTable.putBuildRow(RowData row)	Put a build side row to hash table.
void	ProbeIterator.setInstance(RowData instance)
boolean	BinaryHashTable.tryProbe(RowData record)	Find matched build side rows for a probe row.
boolean	LongHybridHashTable.tryProbe(RowData record)

Constructor parameters in org.apache.flink.table.runtime.hashtable with type arguments of type RowData

Constructor

Description

BinaryHashTable(Object owner, boolean compressionEnabled, int compressionBlockSize, AbstractRowDataSerializer buildSideSerializer, AbstractRowDataSerializer probeSideSerializer, Projection<RowData,BinaryRowData> buildSideProjection, Projection<RowData,BinaryRowData> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)

Uses of RowData in org.apache.flink.table.runtime.keyselector

Methods in org.apache.flink.table.runtime.keyselector that return RowData

Modifier and Type	Method	Description
RowData	BinaryRowDataKeySelector.getKey(RowData value)
RowData	EmptyRowDataKeySelector.getKey(RowData value)
RowData	GenericRowDataKeySelector.getKey(RowData value)

Methods in org.apache.flink.table.runtime.keyselector that return types with arguments of type RowData

Modifier and Type	Method	Description
InternalTypeInfo<RowData>	BinaryRowDataKeySelector.getProducedType()
InternalTypeInfo<RowData>	EmptyRowDataKeySelector.getProducedType()
InternalTypeInfo<RowData>	GenericRowDataKeySelector.getProducedType()
InternalTypeInfo<RowData>	RowDataKeySelector.getProducedType()

Methods in org.apache.flink.table.runtime.keyselector with parameters of type RowData

Modifier and Type	Method	Description
RowData	BinaryRowDataKeySelector.getKey(RowData value)
RowData	EmptyRowDataKeySelector.getKey(RowData value)
RowData	GenericRowDataKeySelector.getKey(RowData value)

Constructor parameters in org.apache.flink.table.runtime.keyselector with type arguments of type RowData

Constructor	Description
BinaryRowDataKeySelector(InternalTypeInfo<RowData> keyRowType, GeneratedProjection generatedProjection)
GenericRowDataKeySelector(InternalTypeInfo<RowData> keyRowType, RowDataSerializer keySerializer, GeneratedProjection generatedProjection)

Uses of RowData in org.apache.flink.table.runtime.operators.aggregate

Methods in org.apache.flink.table.runtime.operators.aggregate that return RowData

Modifier and Type	Method	Description
RowData	MiniBatchGlobalGroupAggFunction.addInput(RowData previousAcc, RowData input)	The previousAcc is accumulator, but input is a row in <key, accumulator> schema, the specific generated MiniBatchGlobalGroupAggFunction.localAgg will project the input to accumulator in merge method.
RowData	MiniBatchIncrementalGroupAggFunction.addInput(RowData previousAcc, RowData input)
RowData	MiniBatchLocalGroupAggFunction.addInput(RowData previousAcc, RowData input)

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

Modifier and Type	Method	Description
List<RowData>	MiniBatchGroupAggFunction.addInput(List<RowData> value, RowData input)

Methods in org.apache.flink.table.runtime.operators.aggregate with parameters of type RowData

Modifier and Type	Method	Description
RowData	MiniBatchGlobalGroupAggFunction.addInput(RowData previousAcc, RowData input)	The previousAcc is accumulator, but input is a row in <key, accumulator> schema, the specific generated MiniBatchGlobalGroupAggFunction.localAgg will project the input to accumulator in merge method.
List<RowData>	MiniBatchGroupAggFunction.addInput(List<RowData> value, RowData input)
RowData	MiniBatchIncrementalGroupAggFunction.addInput(RowData previousAcc, RowData input)
RowData	MiniBatchLocalGroupAggFunction.addInput(RowData previousAcc, RowData input)
void	GroupAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	GroupTableAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
abstract boolean	RecordCounter.recordCountIsZero(RowData acc)	We store the counter in the accumulator.

Method parameters in org.apache.flink.table.runtime.operators.aggregate with type arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	MiniBatchGroupAggFunction.addInput(List<RowData> value, RowData input)
void	MiniBatchGlobalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchGlobalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchGlobalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchGroupAggFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	MiniBatchGroupAggFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	MiniBatchGroupAggFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	MiniBatchIncrementalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchIncrementalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchIncrementalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchLocalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchLocalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	MiniBatchLocalGroupAggFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	GroupAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	GroupTableAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.aggregate with type arguments of type RowData

Constructor	Description
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, KeySelector<RowData,RowData> finalKeySelector, long stateRetentionTime)
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, KeySelector<RowData,RowData> finalKeySelector, long stateRetentionTime)

Uses of RowData in org.apache.flink.table.runtime.operators.aggregate.window

Fields in org.apache.flink.table.runtime.operators.aggregate.window with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	LocalSlicingWindowAggOperator.collector	This is used for emitting elements with a given timestamp.

Methods in org.apache.flink.table.runtime.operators.aggregate.window that return types with arguments of type RowData

Modifier and Type	Method	Description
WindowAggOperator<RowData,?>	WindowAggOperatorBuilder.build()

Method parameters in org.apache.flink.table.runtime.operators.aggregate.window with type arguments of type RowData

Modifier and Type	Method	Description
WindowAggOperatorBuilder	WindowAggOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
WindowAggOperatorBuilder	WindowAggOperatorBuilder.globalAggregate(GeneratedNamespaceAggsHandleFunction<?> localGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> globalGeneratedAggregateFunction, GeneratedNamespaceAggsHandleFunction<?> stateGeneratedAggregateFunction, AbstractRowDataSerializer<RowData> accSerializer)
WindowAggOperatorBuilder	WindowAggOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
WindowAggOperatorBuilder	WindowAggOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer)
void	LocalSlicingWindowAggOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.aggregate.window.buffers

Methods in org.apache.flink.table.runtime.operators.aggregate.window.buffers with parameters of type RowData

Modifier and Type	Method	Description
void	RecordsWindowBuffer.addElement(RowData key, long sliceEnd, RowData element)
void	WindowBuffer.addElement(RowData key, long window, RowData element)	Adds an element with associated key into the buffer.

Method parameters in org.apache.flink.table.runtime.operators.aggregate.window.buffers with type arguments of type RowData

Modifier and Type	Method	Description
WindowBuffer	RecordsWindowBuffer.Factory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)
WindowBuffer	RecordsWindowBuffer.LocalFactory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, Collector<RowData> collector, ZoneId shiftTimeZone)
WindowBuffer	WindowBuffer.Factory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)	Creates a WindowBuffer that buffers elements in memory before flushing.
WindowBuffer	WindowBuffer.LocalFactory.create(Object operatorOwner, MemoryManager memoryManager, long memorySize, RuntimeContext runtimeContext, Collector<RowData> collector, ZoneId shiftTimeZone)	Creates a WindowBuffer for local window that buffers elements in memory before flushing.

Constructor parameters in org.apache.flink.table.runtime.operators.aggregate.window.buffers with type arguments of type RowData

Constructor	Description
Factory(PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, RecordsCombiner.Factory combinerFactory)
Factory(PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, RecordsCombiner.Factory combinerFactory)
LocalFactory(PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, RecordsCombiner.LocalFactory localFactory)
LocalFactory(PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, RecordsCombiner.LocalFactory localFactory)
RecordsWindowBuffer(Object operatorOwner, MemoryManager memoryManager, long memorySize, RecordsCombiner combineFunction, PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, boolean requiresCopy, ZoneId shiftTimeZone)
RecordsWindowBuffer(Object operatorOwner, MemoryManager memoryManager, long memorySize, RecordsCombiner combineFunction, PagedTypeSerializer<RowData> keySer, AbstractRowDataSerializer<RowData> inputSer, boolean requiresCopy, ZoneId shiftTimeZone)

Uses of RowData in org.apache.flink.table.runtime.operators.aggregate.window.combines

Method parameters in org.apache.flink.table.runtime.operators.aggregate.window.combines with type arguments of type RowData

Modifier and Type	Method	Description
void	AggCombiner.combine(WindowKey windowKey, Iterator<RowData> records)
void	GlobalAggCombiner.combine(WindowKey windowKey, Iterator<RowData> localAccs)
void	LocalAggCombiner.combine(WindowKey windowKey, Iterator<RowData> records)
RecordsCombiner	AggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	GlobalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	LocalAggCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, Collector<RowData> collector)

Constructor parameters in org.apache.flink.table.runtime.operators.aggregate.window.combines with type arguments of type RowData

Constructor	Description
LocalAggCombiner(NamespaceAggsHandleFunction<Long> aggregator, Collector<RowData> collector)

Uses of RowData in org.apache.flink.table.runtime.operators.aggregate.window.processors

Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors with type parameters of type RowData

Modifier and Type	Field	Description
protected TypeSerializer<RowData>	AbstractWindowAggProcessor.accSerializer
protected MergingWindowProcessFunction<RowData,TimeWindow>	UnsliceWindowAggProcessor.windowFunction

Methods in org.apache.flink.table.runtime.operators.aggregate.window.processors with parameters of type RowData

Modifier and Type	Method	Description
protected void	AbstractWindowAggProcessor.collect(RowData aggResult)	Send result to downstream.
boolean	AbstractSliceWindowAggProcessor.processElement(RowData key, RowData element)
boolean	UnsliceWindowAggProcessor.processElement(RowData key, RowData element)

Constructor parameters in org.apache.flink.table.runtime.operators.aggregate.window.processors with type arguments of type RowData

Constructor	Description
AbstractSliceWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)
AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<W> genAggsHandler, WindowAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, boolean isEventTime, int indexOfCountStar, ZoneId shiftTimeZone)
SliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)
SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)
UnsliceWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<TimeWindow> genAggsHandler, UnsliceAssigner<TimeWindow> unsliceAssigner, TypeSerializer<RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)

Uses of RowData in org.apache.flink.table.runtime.operators.calc.async

Methods in org.apache.flink.table.runtime.operators.calc.async with parameters of type RowData

Modifier and Type	Method	Description
void	AsyncFunctionRunner.asyncInvoke(RowData input, ResultFuture<RowData> resultFuture)

Method parameters in org.apache.flink.table.runtime.operators.calc.async with type arguments of type RowData

Modifier and Type	Method	Description
void	AsyncFunctionRunner.asyncInvoke(RowData input, ResultFuture<RowData> resultFuture)
void	DelegatingAsyncResultFuture.setOutputFactory(Function<Object,RowData> outputFactory)
boolean	RetryPredicates.EmptyResponseResultStrategy.test(Collection<RowData> c)

Constructor parameters in org.apache.flink.table.runtime.operators.calc.async with type arguments of type RowData

Constructor	Description
AsyncFunctionRunner(GeneratedFunction<AsyncFunction<RowData,RowData>> generatedFetcher)
AsyncFunctionRunner(GeneratedFunction<AsyncFunction<RowData,RowData>> generatedFetcher)

Uses of RowData in org.apache.flink.table.runtime.operators.deduplicate

Methods in org.apache.flink.table.runtime.operators.deduplicate that return RowData

Modifier and Type	Method	Description
RowData	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction.addInput(RowData value, RowData input)
RowData	ProcTimeMiniBatchDeduplicateKeepLastRowFunction.addInput(RowData value, RowData input)
RowData	RowTimeMiniBatchLatestChangeDeduplicateFunction.addInput(RowData value, RowData input)

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

Modifier and Type	Method	Description
List<RowData>	RowTimeMiniBatchDeduplicateFunction.addInput(List<RowData> value, RowData input)

Methods in org.apache.flink.table.runtime.operators.deduplicate with parameters of type RowData

Modifier and Type	Method	Description
RowData	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction.addInput(RowData value, RowData input)
RowData	ProcTimeMiniBatchDeduplicateKeepLastRowFunction.addInput(RowData value, RowData input)
List<RowData>	RowTimeMiniBatchDeduplicateFunction.addInput(List<RowData> value, RowData input)
RowData	RowTimeMiniBatchLatestChangeDeduplicateFunction.addInput(RowData value, RowData input)
static void	RowTimeDeduplicateFunction.deduplicateOnRowTime(ValueState<RowData> state, RowData currentRow, Collector<RowData> out, boolean generateUpdateBefore, boolean generateInsert, int rowtimeIndex, boolean keepLastRow)	Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.
static boolean	DeduplicateFunctionHelper.isDuplicate(RowData preRow, RowData currentRow, int rowtimeIndex, boolean keepLastRow)	Returns current row is duplicate row or not compared to previous row.
void	ProcTimeDeduplicateKeepFirstRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeDeduplicateKeepLastRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeDeduplicateFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Method parameters in org.apache.flink.table.runtime.operators.deduplicate with type arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	RowTimeMiniBatchDeduplicateFunction.addInput(List<RowData> value, RowData input)
static void	RowTimeDeduplicateFunction.deduplicateOnRowTime(ValueState<RowData> state, RowData currentRow, Collector<RowData> out, boolean generateUpdateBefore, boolean generateInsert, int rowtimeIndex, boolean keepLastRow)	Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.
static void	RowTimeDeduplicateFunction.deduplicateOnRowTime(ValueState<RowData> state, RowData currentRow, Collector<RowData> out, boolean generateUpdateBefore, boolean generateInsert, int rowtimeIndex, boolean keepLastRow)	Processes element to deduplicate on keys with row time semantic, sends current element if it is last or first row, retracts previous element if needed.
void	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeMiniBatchDeduplicateKeepFirstRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeMiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeMiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeMiniBatchDeduplicateKeepLastRowFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	RowTimeMiniBatchDeduplicateFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	RowTimeMiniBatchDeduplicateFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	RowTimeMiniBatchDeduplicateFunction.finishBundle(Map<RowData,List<RowData>> buffer, Collector<RowData> out)
void	RowTimeMiniBatchLatestChangeDeduplicateFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	RowTimeMiniBatchLatestChangeDeduplicateFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	RowTimeMiniBatchLatestChangeDeduplicateFunction.finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)
void	ProcTimeDeduplicateKeepFirstRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeDeduplicateKeepLastRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeDeduplicateFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.deduplicate with type arguments of type RowData

Constructor	Description
ProcTimeDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
ProcTimeMiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<RowData> serializer, long stateRetentionTime)
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
RowTimeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchLatestChangeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)
RowTimeMiniBatchLatestChangeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long minRetentionTime, int rowtimeIndex, boolean generateUpdateBefore, boolean generateInsert, boolean keepLastRow)

Uses of RowData in org.apache.flink.table.runtime.operators.deduplicate.window

Methods in org.apache.flink.table.runtime.operators.deduplicate.window that return types with arguments of type RowData

Modifier and Type	Method	Description
WindowAggOperator<RowData,?>	RowTimeWindowDeduplicateOperatorBuilder.build()

Method parameters in org.apache.flink.table.runtime.operators.deduplicate.window with type arguments of type RowData

Modifier and Type	Method	Description
RowTimeWindowDeduplicateOperatorBuilder	RowTimeWindowDeduplicateOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
RowTimeWindowDeduplicateOperatorBuilder	RowTimeWindowDeduplicateOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer)

Uses of RowData in org.apache.flink.table.runtime.operators.deduplicate.window.combines

Method parameters in org.apache.flink.table.runtime.operators.deduplicate.window.combines with type arguments of type RowData

Modifier and Type	Method	Description
void	RowTimeDeduplicateRecordsCombiner.combine(WindowKey windowKey, Iterator<RowData> records)
RecordsCombiner	RowTimeDeduplicateRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Constructor parameters in org.apache.flink.table.runtime.operators.deduplicate.window.combines with type arguments of type RowData

Constructor	Description
Factory(TypeSerializer<RowData> recordSerializer, int rowtimeIndex, boolean keepLastRow)
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowValueState<Long> dataState, int rowtimeIndex, boolean keepLastRow, TypeSerializer<RowData> recordSerializer)

Uses of RowData in org.apache.flink.table.runtime.operators.deduplicate.window.processors

Methods in org.apache.flink.table.runtime.operators.deduplicate.window.processors with parameters of type RowData

Modifier and Type	Method	Description
boolean	RowTimeWindowDeduplicateProcessor.processElement(RowData key, RowData element)

Constructor parameters in org.apache.flink.table.runtime.operators.deduplicate.window.processors with type arguments of type RowData

Constructor	Description
RowTimeWindowDeduplicateProcessor(TypeSerializer<RowData> inputSerializer, WindowBuffer.Factory bufferFactory, int windowEndIndex, ZoneId shiftTimeZone)

Uses of RowData in org.apache.flink.table.runtime.operators.dynamicfiltering

Method parameters in org.apache.flink.table.runtime.operators.dynamicfiltering with type arguments of type RowData

Modifier and Type	Method	Description
void	DynamicFilteringDataCollectorOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.fusion

Constructor parameters in org.apache.flink.table.runtime.operators.fusion with type arguments of type RowData

Constructor	Description
FusionStreamOperatorBase(StreamOperatorParameters<RowData> parameters, int numberOfInputs)

Uses of RowData in org.apache.flink.table.runtime.operators.join

Methods in org.apache.flink.table.runtime.operators.join that return RowData

Modifier and Type	Method	Description
RowData	SortMergeJoinIterator.getProbeRow()
RowData	OuterJoinPaddingUtil.padLeft(RowData leftRow)	Returns a padding result with the given left row.
RowData	OuterJoinPaddingUtil.padRight(RowData rightRow)	Returns a padding result with the given right row.

Methods in org.apache.flink.table.runtime.operators.join with parameters of type RowData

Modifier and Type	Method	Description
boolean	JoinConditionWithNullFilters.apply(RowData left, RowData right)
abstract void	HashJoinOperator.join(RowIterator<BinaryRowData> buildIter, RowData probeRow)
RowData	OuterJoinPaddingUtil.padLeft(RowData leftRow)	Returns a padding result with the given left row.
RowData	OuterJoinPaddingUtil.padRight(RowData rightRow)	Returns a padding result with the given right row.
void	SortMergeJoinFunction.processElement1(RowData element)
void	SortMergeJoinFunction.processElement2(RowData element)

Method parameters in org.apache.flink.table.runtime.operators.join with type arguments of type RowData

Modifier and Type	Method	Description
void	HashJoinOperator.processElement1(StreamRecord<RowData> element)
void	SortMergeJoinOperator.processElement1(StreamRecord<RowData> element)
void	HashJoinOperator.processElement2(StreamRecord<RowData> element)
void	SortMergeJoinOperator.processElement2(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.join with type arguments of type RowData

Constructor	Description
SortMergeFullOuterJoinIterator(BinaryRowDataSerializer serializer1, BinaryRowDataSerializer serializer2, Projection<RowData,BinaryRowData> projection1, Projection<RowData,BinaryRowData> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRowData> iterator1, MutableObjectIterator<BinaryRowData> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeInnerJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)

Uses of RowData in org.apache.flink.table.runtime.operators.join.interval

Methods in org.apache.flink.table.runtime.operators.join.interval that return RowData

Modifier and Type	Method	Description
RowData	PaddingLeftMapFunction.map(RowData value)
RowData	PaddingRightMapFunction.map(RowData value)

Methods in org.apache.flink.table.runtime.operators.join.interval that return types with arguments of type RowData

Modifier and Type	Method	Description
TypeInformation<RowData>	FilterAllFlatMapFunction.getProducedType()
TypeInformation<RowData>	IntervalJoinFunction.getProducedType()
TypeInformation<RowData>	PaddingLeftMapFunction.getProducedType()
TypeInformation<RowData>	PaddingRightMapFunction.getProducedType()

Methods in org.apache.flink.table.runtime.operators.join.interval with parameters of type RowData

Modifier and Type	Method	Description
void	FilterAllFlatMapFunction.flatMap(RowData value, Collector<RowData> out)
void	IntervalJoinFunction.join(RowData first, RowData second, Collector<RowData> out)
RowData	PaddingLeftMapFunction.map(RowData value)
RowData	PaddingRightMapFunction.map(RowData value)
void	IntervalJoinFunction.setJoinKey(RowData currentKey)

Method parameters in org.apache.flink.table.runtime.operators.join.interval with type arguments of type RowData

Modifier and Type	Method	Description
void	FilterAllFlatMapFunction.flatMap(RowData value, Collector<RowData> out)
void	IntervalJoinFunction.join(RowData first, RowData second, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.join.interval with type arguments of type RowData

Constructor	Description
FilterAllFlatMapFunction(InternalTypeInfo<RowData> inputTypeInfo)
IntervalJoinFunction(GeneratedJoinCondition joinCondition, InternalTypeInfo<RowData> returnTypeInfo, boolean[] filterNulls)
PaddingLeftMapFunction(OuterJoinPaddingUtil paddingUtil, InternalTypeInfo<RowData> returnType)
PaddingRightMapFunction(OuterJoinPaddingUtil paddingUtil, InternalTypeInfo<RowData> returnType)
ProcTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, long minCleanUpInterval, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction genJoinFunc)
RowTimeIntervalJoin(FlinkJoinType joinType, long leftLowerBound, long leftUpperBound, long allowedLateness, long minCleanUpInterval, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, IntervalJoinFunction joinFunc, int leftTimeIdx, int rightTimeIdx)

Uses of RowData in org.apache.flink.table.runtime.operators.join.lookup

Fields in org.apache.flink.table.runtime.operators.join.lookup with type parameters of type RowData

Modifier and Type	Field	Description
protected ListenableCollector<RowData>	LookupJoinRunner.collector

Methods in org.apache.flink.table.runtime.operators.join.lookup that return types with arguments of type RowData

Modifier and Type	Method	Description
CompletableFuture<Collection<RowData>>	RetryableAsyncLookupFunctionDelegator.asyncLookup(RowData keyRow)
TableFunctionResultFuture<RowData>	AsyncLookupJoinRunner.createFetcherResultFuture(Configuration parameters)
TableFunctionResultFuture<RowData>	AsyncLookupJoinWithCalcRunner.createFetcherResultFuture(Configuration parameters)
Collector<RowData>	LookupJoinRunner.getFetcherCollector()
Collector<RowData>	LookupJoinWithCalcRunner.getFetcherCollector()
AsyncRetryPredicate<RowData>	ResultRetryStrategy.getRetryPredicate()
Collection<RowData>	RetryableLookupFunctionDelegator.lookup(RowData keyRow)

Methods in org.apache.flink.table.runtime.operators.join.lookup with parameters of type RowData

Modifier and Type	Method	Description
void	AsyncLookupJoinRunner.asyncInvoke(RowData input, ResultFuture<RowData> resultFuture)
CompletableFuture<Collection<RowData>>	RetryableAsyncLookupFunctionDelegator.asyncLookup(RowData keyRow)
void	LookupJoinRunner.doFetch(RowData in)
Collection<RowData>	RetryableLookupFunctionDelegator.lookup(RowData keyRow)
void	LookupJoinRunner.padNullForLeftJoin(RowData in, Collector<RowData> out)
boolean	LookupJoinRunner.preFilter(RowData in)
void	LookupJoinRunner.prepareCollector(RowData in, Collector<RowData> out)
void	KeyedLookupJoinWrapper.processElement(RowData in, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	LookupJoinRunner.processElement(RowData in, ProcessFunction.Context ctx, Collector<RowData> out)

Method parameters in org.apache.flink.table.runtime.operators.join.lookup with type arguments of type RowData

Modifier and Type	Method	Description
void	AsyncLookupJoinRunner.asyncInvoke(RowData input, ResultFuture<RowData> resultFuture)
static ResultRetryStrategy	ResultRetryStrategy.fixedDelayRetry(int maxAttempts, long backoffTimeMillis, Predicate<Collection<RowData>> resultPredicate)	Create a fixed-delay retry strategy by given params.
void	LookupJoinRunner.padNullForLeftJoin(RowData in, Collector<RowData> out)
void	LookupJoinRunner.prepareCollector(RowData in, Collector<RowData> out)
void	KeyedLookupJoinWrapper.processElement(RowData in, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	LookupJoinRunner.processElement(RowData in, ProcessFunction.Context ctx, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.join.lookup with type arguments of type RowData

Constructor	Description
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
AsyncLookupJoinWithCalcRunner(GeneratedFunction<AsyncFunction<RowData,Object>> generatedFetcher, DataStructureConverter<RowData,Object> fetcherConverter, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedResultFuture<TableFunctionResultFuture<RowData>> generatedResultFuture, GeneratedFunction<FilterCondition> generatedPreFilterCondition, RowDataSerializer rightRowSerializer, boolean isLeftOuterJoin, int asyncBufferCapacity)
KeyedLookupJoinWrapper(LookupJoinRunner lookupJoinRunner, StateTtlConfig ttlConfig, TypeSerializer<RowData> serializer, boolean lookupKeyContainsPrimaryKey)
LookupJoinRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedPreFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedPreFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedPreFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinWithCalcRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinWithCalcRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)
LookupJoinWithCalcRunner(GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedFetcher, GeneratedFunction<FlatMapFunction<RowData,RowData>> generatedCalc, GeneratedCollector<ListenableCollector<RowData>> generatedCollector, GeneratedFunction<FilterCondition> generatedFilterCondition, boolean isLeftOuterJoin, int tableFieldsCount)

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream

Fields in org.apache.flink.table.runtime.operators.join.stream with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	AbstractStreamingJoinOperator.collector
protected InternalTypeInfo<RowData>	AbstractStreamingJoinOperator.leftType
protected InternalTypeInfo<RowData>	AbstractStreamingJoinOperator.rightType

Methods in org.apache.flink.table.runtime.operators.join.stream with parameters of type RowData

Modifier and Type	Method	Description
protected void	StreamingJoinOperator.processElement(RowData input, JoinRecordStateView inputSideStateView, JoinRecordStateView otherSideStateView, boolean inputIsLeft, boolean isSuppress)

Method parameters in org.apache.flink.table.runtime.operators.join.stream with type arguments of type RowData

Modifier and Type	Method	Description
static MiniBatchStreamingJoinOperator	MiniBatchStreamingJoinOperator.newMiniBatchStreamJoinOperator(FlinkJoinType joinType, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime, CoBundleTrigger<RowData,RowData> coBundleTrigger)
static MiniBatchStreamingJoinOperator	MiniBatchStreamingJoinOperator.newMiniBatchStreamJoinOperator(FlinkJoinType joinType, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime, CoBundleTrigger<RowData,RowData> coBundleTrigger)
static MiniBatchStreamingJoinOperator	MiniBatchStreamingJoinOperator.newMiniBatchStreamJoinOperator(FlinkJoinType joinType, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime, CoBundleTrigger<RowData,RowData> coBundleTrigger)
void	MiniBatchStreamingJoinOperator.processElement1(StreamRecord<RowData> element)
void	StreamingJoinOperator.processElement1(StreamRecord<RowData> element)
void	StreamingSemiAntiJoinOperator.processElement1(StreamRecord<RowData> element)	Process an input element and output incremental joined records, retraction messages will be sent in some scenarios.
void	MiniBatchStreamingJoinOperator.processElement2(StreamRecord<RowData> element)
void	StreamingJoinOperator.processElement2(StreamRecord<RowData> element)
void	StreamingSemiAntiJoinOperator.processElement2(StreamRecord<RowData> element)	Process an input element and output incremental joined records, retraction messages will be sent in some scenarios.

Constructor parameters in org.apache.flink.table.runtime.operators.join.stream with type arguments of type RowData

Constructor	Description
AbstractStreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime)
StreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime)
StreamingSemiAntiJoinOperator(boolean isAntiJoin, InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTIme)

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing

Fields in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	AbstractAsyncStateStreamingJoinOperator.collector
protected InternalTypeInfo<RowData>	AbstractAsyncStateStreamingJoinOperator.leftType
protected InternalTypeInfo<RowData>	AbstractAsyncStateStreamingJoinOperator.rightType

Method parameters in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing with type arguments of type RowData

Modifier and Type	Method	Description
void	AsyncStateStreamingJoinOperator.processElement1(StreamRecord<RowData> element)
void	AsyncStateStreamingJoinOperator.processElement2(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing with type arguments of type RowData

Constructor	Description
AbstractAsyncStateStreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime)
AsyncStateStreamingJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, JoinInputSideSpec leftInputSideSpec, JoinInputSideSpec rightInputSideSpec, boolean leftIsOuter, boolean rightIsOuter, boolean[] filterNullKeys, long leftStateRetentionTime, long rightStateRetentionTime)

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state

Methods in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state with parameters of type RowData

Modifier and Type	Method	Description
StateFuture<Void>	JoinRecordAsyncStateView.addRecord(RowData record)	Add a new record to the state view.
default StateFuture<Void>	OuterJoinRecordAsyncStateView.addRecord(RowData record)
StateFuture<Void>	OuterJoinRecordAsyncStateView.addRecord(RowData record, int numOfAssociations)	Adds a new record with the number of associations to the state view.
StateFuture<Void>	JoinRecordAsyncStateView.retractRecord(RowData record)	Retract the record from the state view.
StateFuture<Void>	OuterJoinRecordAsyncStateView.updateNumOfAssociations(RowData record, int numOfAssociations)	Updates the number of associations belongs to the record.

Method parameters in org.apache.flink.table.runtime.operators.join.stream.asyncprocessing.state with type arguments of type RowData

Modifier and Type	Method	Description
static JoinRecordAsyncStateView	JoinRecordAsyncStateViews.create(StreamingRuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime)	Creates a JoinRecordAsyncStateView depends on JoinInputSideSpec.
static OuterJoinRecordAsyncStateView	OuterJoinRecordAsyncStateViews.create(StreamingRuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime)	Creates a OuterJoinRecordAsyncStateView depends on JoinInputSideSpec.
StateFuture<List<OuterRecord>>	JoinRecordAsyncStateView.findMatchedRecords(Function<RowData,Boolean> condition)	Find all the records matched the condition under the current context (i.e. join key).
default StateFuture<List<OuterRecord>>	OuterJoinRecordAsyncStateView.findMatchedRecords(Function<RowData,Boolean> condition)
StateFuture<List<OuterRecord>>	OuterJoinRecordAsyncStateView.findMatchedRecordsAndNumOfAssociations(Function<RowData,Boolean> condition)	Find all the records matched the condition and the corresponding number of associations under the current context (i.e. join key).

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream.bundle

Fields in org.apache.flink.table.runtime.operators.join.stream.bundle with type parameters of type RowData

Modifier and Type	Field	Description
protected Map<RowData,T>	BufferBundle.bundle

Methods in org.apache.flink.table.runtime.operators.join.stream.bundle that return types with arguments of type RowData

Modifier and Type	Method	Description
Set<RowData>	BufferBundle.getJoinKeys()	Get the joinKeys in bufferBundle.
Set<RowData>	InputSideHasUniqueKeyBundle.getJoinKeys()
abstract Map<RowData,List<RowData>>	BufferBundle.getRecords()	Get records associated with joinKeys from bufferBundle.
abstract Map<RowData,List<RowData>>	BufferBundle.getRecords()	Get records associated with joinKeys from bufferBundle.
Map<RowData,List<RowData>>	InputSideHasNoUniqueKeyBundle.getRecords()
Map<RowData,List<RowData>>	InputSideHasNoUniqueKeyBundle.getRecords()
Map<RowData,List<RowData>>	InputSideHasUniqueKeyBundle.getRecords()
Map<RowData,List<RowData>>	InputSideHasUniqueKeyBundle.getRecords()
Map<RowData,List<RowData>>	JoinKeyContainsUniqueKeyBundle.getRecords()
Map<RowData,List<RowData>>	JoinKeyContainsUniqueKeyBundle.getRecords()
abstract Map<RowData,List<RowData>>	BufferBundle.getRecordsWithJoinKey(RowData joinKey)	Get records associated with joinKeys from bufferBundle.
abstract Map<RowData,List<RowData>>	BufferBundle.getRecordsWithJoinKey(RowData joinKey)	Get records associated with joinKeys from bufferBundle.
Map<RowData,List<RowData>>	InputSideHasNoUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	InputSideHasNoUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	InputSideHasUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	InputSideHasUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	JoinKeyContainsUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	JoinKeyContainsUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)

Methods in org.apache.flink.table.runtime.operators.join.stream.bundle with parameters of type RowData

Modifier and Type	Method	Description
abstract int	BufferBundle.addRecord(RowData joinKey, RowData uniqueKey, RowData record)	Adds a record into the bufferBundle when processing element in a stream and this function would return the size of the bufferBundle.
int	InputSideHasNoUniqueKeyBundle.addRecord(RowData joinKey, RowData uniqueKey, RowData record)	The structure of the bundle: first-level key is the joinKey while the second-level key is the hash value of the record.
int	InputSideHasUniqueKeyBundle.addRecord(RowData joinKey, RowData uniqueKey, RowData record)
int	JoinKeyContainsUniqueKeyBundle.addRecord(RowData joinKey, RowData uniqueKey, RowData record)
abstract Map<RowData,List<RowData>>	BufferBundle.getRecordsWithJoinKey(RowData joinKey)	Get records associated with joinKeys from bufferBundle.
Map<RowData,List<RowData>>	InputSideHasNoUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	InputSideHasUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)
Map<RowData,List<RowData>>	JoinKeyContainsUniqueKeyBundle.getRecordsWithJoinKey(RowData joinKey)

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream.state

Methods in org.apache.flink.table.runtime.operators.join.stream.state that return types with arguments of type RowData

Modifier and Type	Method	Description
Iterable<RowData>	JoinRecordStateView.getRecords()	Gets all the records under the current context (i.e. join key).
Iterable<Tuple2<RowData,Integer>>	OuterJoinRecordStateView.getRecordsAndNumOfAssociations()	Gets all the records and number of associations under the current context (i.e. join key).

Methods in org.apache.flink.table.runtime.operators.join.stream.state with parameters of type RowData

Modifier and Type	Method	Description
void	JoinRecordStateView.addRecord(RowData record)	Add a new record to the state view.
void	OuterJoinRecordStateView.addRecord(RowData record, int numOfAssociations)	Adds a new record with the number of associations to the state view.
void	JoinRecordStateView.retractRecord(RowData record)	Retract the record from the state view.
void	OuterJoinRecordStateView.updateNumOfAssociations(RowData record, int numOfAssociations)	Updates the number of associations belongs to the record.

Method parameters in org.apache.flink.table.runtime.operators.join.stream.state with type arguments of type RowData

Modifier and Type	Method	Description
static JoinRecordStateView	JoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime)	Creates a JoinRecordStateView depends on JoinInputSideSpec.
static OuterJoinRecordStateView	OuterJoinRecordStateViews.create(RuntimeContext ctx, String stateName, JoinInputSideSpec inputSideSpec, InternalTypeInfo<RowData> recordType, long retentionTime)	Creates a OuterJoinRecordStateView depends on JoinInputSideSpec.

Uses of RowData in org.apache.flink.table.runtime.operators.join.stream.utils

Fields in org.apache.flink.table.runtime.operators.join.stream.utils declared as RowData

Modifier and Type	Field	Description
RowData	OuterRecord.record

Methods in org.apache.flink.table.runtime.operators.join.stream.utils that return RowData

Modifier and Type	Method	Description
RowData	OuterRecord.getRecord()

Methods in org.apache.flink.table.runtime.operators.join.stream.utils that return types with arguments of type RowData

Modifier and Type	Method	Description
Iterable<RowData>	AssociatedRecords.getRecords()	Gets the iterable of records.
KeySelector<RowData,RowData>	JoinInputSideSpec.getUniqueKeySelector()	Returns the KeySelector to extract unique key from the input row.
KeySelector<RowData,RowData>	JoinInputSideSpec.getUniqueKeySelector()	Returns the KeySelector to extract unique key from the input row.
InternalTypeInfo<RowData>	JoinInputSideSpec.getUniqueKeyType()	Returns the TypeInformation of the unique key.

Methods in org.apache.flink.table.runtime.operators.join.stream.utils with parameters of type RowData

Modifier and Type	Method	Description
abstract void	JoinHelper.addRecord(STATE_VIEW stateView, RowData record)
abstract void	JoinHelper.addRecordInOuterSide(OUTER_STATE_VIEW stateView, RowData record, int numOfAssociations)
static StateFuture<AssociatedRecords>	AssociatedRecords.fromAsyncStateView(RowData input, boolean inputIsLeft, JoinRecordAsyncStateView otherSideAsyncStateView, JoinCondition joinCondition)	Creates an AssociatedRecords which represents the records associated to the input row.
static AssociatedRecords	AssociatedRecords.fromSyncStateView(RowData input, boolean inputIsLeft, JoinRecordStateView otherSideStateView, JoinCondition condition)	Creates an AssociatedRecords which represents the records associated to the input row.
void	JoinHelper.processJoin(RowData input, STATE_VIEW inputSideAsyncStateView, STATE_VIEW otherSideAsyncStateView, boolean inputIsLeft, AssociatedRecords otherSideAssociatedRecords, boolean isSuppress)	Process an input element and output incremental joined records, retraction messages will be sent in some scenarios.
abstract void	JoinHelper.retractRecord(STATE_VIEW stateView, RowData record)
abstract void	JoinHelper.updateNumOfAssociationsInOuterSide(OUTER_STATE_VIEW stateView, RowData record, int numOfAssociations)

Method parameters in org.apache.flink.table.runtime.operators.join.stream.utils with type arguments of type RowData

Modifier and Type	Method	Description
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that the input has an unique key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that the input has an unique key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that the input has an unique key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKeyContainedByJoinKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that input has an unique key and the unique key is contained by the join key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKeyContainedByJoinKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that input has an unique key and the unique key is contained by the join key.
static JoinInputSideSpec	JoinInputSideSpec.withUniqueKeyContainedByJoinKey(InternalTypeInfo<RowData> uniqueKeyType, KeySelector<RowData,RowData> uniqueKeySelector)	Creates a JoinInputSideSpec that input has an unique key and the unique key is contained by the join key.

Constructors in org.apache.flink.table.runtime.operators.join.stream.utils with parameters of type RowData

Constructor	Description
JoinHelper(boolean leftIsOuter, boolean rightIsOuter, JoinedRowData outRow, RowData leftNullRow, RowData rightNullRow, TimestampedCollector<RowData> collector)
OuterRecord(RowData record)
OuterRecord(RowData record, int numOfAssociations)

Constructor parameters in org.apache.flink.table.runtime.operators.join.stream.utils with type arguments of type RowData

Constructor	Description
JoinHelper(boolean leftIsOuter, boolean rightIsOuter, JoinedRowData outRow, RowData leftNullRow, RowData rightNullRow, TimestampedCollector<RowData> collector)

Uses of RowData in org.apache.flink.table.runtime.operators.join.temporal

Method parameters in org.apache.flink.table.runtime.operators.join.temporal with type arguments of type RowData

Modifier and Type	Method	Description
void	TemporalProcessTimeJoinOperator.processElement1(StreamRecord<RowData> element)
void	TemporalRowTimeJoinOperator.processElement1(StreamRecord<RowData> element)
void	TemporalProcessTimeJoinOperator.processElement2(StreamRecord<RowData> element)
void	TemporalRowTimeJoinOperator.processElement2(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.join.temporal with type arguments of type RowData

Constructor	Description
TemporalProcessTimeJoinOperator(InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, long minRetentionTime, long maxRetentionTime, boolean isLeftOuterJoin)
TemporalRowTimeJoinOperator(InternalTypeInfo<RowData> leftType, InternalTypeInfo<RowData> rightType, GeneratedJoinCondition generatedJoinCondition, int leftTimeAttribute, int rightTimeAttribute, long minRetentionTime, long maxRetentionTime, boolean isLeftOuterJoin)

Uses of RowData in org.apache.flink.table.runtime.operators.join.window

Fields in org.apache.flink.table.runtime.operators.join.window with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	WindowJoinOperator.collector	This is used for emitting elements with a given timestamp.

Method parameters in org.apache.flink.table.runtime.operators.join.window with type arguments of type RowData

Modifier and Type	Method	Description
abstract void	WindowJoinOperator.join(Iterable<RowData> leftRecords, Iterable<RowData> rightRecords)
WindowJoinOperatorBuilder	WindowJoinOperatorBuilder.leftSerializer(TypeSerializer<RowData> leftSerializer)
void	WindowJoinOperator.onEventTime(InternalTimer<RowData,Long> timer)
void	WindowJoinOperator.onProcessingTime(InternalTimer<RowData,Long> timer)
void	WindowJoinOperator.processElement1(StreamRecord<RowData> element)
void	WindowJoinOperator.processElement2(StreamRecord<RowData> element)
WindowJoinOperatorBuilder	WindowJoinOperatorBuilder.rightSerializer(TypeSerializer<RowData> rightSerializer)

Uses of RowData in org.apache.flink.table.runtime.operators.match

Methods in org.apache.flink.table.runtime.operators.match with parameters of type RowData

Modifier and Type	Method	Description
int	RowDataEventComparator.compare(RowData row1, RowData row2)
boolean	IterativeConditionRunner.filter(RowData value, IterativeCondition.Context<RowData> ctx)

Method parameters in org.apache.flink.table.runtime.operators.match with type arguments of type RowData

Modifier and Type	Method	Description
boolean	IterativeConditionRunner.filter(RowData value, IterativeCondition.Context<RowData> ctx)
void	PatternProcessFunctionRunner.processMatch(Map<String,List<RowData>> match, PatternProcessFunction.Context ctx, Collector<RowData> out)
void	PatternProcessFunctionRunner.processMatch(Map<String,List<RowData>> match, PatternProcessFunction.Context ctx, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.match with type arguments of type RowData

Constructor	Description
IterativeConditionRunner(GeneratedFunction<RichIterativeCondition<RowData>> generatedFunction)
PatternProcessFunctionRunner(GeneratedFunction<PatternProcessFunction<RowData,RowData>> generatedFunction)
PatternProcessFunctionRunner(GeneratedFunction<PatternProcessFunction<RowData,RowData>> generatedFunction)

Uses of RowData in org.apache.flink.table.runtime.operators.misc

Methods in org.apache.flink.table.runtime.operators.misc with parameters of type RowData

Modifier and Type	Method	Description
boolean	DropUpdateBeforeFunction.filter(RowData value)

Uses of RowData in org.apache.flink.table.runtime.operators.multipleinput

Classes in org.apache.flink.table.runtime.operators.multipleinput with type parameters of type RowData

Modifier and Type	Class	Description
class	TableOperatorWrapper<OP extends StreamOperator<RowData>>	This class handles the close, endInput and other related logic of a StreamOperator.

Methods in org.apache.flink.table.runtime.operators.multipleinput with type parameters of type RowData

Modifier and Type	Method	Description
<T extends StreamOperator<RowData>> T	BatchMultipleInputStreamOperatorFactory.createStreamOperator(StreamOperatorParameters<RowData> parameters)

Method parameters in org.apache.flink.table.runtime.operators.multipleinput with type arguments of type RowData

Modifier and Type	Method	Description
void	TableOperatorWrapper.createOperator(StreamOperatorParameters<RowData> parameters)
protected StreamConfig	BatchMultipleInputStreamOperator.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
protected StreamConfig	MultipleInputStreamOperatorBase.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters, TableOperatorWrapper<?> wrapper)
<T extends StreamOperator<RowData>> T	BatchMultipleInputStreamOperatorFactory.createStreamOperator(StreamOperatorParameters<RowData> parameters)

Constructor parameters in org.apache.flink.table.runtime.operators.multipleinput with type arguments of type RowData

Constructor	Description
BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrapper, TableOperatorWrapper<?> tailWrapper)
MultipleInputStreamOperatorBase(StreamOperatorParameters<RowData> parameters, List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrappers, TableOperatorWrapper<?> tailWrapper)
TableOperatorWrapper(StreamOperatorFactory<RowData> factory, String operatorName, List<TypeInformation<?>> allInputTypes, TypeInformation<?> outputType)

Uses of RowData in org.apache.flink.table.runtime.operators.multipleinput.input

Method parameters in org.apache.flink.table.runtime.operators.multipleinput.input with type arguments of type RowData

Modifier and Type	Method	Description
void	FirstInputOfTwoInput.processElement(StreamRecord<RowData> element)
void	OneInput.processElement(StreamRecord<RowData> element)
void	SecondInputOfTwoInput.processElement(StreamRecord<RowData> element)
void	InputBase.setKeyContextElement(StreamRecord<RowData> record)

Constructor parameters in org.apache.flink.table.runtime.operators.multipleinput.input with type arguments of type RowData

Constructor	Description
FirstInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
FirstInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
FirstInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
OneInput(OneInputStreamOperator<RowData,RowData> operator)
OneInput(OneInputStreamOperator<RowData,RowData> operator)
SecondInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
SecondInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
SecondInputOfTwoInput(TwoInputStreamOperator<RowData,RowData,RowData> operator)

Uses of RowData in org.apache.flink.table.runtime.operators.multipleinput.output

Method parameters in org.apache.flink.table.runtime.operators.multipleinput.output with type arguments of type RowData

Modifier and Type	Method	Description
void	BroadcastingOutput.collect(StreamRecord<RowData> record)
void	CopyingBroadcastingOutput.collect(StreamRecord<RowData> record)
void	CopyingSecondInputOfTwoInputStreamOperatorOutput.collect(StreamRecord<RowData> record)
void	FirstInputOfTwoInputStreamOperatorOutput.collect(StreamRecord<RowData> record)
void	OneInputStreamOperatorOutput.collect(StreamRecord<RowData> record)
void	SecondInputOfTwoInputStreamOperatorOutput.collect(StreamRecord<RowData> record)

Constructor parameters in org.apache.flink.table.runtime.operators.multipleinput.output with type arguments of type RowData

Constructor	Description
CopyingFirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingFirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingFirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingFirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingOneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingOneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingOneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
FirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
FirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
FirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
OneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator)
OneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator)
SecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
SecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)
SecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator)

Uses of RowData in org.apache.flink.table.runtime.operators.over

Methods in org.apache.flink.table.runtime.operators.over with parameters of type RowData

Modifier and Type	Method	Description
void	AbstractRowTimeUnboundedPrecedingOver.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)	Puts an element from the input stream into state if it is not late.
void	ProcTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeUnboundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Method parameters in org.apache.flink.table.runtime.operators.over with type arguments of type RowData

Modifier and Type	Method	Description
void	AbstractRowTimeUnboundedPrecedingOver.onTimer(long timestamp, KeyedProcessFunction.OnTimerContext ctx, Collector<RowData> out)
void	ProcTimeRangeBoundedPrecedingFunction.onTimer(long timestamp, KeyedProcessFunction.OnTimerContext ctx, Collector<RowData> out)
void	ProcTimeRowsBoundedPrecedingFunction.onTimer(long timestamp, KeyedProcessFunction.OnTimerContext ctx, Collector<RowData> out)
void	RowTimeRangeBoundedPrecedingFunction.onTimer(long timestamp, KeyedProcessFunction.OnTimerContext ctx, Collector<RowData> out)
void	RowTimeRowsBoundedPrecedingFunction.onTimer(long timestamp, KeyedProcessFunction.OnTimerContext ctx, Collector<RowData> out)
void	AbstractRowTimeUnboundedPrecedingOver.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)	Puts an element from the input stream into state if it is not late.
void	BufferDataOverWindowOperator.processElement(StreamRecord<RowData> element)
void	NonBufferOverWindowOperator.processElement(StreamRecord<RowData> element)
void	ProcTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeUnboundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
protected abstract void	AbstractRowTimeUnboundedPrecedingOver.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)	Process the same timestamp datas, the mechanism is different between rows and range window.
protected abstract void	AbstractRowTimeUnboundedPrecedingOver.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)	Process the same timestamp datas, the mechanism is different between rows and range window.
void	RowTimeRangeUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)
void	RowTimeRangeUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)
void	RowTimeRowsUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)
void	RowTimeRowsUnboundedPrecedingFunction.processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out)

Constructor parameters in org.apache.flink.table.runtime.operators.over with type arguments of type RowData

Constructor	Description
BufferDataOverWindowOperator(StreamOperatorParameters<RowData> parameters, OverWindowFrame[] overWindowFrames, GeneratedRecordComparator genComparator, boolean isRowAllInFixedPart)
NonBufferOverWindowOperator(StreamOperatorParameters<RowData> parameters, GeneratedAggsHandleFunction[] aggsHandlers, GeneratedRecordComparator genComparator, boolean[] resetAccumulators)

Uses of RowData in org.apache.flink.table.runtime.operators.over.frame

Methods in org.apache.flink.table.runtime.operators.over.frame that return RowData

Modifier and Type	Method	Description
RowData	InsensitiveOverFrame.process(int index, RowData current)
RowData	OffsetOverFrame.process(int index, RowData current)
RowData	OverWindowFrame.process(int index, RowData current)	return the ACC of the window frame.
RowData	RangeSlidingOverFrame.process(int index, RowData current)
RowData	RangeUnboundedFollowingOverFrame.process(int index, RowData current)
RowData	RangeUnboundedPrecedingOverFrame.process(int index, RowData current)
RowData	RowSlidingOverFrame.process(int index, RowData current)
RowData	RowUnboundedFollowingOverFrame.process(int index, RowData current)
RowData	RowUnboundedPrecedingOverFrame.process(int index, RowData current)
RowData	UnboundedOverWindowFrame.process(int index, RowData current)

Methods in org.apache.flink.table.runtime.operators.over.frame with parameters of type RowData

Modifier and Type	Method	Description
long	OffsetOverFrame.CalcOffsetFunc.calc(RowData row)
RowData	InsensitiveOverFrame.process(int index, RowData current)
RowData	OffsetOverFrame.process(int index, RowData current)
RowData	OverWindowFrame.process(int index, RowData current)	return the ACC of the window frame.
RowData	RangeSlidingOverFrame.process(int index, RowData current)
RowData	RangeUnboundedFollowingOverFrame.process(int index, RowData current)
RowData	RangeUnboundedPrecedingOverFrame.process(int index, RowData current)
RowData	RowSlidingOverFrame.process(int index, RowData current)
RowData	RowUnboundedFollowingOverFrame.process(int index, RowData current)
RowData	RowUnboundedPrecedingOverFrame.process(int index, RowData current)
RowData	UnboundedOverWindowFrame.process(int index, RowData current)

Uses of RowData in org.apache.flink.table.runtime.operators.python.aggregate

Methods in org.apache.flink.table.runtime.operators.python.aggregate with parameters of type RowData

Modifier and Type	Method	Description
abstract void	AbstractPythonStreamAggregateOperator.processElementInternal(RowData value)
void	AbstractPythonStreamGroupAggregateOperator.processElementInternal(RowData value)
void	PythonStreamGroupWindowAggregateOperator.processElementInternal(RowData value)

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

Modifier and Type	Method	Description
void	AbstractPythonStreamGroupAggregateOperator.onEventTime(InternalTimer<RowData,VoidNamespace> timer)	Invoked when an event-time timer fires.
void	AbstractPythonStreamGroupAggregateOperator.onProcessingTime(InternalTimer<RowData,VoidNamespace> timer)	Invoked when a processing-time timer fires.
void	AbstractPythonStreamAggregateOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.python.aggregate.arrow

Methods in org.apache.flink.table.runtime.operators.python.aggregate.arrow that return RowData

Modifier and Type	Method	Description
RowData	AbstractArrowPythonAggregateFunctionOperator.getFunctionInput(RowData element)

Methods in org.apache.flink.table.runtime.operators.python.aggregate.arrow with parameters of type RowData

Modifier and Type	Method	Description
RowData	AbstractArrowPythonAggregateFunctionOperator.getFunctionInput(RowData element)

Method parameters in org.apache.flink.table.runtime.operators.python.aggregate.arrow with type arguments of type RowData

Modifier and Type	Method	Description
void	AbstractArrowPythonAggregateFunctionOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch

Methods in org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch with parameters of type RowData

Modifier and Type	Method	Description
void	BatchArrowPythonGroupAggregateFunctionOperator.bufferInput(RowData input)
void	BatchArrowPythonGroupWindowAggregateFunctionOperator.bufferInput(RowData input)
void	BatchArrowPythonOverWindowAggregateFunctionOperator.bufferInput(RowData input)
void	BatchArrowPythonGroupAggregateFunctionOperator.processElementInternal(RowData value)
void	BatchArrowPythonGroupWindowAggregateFunctionOperator.processElementInternal(RowData value)
void	BatchArrowPythonOverWindowAggregateFunctionOperator.processElementInternal(RowData value)

Uses of RowData in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream

Methods in org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream with parameters of type RowData

Modifier and Type	Method	Description
void	StreamArrowPythonGroupWindowAggregateFunctionOperator.bufferInput(RowData input)
void	StreamArrowPythonProcTimeBoundedRangeOperator.bufferInput(RowData input)
void	StreamArrowPythonProcTimeBoundedRowsOperator.bufferInput(RowData input)
void	StreamArrowPythonRowTimeBoundedRangeOperator.bufferInput(RowData input)
void	StreamArrowPythonRowTimeBoundedRowsOperator.bufferInput(RowData input)
void	AbstractStreamArrowPythonOverWindowAggregateFunctionOperator.processElementInternal(RowData value)
void	StreamArrowPythonGroupWindowAggregateFunctionOperator.processElementInternal(RowData value)
void	StreamArrowPythonProcTimeBoundedRowsOperator.processElementInternal(RowData value)

Uses of RowData in org.apache.flink.table.runtime.operators.python.scalar

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

Modifier and Type	Method	Description
RowData	AbstractPythonScalarFunctionOperator.getFunctionInput(RowData element)

Methods in org.apache.flink.table.runtime.operators.python.scalar with parameters of type RowData

Modifier and Type	Method	Description
void	AbstractPythonScalarFunctionOperator.bufferInput(RowData input)
RowData	AbstractPythonScalarFunctionOperator.getFunctionInput(RowData element)
void	PythonScalarFunctionOperator.processElementInternal(RowData value)

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

Modifier and Type	Method	Description
void	EmbeddedPythonScalarFunctionOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.python.scalar.arrow

Methods in org.apache.flink.table.runtime.operators.python.scalar.arrow with parameters of type RowData

Modifier and Type	Method	Description
void	ArrowPythonScalarFunctionOperator.processElementInternal(RowData value)

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

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

Modifier and Type	Method	Description
RowData	PythonTableFunctionOperator.getFunctionInput(RowData element)

Methods in org.apache.flink.table.runtime.operators.python.table with parameters of type RowData

Modifier and Type	Method	Description
void	PythonTableFunctionOperator.bufferInput(RowData input)
RowData	PythonTableFunctionOperator.getFunctionInput(RowData element)
void	PythonTableFunctionOperator.processElementInternal(RowData value)

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

Modifier and Type	Method	Description
void	EmbeddedPythonTableFunctionOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.python.utils

Methods in org.apache.flink.table.runtime.operators.python.utils with parameters of type RowData

Modifier and Type	Method	Description
void	StreamRecordRowDataWrappingCollector.collect(RowData record)

Constructor parameters in org.apache.flink.table.runtime.operators.python.utils with type arguments of type RowData

Constructor	Description
StreamRecordRowDataWrappingCollector(Collector<StreamRecord<RowData>> out)

Uses of RowData in org.apache.flink.table.runtime.operators.rank

Fields in org.apache.flink.table.runtime.operators.rank with type parameters of type RowData

Modifier and Type	Field	Description
protected InternalTypeInfo<RowData>	AbstractTopNFunction.inputRowType
protected Comparator<RowData>	AbstractTopNFunction.sortKeyComparator
protected KeySelector<RowData,RowData>	AbstractTopNFunction.sortKeySelector
protected KeySelector<RowData,RowData>	AbstractTopNFunction.sortKeySelector

Methods in org.apache.flink.table.runtime.operators.rank that return RowData

Modifier and Type	Method	Description
RowData	TopNBuffer.getElement(int rank)	Gets record which rank is given value.
RowData	TopNBuffer.lastElement()	Returns the last record of the last Entry in the buffer.
RowData	TopNBuffer.removeLast()	Removes the last record of the last Entry in the buffer.

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

Modifier and Type	Method	Description
Set<Map.Entry<RowData,Collection<RowData>>>	TopNBuffer.entrySet()	Returns a Set view of the mappings contained in the buffer.
Set<Map.Entry<RowData,Collection<RowData>>>	TopNBuffer.entrySet()	Returns a Set view of the mappings contained in the buffer.
Collection<RowData>	TopNBuffer.get(RowData sortKey)	Gets the record list from the buffer under the sortKey.
Comparator<RowData>	TopNBuffer.getSortKeyComparator()	Gets sort key comparator used by buffer.
Map.Entry<RowData,Collection<RowData>>	TopNBuffer.lastEntry()	Returns the last Entry in the buffer.
Map.Entry<RowData,Collection<RowData>>	TopNBuffer.lastEntry()	Returns the last Entry in the buffer.

Methods in org.apache.flink.table.runtime.operators.rank with parameters of type RowData

Modifier and Type	Method	Description
protected boolean	AbstractTopNFunction.checkSortKeyInBufferRange(RowData sortKey, TopNBuffer buffer)	Checks whether the record should be put into the buffer.
boolean	TopNBuffer.checkSortKeyInBufferRange(RowData sortKey, long topNum)	Checks whether the record should be put into the buffer.
protected void	AbstractTopNFunction.collectDelete(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectDelete(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectInsert(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectInsert(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectUpdateAfter(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectUpdateAfter(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectUpdateBefore(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectUpdateBefore(Collector<RowData> out, RowData inputRow, long rank)
int	ComparableRecordComparator.compare(RowData o1, RowData o2)
boolean	TopNBuffer.containsKey(RowData key)	Returns true if the buffer contains a mapping for the specified key.
Collection<RowData>	TopNBuffer.get(RowData sortKey)	Gets the record list from the buffer under the sortKey.
protected long	AbstractTopNFunction.initRankEnd(RowData row)	Initialize rank end.
void	AppendOnlyFirstNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	AppendOnlyTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	FastTop1Function.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RetractableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	UpdatableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
int	TopNBuffer.put(RowData sortKey, RowData value)	Appends a record into the buffer.
void	TopNBuffer.putAll(RowData sortKey, Collection<RowData> values)	Puts a record list into the buffer under the sortKey.
void	TopNBuffer.remove(RowData sortKey, RowData value)
void	TopNBuffer.removeAll(RowData sortKey)	Removes all record list from the buffer under the sortKey.

Method parameters in org.apache.flink.table.runtime.operators.rank with type arguments of type RowData

Modifier and Type	Method	Description
protected void	AbstractTopNFunction.collectDelete(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectDelete(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectInsert(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectInsert(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectUpdateAfter(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectUpdateAfter(Collector<RowData> out, RowData inputRow, long rank)
protected void	AbstractTopNFunction.collectUpdateBefore(Collector<RowData> out, RowData inputRow)
protected void	AbstractTopNFunction.collectUpdateBefore(Collector<RowData> out, RowData inputRow, long rank)
void	TopNBufferCacheRemovalListener.onRemoval(org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification<RowData,V> removalNotification)
void	AppendOnlyFirstNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	AppendOnlyTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	FastTop1Function.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RetractableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	UpdatableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	TopNBuffer.putAll(RowData sortKey, Collection<RowData> values)	Puts a record list into the buffer under the sortKey.

Constructor parameters in org.apache.flink.table.runtime.operators.rank with type arguments of type RowData

Constructor	Description
AppendOnlyFirstNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber)
AppendOnlyTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator sortKeyGeneratedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
FastTop1Function(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator generatedSortKeyComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)
RetractableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, ComparableRecordComparator comparableRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)
TopNBuffer(Comparator<RowData> sortKeyComparator, Supplier<Collection<RowData>> valueSupplier)
TopNBuffer(Comparator<RowData> sortKeyComparator, Supplier<Collection<RowData>> valueSupplier)
UpdatableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, RowDataKeySelector rowKeySelector, GeneratedRecordComparator generatedRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber, long cacheSize)

Uses of RowData in org.apache.flink.table.runtime.operators.rank.window

Methods in org.apache.flink.table.runtime.operators.rank.window that return types with arguments of type RowData

Modifier and Type	Method	Description
WindowAggOperator<RowData,?>	WindowRankOperatorBuilder.build()

Method parameters in org.apache.flink.table.runtime.operators.rank.window with type arguments of type RowData

Modifier and Type	Method	Description
WindowRankOperatorBuilder	WindowRankOperatorBuilder.inputSerializer(AbstractRowDataSerializer<RowData> inputSerializer)
WindowRankOperatorBuilder	WindowRankOperatorBuilder.keySerializer(PagedTypeSerializer<RowData> keySerializer)

Uses of RowData in org.apache.flink.table.runtime.operators.rank.window.combines

Method parameters in org.apache.flink.table.runtime.operators.rank.window.combines with type arguments of type RowData

Modifier and Type	Method	Description
void	TopNRecordsCombiner.combine(WindowKey windowKey, Iterator<RowData> records)
RecordsCombiner	TopNRecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Constructor parameters in org.apache.flink.table.runtime.operators.rank.window.combines with type arguments of type RowData

Constructor	Description
Factory(GeneratedRecordComparator genSortKeyComparator, RowDataKeySelector sortKeySelector, TypeSerializer<RowData> recordSerializer, long topN)
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)
TopNRecordsCombiner(WindowTimerService<Long> timerService, StateKeyContext keyContext, WindowMapState<Long,List<RowData>> dataState, Comparator<RowData> sortKeyComparator, KeySelector<RowData,RowData> sortKeySelector, long topN, TypeSerializer<RowData> recordSerializer, boolean isEventTime)

Uses of RowData in org.apache.flink.table.runtime.operators.rank.window.processors

Methods in org.apache.flink.table.runtime.operators.rank.window.processors with parameters of type RowData

Modifier and Type	Method	Description
boolean	WindowRankProcessor.processElement(RowData key, RowData element)

Constructor parameters in org.apache.flink.table.runtime.operators.rank.window.processors with type arguments of type RowData

Constructor	Description
WindowRankProcessor(TypeSerializer<RowData> inputSerializer, GeneratedRecordComparator genSortKeyComparator, TypeSerializer<RowData> sortKeySerializer, WindowBuffer.Factory bufferFactory, long rankStart, long rankEnd, boolean outputRankNumber, int windowEndIndex, ZoneId shiftTimeZone)

Uses of RowData in org.apache.flink.table.runtime.operators.runtimefilter

Method parameters in org.apache.flink.table.runtime.operators.runtimefilter with type arguments of type RowData

Modifier and Type	Method	Description
void	GlobalRuntimeFilterBuilderOperator.processElement(StreamRecord<RowData> element)
void	LocalRuntimeFilterBuilderOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.runtimefilter.util

Methods in org.apache.flink.table.runtime.operators.runtimefilter.util that return RowData

Modifier and Type	Method	Description
static RowData	RuntimeFilterUtils.convertBloomFilterToRowData(int actualRowCount, byte[] serializedBloomFilter)
static RowData	RuntimeFilterUtils.convertBloomFilterToRowData(int actualRowCount, BloomFilter bloomFilter)

Uses of RowData in org.apache.flink.table.runtime.operators.sink

Method parameters in org.apache.flink.table.runtime.operators.sink with type arguments of type RowData

Modifier and Type	Method	Description
void	ConstraintEnforcer.processElement(StreamRecord<RowData> element)
void	OutputConversionOperator.processElement(StreamRecord<RowData> element)
void	RowKindSetter.processElement(StreamRecord<RowData> element)
void	SinkOperator.processElement(StreamRecord<RowData> element)
void	SinkUpsertMaterializer.processElement(StreamRecord<RowData> element)
void	StreamRecordTimestampInserter.processElement(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.sink with type arguments of type RowData

Constructor	Description
SinkOperator(SinkFunction<RowData> sinkFunction, int rowtimeFieldIndex)
SinkUpsertMaterializer(StateTtlConfig ttlConfig, TypeSerializer<RowData> serializer, GeneratedRecordEqualiser generatedRecordEqualiser, GeneratedRecordEqualiser generatedUpsertKeyEqualiser, int[] inputUpsertKey)

Uses of RowData in org.apache.flink.table.runtime.operators.sort

Fields in org.apache.flink.table.runtime.operators.sort with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	BaseTemporalSortOperator.collector
protected TimestampedCollector<RowData>	BaseTemporalSortOperator.collector

Methods in org.apache.flink.table.runtime.operators.sort with parameters of type RowData

Modifier and Type	Method	Description
void	BinaryExternalSorter.write(RowData current)
boolean	BinaryInMemorySortBuffer.write(RowData record)	Writes a given record to this sort buffer.
protected void	BinaryIndexedSortable.writeIndexAndNormalizedKey(RowData record, long currOffset)	Write of index and normalizedKey.

Method parameters in org.apache.flink.table.runtime.operators.sort with type arguments of type RowData

Modifier and Type	Method	Description
static BinaryInMemorySortBuffer	BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer, AbstractRowDataSerializer<RowData> inputSerializer, BinaryRowDataSerializer serializer, RecordComparator comparator, MemorySegmentPool memoryPool)	Create a memory sorter in `insert` way.
void	ProcTimeSortOperator.onEventTime(InternalTimer<RowData,VoidNamespace> timer)
void	RowTimeSortOperator.onEventTime(InternalTimer<RowData,VoidNamespace> timer)
void	ProcTimeSortOperator.onProcessingTime(InternalTimer<RowData,VoidNamespace> timer)
void	RowTimeSortOperator.onProcessingTime(InternalTimer<RowData,VoidNamespace> timer)
void	LimitOperator.processElement(StreamRecord<RowData> element)
void	ProcTimeSortOperator.processElement(StreamRecord<RowData> element)
void	RankOperator.processElement(StreamRecord<RowData> element)
void	RowTimeSortOperator.processElement(StreamRecord<RowData> element)
void	SortLimitOperator.processElement(StreamRecord<RowData> element)
void	SortOperator.processElement(StreamRecord<RowData> element)
void	StreamSortOperator.processElement(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.sort with type arguments of type RowData

Constructor	Description
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowDataSerializer<RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled)
BinaryExternalSorter(Object owner, MemoryManager memoryManager, long reservedMemorySize, IOManager ioManager, AbstractRowDataSerializer<RowData> inputSerializer, BinaryRowDataSerializer serializer, NormalizedKeyComputer normalizedKeyComputer, RecordComparator comparator, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled, float startSpillingFraction)
ProcTimeSortOperator(InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator gComparator)
RowTimeSortOperator(InternalTypeInfo<RowData> inputRowType, int rowTimeIdx, GeneratedRecordComparator gComparator)
StreamSortOperator(InternalTypeInfo<RowData> inputRowType, GeneratedRecordComparator gComparator)

Uses of RowData in org.apache.flink.table.runtime.operators.values

Methods in org.apache.flink.table.runtime.operators.values that return RowData

Modifier and Type	Method	Description
RowData	ValuesInputFormat.nextRecord(RowData reuse)

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

Modifier and Type	Method	Description
InternalTypeInfo<RowData>	ValuesInputFormat.getProducedType()

Methods in org.apache.flink.table.runtime.operators.values with parameters of type RowData

Modifier and Type	Method	Description
RowData	ValuesInputFormat.nextRecord(RowData reuse)

Constructor parameters in org.apache.flink.table.runtime.operators.values with type arguments of type RowData

Constructor	Description
ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput, InternalTypeInfo<RowData> returnType)
ValuesInputFormat(GeneratedInput<GenericInputFormat<RowData>> generatedInput, InternalTypeInfo<RowData> returnType)

Uses of RowData in org.apache.flink.table.runtime.operators.window.groupwindow.assigners

Methods in org.apache.flink.table.runtime.operators.window.groupwindow.assigners with parameters of type RowData

Modifier and Type	Method	Description
Collection<CountWindow>	CountSlidingWindowAssigner.assignWindows(RowData element, long timestamp)
Collection<CountWindow>	CountTumblingWindowAssigner.assignWindows(RowData element, long timestamp)
Collection<TimeWindow>	CumulativeWindowAssigner.assignWindows(RowData element, long timestamp)
abstract Collection<W>	GroupWindowAssigner.assignWindows(RowData element, long timestamp)	Given the timestamp and element, returns the set of windows into which it should be placed.
Collection<TimeWindow>	SessionWindowAssigner.assignWindows(RowData element, long timestamp)
Collection<TimeWindow>	SlidingWindowAssigner.assignWindows(RowData element, long timestamp)
Collection<TimeWindow>	TumblingWindowAssigner.assignWindows(RowData element, long timestamp)

Uses of RowData in org.apache.flink.table.runtime.operators.window.groupwindow.internal

Methods in org.apache.flink.table.runtime.operators.window.groupwindow.internal that return RowData

Modifier and Type	Method	Description
RowData	InternalWindowProcessFunction.Context.getWindowAccumulators(W window)	Gets the accumulators of the given window.

Methods in org.apache.flink.table.runtime.operators.window.groupwindow.internal with parameters of type RowData

Modifier and Type	Method	Description
Collection<W>	GeneralWindowProcessFunction.assignActualWindows(RowData inputRow, long timestamp)
abstract Collection<W>	InternalWindowProcessFunction.assignActualWindows(RowData inputRow, long timestamp)	Assigns the input element into the actual windows which the Trigger should trigger on.
Collection<W>	MergingWindowProcessFunction.assignActualWindows(RowData inputRow, long timestamp)
Collection<W>	PanedWindowProcessFunction.assignActualWindows(RowData inputRow, long timestamp)
Collection<W>	GeneralWindowProcessFunction.assignStateNamespace(RowData inputRow, long timestamp)
abstract Collection<W>	InternalWindowProcessFunction.assignStateNamespace(RowData inputRow, long timestamp)	Assigns the input element into the state namespace which the input element should be accumulated/retracted into.
Collection<W>	MergingWindowProcessFunction.assignStateNamespace(RowData inputRow, long timestamp)
Collection<W>	PanedWindowProcessFunction.assignStateNamespace(RowData inputRow, long timestamp)
void	InternalWindowProcessFunction.Context.setWindowAccumulators(W window, RowData acc)	Sets the accumulators of the given window.

Uses of RowData in org.apache.flink.table.runtime.operators.window.groupwindow.operator

Fields in org.apache.flink.table.runtime.operators.window.groupwindow.operator with type parameters of type RowData

Modifier and Type	Field	Description
protected TimestampedCollector<RowData>	WindowOperator.collector	This is used for emitting elements with a given timestamp.
protected InternalValueState<K,W,RowData>	WindowOperator.previousState

Method parameters in org.apache.flink.table.runtime.operators.window.groupwindow.operator with type arguments of type RowData

Modifier and Type	Method	Description
void	WindowOperator.processElement(StreamRecord<RowData> record)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.combines

Method parameters in org.apache.flink.table.runtime.operators.window.tvf.combines with type arguments of type RowData

Modifier and Type	Method	Description
void	RecordsCombiner.combine(WindowKey windowKey, Iterator<RowData> records)	Combines the buffered data into state based on the given window-key pair.
RecordsCombiner	RecordsCombiner.Factory.createRecordsCombiner(RuntimeContext runtimeContext, WindowTimerService<Long> timerService, KeyedStateBackend<RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)	Creates a RecordsCombiner that can combine buffered data into states.
RecordsCombiner	RecordsCombiner.LocalFactory.createRecordsCombiner(RuntimeContext runtimeContext, Collector<RowData> collector)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.common

Methods in org.apache.flink.table.runtime.operators.window.tvf.common that return types with arguments of type RowData

Modifier and Type	Method	Description
KeyedStateBackend<RowData>	WindowProcessor.Context.getKeyedStateBackend()	Returns the current KeyedStateBackend.

Methods in org.apache.flink.table.runtime.operators.window.tvf.common with parameters of type RowData

Modifier and Type	Method	Description
void	WindowProcessor.Context.output(RowData result)	Outputs results to downstream operators.
boolean	WindowProcessor.processElement(RowData key, RowData element)	Process an element with associated key from the input stream.

Method parameters in org.apache.flink.table.runtime.operators.window.tvf.common with type arguments of type RowData

Modifier and Type	Method	Description
void	WindowAggOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.operator

Methods in org.apache.flink.table.runtime.operators.window.tvf.operator with parameters of type RowData

Modifier and Type	Method	Description
protected void	WindowTableFunctionOperatorBase.collect(RowData inputRow, Collection<TimeWindow> allWindows)

Method parameters in org.apache.flink.table.runtime.operators.window.tvf.operator with type arguments of type RowData

Modifier and Type	Method	Description
void	UnalignedWindowTableFunctionOperator.onEventTime(InternalTimer<RowData,TimeWindow> timer)
void	UnalignedWindowTableFunctionOperator.onProcessingTime(InternalTimer<RowData,TimeWindow> timer)
void	AlignedWindowTableFunctionOperator.processElement(StreamRecord<RowData> element)
void	UnalignedWindowTableFunctionOperator.processElement(StreamRecord<RowData> element)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.slicing

Methods in org.apache.flink.table.runtime.operators.window.tvf.slicing with parameters of type RowData

Modifier and Type	Method	Description
long	SliceAssigner.assignSliceEnd(RowData element, ClockService clock)	Returns the end timestamp of a slice that the given element should belong.
long	SliceAssigners.WindowedSliceAssigner.assignSliceEnd(RowData element, ClockService clock)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.state

Methods in org.apache.flink.table.runtime.operators.window.tvf.state that return RowData

Modifier and Type	Method	Description
RowData	WindowValueState.value(W window)	Returns the current value for the state under current key and the given window.

Methods in org.apache.flink.table.runtime.operators.window.tvf.state that return types with arguments of type RowData

Modifier and Type	Method	Description
Iterable<Map.Entry<RowData,UV>>	WindowMapState.entries(W window)	Returns all the mappings in the state.
List<RowData>	WindowListState.get(W window)
Iterator<Map.Entry<RowData,UV>>	WindowMapState.iterator(W window)	Iterates over all the mappings in the state.
Iterable<RowData>	WindowMapState.keys(W window)	Returns all the keys in the state.

Methods in org.apache.flink.table.runtime.operators.window.tvf.state with parameters of type RowData

Modifier and Type	Method	Description
void	WindowListState.add(W window, RowData value)	Updates the operator state accessible by #get(W) by adding the given value to the list of values.
boolean	WindowMapState.contains(W window, RowData key)	Returns whether there exists the given mapping.
UV	WindowMapState.get(W window, RowData key)	Returns the current value associated with the given key.
void	WindowMapState.put(W window, RowData key, UV value)	Associates a new value with the given key.
void	WindowMapState.remove(W window, RowData key)	Deletes the mapping of the given key.
void	StateKeyContext.setCurrentKey(RowData key)	Sets current state key to given value.
void	WindowValueState.update(W window, RowData value)	Update the state with the given value under current key and the given window.

Method parameters in org.apache.flink.table.runtime.operators.window.tvf.state with type arguments of type RowData

Modifier and Type	Method	Description
void	WindowMapState.putAll(W window, Map<RowData,UV> map)	Copies all of the mappings from the given map into the state.

Constructor parameters in org.apache.flink.table.runtime.operators.window.tvf.state with type arguments of type RowData

Constructor	Description
WindowListState(InternalListState<RowData,W,RowData> windowState)
WindowListState(InternalListState<RowData,W,RowData> windowState)
WindowMapState(InternalMapState<RowData,W,RowData,UV> windowState)
WindowMapState(InternalMapState<RowData,W,RowData,UV> windowState)
WindowValueState(InternalValueState<RowData,W,RowData> windowState)
WindowValueState(InternalValueState<RowData,W,RowData> windowState)

Uses of RowData in org.apache.flink.table.runtime.operators.window.tvf.unslicing

Methods in org.apache.flink.table.runtime.operators.window.tvf.unslicing with parameters of type RowData

Modifier and Type	Method	Description
Optional<W>	UnsliceAssigner.assignActualWindow(RowData element, ClockService clock, MergingWindowProcessFunction<?,W> windowFunction)	Returns the Window that the given element should belong to be used to trigger on.
Optional<TimeWindow>	UnsliceAssigners.SessionUnsliceAssigner.assignActualWindow(RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)
Optional<TimeWindow>	UnsliceAssigners.WindowedUnsliceAssigner.assignActualWindow(RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)
Optional<W>	UnsliceAssigner.assignStateNamespace(RowData element, ClockService clock, MergingWindowProcessFunction<?,W> windowFunction)	Returns the Window that the given element should belong to be used as a namespace to restore the state.
Optional<TimeWindow>	UnsliceAssigners.SessionUnsliceAssigner.assignStateNamespace(RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)
Optional<TimeWindow>	UnsliceAssigners.WindowedUnsliceAssigner.assignStateNamespace(RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)
Collection<TimeWindow>	UnsliceAssigners.WindowedUnsliceAssigner.assignWindows(RowData element, long timestamp)
protected long	UnsliceAssigners.SessionUnsliceAssigner.getUtcTimestamp(RowData element, ClockService clock)

Uses of RowData in org.apache.flink.table.runtime.operators.wmassigners

Methods in org.apache.flink.table.runtime.operators.wmassigners with parameters of type RowData

Modifier and Type	Method	Description
Watermark	PunctuatedWatermarkStrategyWrapper.checkAndGetNextWatermark(RowData row, long extractedTimestamp)
Long	BoundedOutOfOrderWatermarkGenerator.currentWatermark(RowData row)
long	PeriodicWatermarkAssignerWrapper.extractTimestamp(RowData row, long recordTimestamp)
long	PunctuatedWatermarkStrategyWrapper.extractTimestamp(RowData element, long recordTimestamp)

Method parameters in org.apache.flink.table.runtime.operators.wmassigners with type arguments of type RowData

Modifier and Type	Method	Description
void	ProcTimeMiniBatchAssignerOperator.processElement(StreamRecord<RowData> element)
void	RowTimeMiniBatchAssginerOperator.processElement(StreamRecord<RowData> element)
void	WatermarkAssignerOperator.processElement(StreamRecord<RowData> element)

Constructor parameters in org.apache.flink.table.runtime.operators.wmassigners with type arguments of type RowData

Constructor	Description
WatermarkAssignerOperator(StreamOperatorParameters<RowData> parameters, int rowtimeFieldIndex, WatermarkGenerator watermarkGenerator, long idleTimeout, ProcessingTimeService processingTimeService)	Create a watermark assigner operator.

Uses of RowData in org.apache.flink.table.runtime.partitioner

Methods in org.apache.flink.table.runtime.partitioner that return types with arguments of type RowData

Modifier and Type	Method	Description
StreamPartitioner<RowData>	BinaryHashPartitioner.copy()

Method parameters in org.apache.flink.table.runtime.partitioner with type arguments of type RowData

Modifier and Type	Method	Description
int	BinaryHashPartitioner.selectChannel(SerializationDelegate<StreamRecord<RowData>> record)

Uses of RowData in org.apache.flink.table.runtime.typeutils

Classes in org.apache.flink.table.runtime.typeutils with type parameters of type RowData

Modifier and Type	Class	Description
class	AbstractRowDataSerializer<T extends RowData>	Row serializer, provided paged serialize paged method.

Methods in org.apache.flink.table.runtime.typeutils that return RowData

Modifier and Type	Method	Description
RowData	RowDataSerializer.copy(RowData from)
RowData	RowDataSerializer.copy(RowData from, RowData reuse)
RowData	RowDataSerializer.createInstance()
RowData	RowDataSerializer.deserialize(DataInputView source)
RowData	RowDataSerializer.deserialize(RowData reuse, DataInputView source)
RowData	RowDataSerializer.deserializeFromPages(AbstractPagedInputView source)
RowData	RowDataSerializer.deserializeFromPages(RowData reuse, AbstractPagedInputView source)
RowData	RowDataSerializer.mapFromPages(RowData reuse, AbstractPagedInputView source)

Methods in org.apache.flink.table.runtime.typeutils that return types with arguments of type RowData

Modifier and Type	Method	Description
TypeSerializer<RowData>	RowDataSerializer.duplicate()
static InternalTypeInfo<RowData>	InternalTypeInfo.of(RowType type)	Creates type information for a RowType represented by internal data structures.
static InternalTypeInfo<RowData>	InternalTypeInfo.ofFields(LogicalType... fieldTypes)	Creates type information for RowType represented by internal data structures.
static InternalTypeInfo<RowData>	InternalTypeInfo.ofFields(LogicalType[] fieldTypes, String[] fieldNames)	Creates type information for RowType represented by internal data structures.
TypeSerializerSchemaCompatibility<RowData>	RowDataSerializer.RowDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<RowData> oldSerializerSnapshot)
TypeSerializerSnapshot<RowData>	RowDataSerializer.snapshotConfiguration()

Methods in org.apache.flink.table.runtime.typeutils with parameters of type RowData

Modifier and Type	Method	Description
RowData	RowDataSerializer.copy(RowData from)
RowData	RowDataSerializer.copy(RowData from, RowData reuse)
RowData	RowDataSerializer.deserialize(RowData reuse, DataInputView source)
RowData	RowDataSerializer.deserializeFromPages(RowData reuse, AbstractPagedInputView source)
RowData	RowDataSerializer.mapFromPages(RowData reuse, AbstractPagedInputView source)
void	RowDataSerializer.serialize(RowData row, DataOutputView target)
int	RowDataSerializer.serializeToPages(RowData row, AbstractPagedOutputView target)
BinaryRowData	RowDataSerializer.toBinaryRow(RowData row)	Convert RowData into BinaryRowData.
OUT	PythonTypeUtils.DataConverter.toExternal(RowData row, int column)

Method parameters in org.apache.flink.table.runtime.typeutils with type arguments of type RowData

Modifier and Type	Method	Description
TypeSerializerSchemaCompatibility<RowData>	RowDataSerializer.RowDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<RowData> oldSerializerSnapshot)

Constructor parameters in org.apache.flink.table.runtime.typeutils with type arguments of type RowData

Constructor	Description
WindowKeySerializer(PagedTypeSerializer<RowData> keySerializer)

Uses of RowData in org.apache.flink.table.runtime.typeutils.serializers.python

Methods in org.apache.flink.table.runtime.typeutils.serializers.python that return RowData

Modifier and Type	Method	Description
RowData	RowDataSerializer.deserialize(DataInputView source)
RowData	RowDataSerializer.deserialize(RowData reuse, DataInputView source)

Methods in org.apache.flink.table.runtime.typeutils.serializers.python that return types with arguments of type RowData

Modifier and Type	Method	Description
TypeSerializerSchemaCompatibility<RowData>	RowDataSerializer.RowDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<RowData> oldSerializerSnapshot)
TypeSerializerSnapshot<RowData>	RowDataSerializer.snapshotConfiguration()

Methods in org.apache.flink.table.runtime.typeutils.serializers.python with parameters of type RowData

Modifier and Type	Method	Description
RowData	RowDataSerializer.deserialize(RowData reuse, DataInputView source)
void	RowDataSerializer.serialize(RowData row, DataOutputView target)

Method parameters in org.apache.flink.table.runtime.typeutils.serializers.python with type arguments of type RowData

Modifier and Type	Method	Description
TypeSerializerSchemaCompatibility<RowData>	RowDataSerializer.RowDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializerSnapshot<RowData> oldSerializerSnapshot)

Uses of RowData in org.apache.flink.table.runtime.util

Classes in org.apache.flink.table.runtime.util with type parameters of type RowData

Modifier and Type	Interface	Description
interface	RowIterator<T extends RowData>	An internal iterator interface which presents a more restrictive API than Iterator.

Methods in org.apache.flink.table.runtime.util that return RowData

Modifier and Type	Method	Description
RowData	WindowKey.getKey()

Methods in org.apache.flink.table.runtime.util with parameters of type RowData

Modifier and Type	Method	Description
void	ResettableExternalBuffer.add(RowData row)
void	ResettableRowBuffer.add(RowData row)	Appends the specified row to the end of this buffer.
WindowKey	WindowKey.replace(long window, RowData key)	Replace the currently stored key and window by the given new key and new window.

Constructors in org.apache.flink.table.runtime.util with parameters of type RowData

Constructor	Description
WindowKey(long window, RowData key)

Uses of RowData in org.apache.flink.table.runtime.util.collections.binary

Methods in org.apache.flink.table.runtime.util.collections.binary that return types with arguments of type RowData

Modifier and Type	Method	Description
KeyValueIterator<K,Iterator<RowData>>	AbstractBytesMultiMap.getEntryIterator(boolean requiresCopy)

Method parameters in org.apache.flink.table.runtime.util.collections.binary with type arguments of type RowData

Modifier and Type	Method	Description
void	AbstractBytesMultiMap.append(BytesMap.LookupInfo<K,Iterator<RowData>> lookupInfo, BinaryRowData value)	Append an value into the hash map's record area.

Constructor parameters in org.apache.flink.table.runtime.util.collections.binary with type arguments of type RowData

Constructor	Description
WindowBytesHashMap(Object owner, MemoryManager memoryManager, long memorySize, PagedTypeSerializer<RowData> keySer, int valueArity)
WindowBytesMultiMap(Object owner, MemoryManager memoryManager, long memorySize, PagedTypeSerializer<RowData> keySer, int valueArity)

Uses of RowData in org.apache.flink.table.toolbox

Method parameters in org.apache.flink.table.toolbox with type arguments of type RowData

Modifier and Type	Method	Description
void	TestScanTableSourceWithWatermarkPushDown.applyWatermark(WatermarkStrategy<RowData> watermarkStrategy)
void	TestSourceFunction.run(SourceFunction.SourceContext<RowData> ctx)

Constructor parameters in org.apache.flink.table.toolbox with type arguments of type RowData

Constructor	Description
TestSourceFunction(WatermarkStrategy<RowData> watermarkStrategy)

Uses of RowData in org.apache.flink.table.utils.print

Methods in org.apache.flink.table.utils.print with parameters of type RowData

Modifier and Type	Method	Description
String[]	RowDataToStringConverter.convert(RowData rowData)
String[]	TableauStyle.rowFieldsToString(RowData row)

Method parameters in org.apache.flink.table.utils.print with type arguments of type RowData

Modifier and Type	Method	Description
void	PrintStyle.print(Iterator<RowData> it, PrintWriter printWriter)	Displays the result.
void	RawContentStyle.print(Iterator<RowData> it, PrintWriter printWriter)
void	TableauStyle.print(Iterator<RowData> it, PrintWriter printWriter)
void	TableauStyle.printEmptyResult(Iterator<RowData> it, PrintWriter printWriter)
long	TableauStyle.printTable(Iterator<RowData> it, PrintWriter printWriter)	Print table with column names and borders.

Uses of RowData in org.apache.flink.table.utils.python

Methods in org.apache.flink.table.utils.python that return types with arguments of type RowData

Modifier and Type	Method	Description
static InputFormat<RowData,?>	PythonTableUtils.getInputFormat(List<Object[]> data, DataType dataType)	Wrap the unpickled python data with an InputFormat.

Uses of RowData in org.apache.flink.tests.util.flink

Methods in org.apache.flink.tests.util.flink that return types with arguments of type RowData

Modifier and Type	Method	Description
List<RowData>	FlinkDistribution.TestSqlGatewayRestClient.executeStatementWithResult(String sql)
List<RowData>	FlinkDistribution.TestSqlGatewayRestClient.getOperationResult(String operationHandle)