Uses of Class
org.apache.flink.table.types.logical.RowType

Packages that use RowType

Package	Description
org.apache.flink.connector.jdbc.dialect
org.apache.flink.connector.jdbc.internal.converter
org.apache.flink.connector.jdbc.table
org.apache.flink.connectors.hive.read
org.apache.flink.formats.avro
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.parquet
org.apache.flink.formats.parquet.row
org.apache.flink.formats.parquet.utils
org.apache.flink.orc
org.apache.flink.orc.nohive
org.apache.flink.table.factories
org.apache.flink.table.factories.datagen
org.apache.flink.table.filesystem
org.apache.flink.table.planner.sources
org.apache.flink.table.runtime.arrow
org.apache.flink.table.runtime.arrow.serializers
org.apache.flink.table.runtime.functions.python
org.apache.flink.table.runtime.functions.python.arrow
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.over.frame
org.apache.flink.table.runtime.operators.python
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.runners.python.beam
org.apache.flink.table.runtime.typeutils
org.apache.flink.table.types.logical
org.apache.flink.table.types.logical.utils

Uses of RowType in org.apache.flink.connector.jdbc.dialect

Methods in org.apache.flink.connector.jdbc.dialect with parameters of type RowType

Modifier and Type	Method and Description
JdbcRowConverter	PostgresDialect.getRowConverter(RowType rowType)
JdbcRowConverter	JdbcDialect.getRowConverter(RowType rowType) Get converter that convert jdbc object and Flink internal object each other.
JdbcRowConverter	MySQLDialect.getRowConverter(RowType rowType)

Uses of RowType in org.apache.flink.connector.jdbc.internal.converter

Fields in org.apache.flink.connector.jdbc.internal.converter declared as RowType

Modifier and Type	Field and Description
protected RowType	AbstractJdbcRowConverter.rowType

Constructors in org.apache.flink.connector.jdbc.internal.converter with parameters of type RowType

Constructor and Description
AbstractJdbcRowConverter(RowType rowType)
DerbyRowConverter(RowType rowType)
MySQLRowConverter(RowType rowType)
PostgresRowConverter(RowType rowType)

Uses of RowType in org.apache.flink.connector.jdbc.table

Constructors in org.apache.flink.connector.jdbc.table with parameters of type RowType

Constructor and Description
JdbcRowDataLookupFunction(JdbcOptions options, JdbcLookupOptions lookupOptions, String[] fieldNames, DataType[] fieldTypes, String[] keyNames, RowType rowType)

Uses of RowType in org.apache.flink.connectors.hive.read

Constructors in org.apache.flink.connectors.hive.read with parameters of type RowType

Constructor and Description
HiveBulkFormatAdapter(JobConfWrapper jobConfWrapper, List<String> partitionKeys, String[] fieldNames, DataType[] fieldTypes, String hiveVersion, RowType producedRowType, boolean useMapRedReader)
HiveCompactReaderFactory(org.apache.hadoop.hive.metastore.api.StorageDescriptor sd, Properties properties, org.apache.hadoop.mapred.JobConf jobConf, CatalogTable catalogTable, String hiveVersion, RowType producedRowType, boolean useMapRedReader)

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

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

Modifier and Type	Method and Description
static AvroToRowDataConverters.AvroToRowDataConverter	AvroToRowDataConverters.createRowConverter(RowType rowType)

Constructors in org.apache.flink.formats.avro with parameters of type RowType

Constructor and Description
AvroRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> typeInfo) Creates a Avro deserialization schema for the given logical type.
AvroRowDataSerializationSchema(RowType rowType) Creates an Avro serialization schema with the given record row type.
AvroRowDataSerializationSchema(RowType rowType, SerializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema, RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter) Creates an Avro serialization schema with the given record row type, nested schema and runtime converters.

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

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

Modifier and Type	Method and Description
static RowType	DebeziumAvroSerializationSchema.createDebeziumAvroRowType(DataType dataType)
static RowType	DebeziumAvroDeserializationSchema.createDebeziumAvroRowType(DataType databaseSchema)

Constructors in org.apache.flink.formats.avro.registry.confluent.debezium with parameters of type RowType

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

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

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

Modifier and Type	Method and Description
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema	CsvRowSchemaConverter.convert(RowType rowType) Convert RowType to CsvSchema.
static RowDataToCsvConverters.RowDataToCsvConverter	RowDataToCsvConverters.createRowConverter(RowType type)
CsvToRowDataConverters.CsvToRowDataConverter	CsvToRowDataConverters.createRowConverter(RowType rowType, boolean isTopLevel)

Constructors in org.apache.flink.formats.csv with parameters of type RowType

Constructor and Description
Builder(RowType rowType) Creates a CsvRowDataSerializationSchema expecting the given RowType.
Builder(RowType rowType, TypeInformation<RowData> resultTypeInfo) Creates a CSV deserialization schema for the given TypeInformation with optional parameters.
CsvInputFormat(Path[] filePaths, DataType[] fieldTypes, String[] fieldNames, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema csvSchema, RowType formatRowType, int[] selectFields, List<String> partitionKeys, String defaultPartValue, long limit, int[] csvSelectFieldToProjectFieldMapping, int[] csvSelectFieldToCsvFieldMapping, boolean ignoreParseErrors)

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

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

Modifier and Type	Method and Description
JsonToRowDataConverters.JsonToRowDataConverter	JsonToRowDataConverters.createRowConverter(RowType rowType)

Constructors in org.apache.flink.formats.json with parameters of type RowType

Constructor and Description
JsonRowDataDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean failOnMissingField, boolean ignoreParseErrors, TimestampFormat timestampFormat)
JsonRowDataSerializationSchema(RowType rowType, TimestampFormat timestampFormat, JsonOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

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

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

Modifier and Type	Method and Description
static CanalJsonDeserializationSchema.Builder	CanalJsonDeserializationSchema.builder(RowType rowType, TypeInformation<RowData> resultTypeInfo) Creates A builder for building a CanalJsonDeserializationSchema.

Constructors in org.apache.flink.formats.json.canal with parameters of type RowType

Constructor and Description
CanalJsonSerializationSchema(RowType rowType, TimestampFormat timestampFormat, JsonOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

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

Constructors in org.apache.flink.formats.json.debezium with parameters of type RowType

Constructor and Description
DebeziumJsonSerializationSchema(RowType rowType, TimestampFormat timestampFormat, JsonOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

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

Constructors in org.apache.flink.formats.json.maxwell with parameters of type RowType

Constructor and Description
MaxwellJsonDeserializationSchema(RowType rowType, TypeInformation<RowData> resultTypeInfo, boolean ignoreParseErrors, TimestampFormat timestampFormatOption)
MaxwellJsonSerializationSchema(RowType rowType, TimestampFormat timestampFormat, JsonOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

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

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

Modifier and Type	Method and Description
static <SplitT extends FileSourceSplit> ParquetColumnarRowInputFormat<SplitT>	ParquetColumnarRowInputFormat.createPartitionedFormat(Configuration hadoopConfig, RowType producedRowType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive) Create a partitioned ParquetColumnarRowInputFormat, the partition columns can be generated by Path.

Constructors in org.apache.flink.formats.parquet with parameters of type RowType

Constructor and Description
ParquetColumnarRowInputFormat(Configuration hadoopConfig, RowType projectedType, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive) Constructor to create parquet format without extra fields.
ParquetColumnarRowInputFormat(Configuration hadoopConfig, RowType projectedType, RowType producedType, ColumnBatchFactory<SplitT> batchFactory, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive) Constructor to create parquet format with extra fields created by ColumnBatchFactory.
ParquetVectorizedInputFormat(SerializableConfiguration hadoopConfig, RowType projectedType, ColumnBatchFactory<SplitT> batchFactory, int batchSize, boolean isUtcTimestamp, boolean isCaseSensitive)

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

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

Modifier and Type	Method and Description
static ParquetWriterFactory<RowData>	ParquetRowDataBuilder.createWriterFactory(RowType rowType, Configuration conf, boolean utcTimestamp) Create a parquet BulkWriter.Factory.

Constructors in org.apache.flink.formats.parquet.row with parameters of type RowType

Constructor and Description
FlinkParquetBuilder(RowType rowType, Configuration conf, boolean utcTimestamp)
ParquetRowDataBuilder(org.apache.parquet.io.OutputFile path, RowType rowType, boolean utcTimestamp)
ParquetRowDataWriter(org.apache.parquet.io.api.RecordConsumer recordConsumer, RowType rowType, org.apache.parquet.schema.GroupType schema, boolean utcTimestamp)

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

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

Modifier and Type	Method and Description
static org.apache.parquet.schema.MessageType	ParquetSchemaConverter.convertToParquetMessageType(String name, RowType rowType)

Uses of RowType in org.apache.flink.orc

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

Modifier and Type

Method and Description

static <SplitT extends FileSourceSplit> OrcColumnarRowFileInputFormat<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch,SplitT>

OrcColumnarRowFileInputFormat.createPartitionedFormat(OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> shim, Configuration hadoopConfig, RowType tableType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize) Create a partitioned OrcColumnarRowFileInputFormat, the partition columns can be generated by split.

Constructors in org.apache.flink.orc with parameters of type RowType

Constructor and Description
OrcColumnarRowFileInputFormat(OrcShim<BatchT> shim, Configuration hadoopConfig, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, ColumnBatchFactory<BatchT,SplitT> batchFactory, RowType projectedOutputType)

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

Methods in org.apache.flink.orc.nohive with parameters of type RowType

Modifier and Type	Method and Description
static <SplitT extends FileSourceSplit> OrcColumnarRowFileInputFormat<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,SplitT>	OrcNoHiveColumnarRowInputFormat.createPartitionedFormat(Configuration hadoopConfig, RowType tableType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize) Create a partitioned OrcColumnarRowFileInputFormat, the partition columns can be generated by split.

Uses of RowType in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return RowType

Modifier and Type	Method and Description
default RowType	FileSystemFormatFactory.ReaderContext.getFormatRowType() RowType of table that excludes partition key fields.

Uses of RowType in org.apache.flink.table.factories.datagen

Methods in org.apache.flink.table.factories.datagen with parameters of type RowType

Modifier and Type	Method and Description
DataGeneratorContainer	RandomGeneratorVisitor.visit(RowType rowType)

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

Constructors in org.apache.flink.table.filesystem with parameters of type RowType

Constructor and Description
FileSystemLookupFunction(PartitionFetcher<P> partitionFetcher, PartitionFetcher.Context<P> fetcherContext, PartitionReader<P,RowData> partitionReader, RowType rowType, int[] lookupKeys, java.time.Duration reloadInterval)

Uses of RowType in org.apache.flink.table.planner.sources

Methods in org.apache.flink.table.planner.sources that return RowType

Modifier and Type	Method and Description
static RowType	DynamicSourceUtils.createProducedType(TableSchema schema, DynamicTableSource source) Returns the DataType that a source should produce as the input into the runtime.

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

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

Modifier and Type	Method and Description
static RowArrowReader	ArrowUtils.createRowArrowReader(org.apache.arrow.vector.VectorSchemaRoot root, RowType rowType) Creates an ArrowReader for the specified VectorSchemaRoot.
static ArrowWriter<Row>	ArrowUtils.createRowArrowWriter(org.apache.arrow.vector.VectorSchemaRoot root, RowType rowType) Creates an ArrowWriter for the specified VectorSchemaRoot.
static RowDataArrowReader	ArrowUtils.createRowDataArrowReader(org.apache.arrow.vector.VectorSchemaRoot root, RowType rowType) Creates an ArrowReader for blink planner for the specified VectorSchemaRoot.
static ArrowWriter<RowData>	ArrowUtils.createRowDataArrowWriter(org.apache.arrow.vector.VectorSchemaRoot root, RowType rowType) Creates an ArrowWriter for blink planner for the specified VectorSchemaRoot.
static org.apache.arrow.vector.types.pojo.Schema	ArrowUtils.toArrowSchema(RowType rowType) Returns the Arrow schema of the specified type.

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

Fields in org.apache.flink.table.runtime.arrow.serializers declared as RowType

Modifier and Type	Field and Description
protected RowType	ArrowSerializer.inputType The input RowType.
protected RowType	ArrowSerializer.outputType The output RowType.

Constructors in org.apache.flink.table.runtime.arrow.serializers with parameters of type RowType

Constructor and Description
ArrowSerializer(RowType inputType, RowType outputType)
RowArrowSerializer(RowType inputType, RowType outputType)
RowDataArrowSerializer(RowType inputType, RowType outputType)

Uses of RowType in org.apache.flink.table.runtime.functions.python

Fields in org.apache.flink.table.runtime.functions.python declared as RowType

Modifier and Type	Field and Description
protected RowType	AbstractPythonStatelessFunctionFlatMap.inputType The input logical type.
protected RowType	AbstractPythonStatelessFunctionFlatMap.outputType The output logical type.
protected RowType	AbstractPythonStatelessFunctionFlatMap.userDefinedFunctionInputType The user-defined function input logical type.
protected RowType	AbstractPythonStatelessFunctionFlatMap.userDefinedFunctionOutputType The user-defined function output logical type.

Constructors in org.apache.flink.table.runtime.functions.python with parameters of type RowType

Constructor and Description
AbstractPythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
AbstractPythonStatelessFunctionFlatMap(Configuration config, RowType inputType, RowType outputType, int[] userDefinedFunctionInputOffsets)
PythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
PythonTableFunctionFlatMap(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)

Uses of RowType in org.apache.flink.table.runtime.functions.python.arrow

Constructors in org.apache.flink.table.runtime.functions.python.arrow with parameters of type RowType

Constructor and Description
ArrowPythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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

Constructors in org.apache.flink.table.runtime.operators.aggregate with parameters of type RowType

Constructor and Description
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, RowType inputType, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a MiniBatchGroupAggFunction.

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

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

Modifier and Type	Method and Description
static HashJoinOperator	HashJoinOperator.newHashJoinOperator(HashJoinType type, GeneratedJoinCondition condFuncCode, boolean reverseJoinFunction, boolean[] filterNullKeys, GeneratedProjection buildProjectionCode, GeneratedProjection probeProjectionCode, boolean tryDistinctBuildRow, int buildRowSize, long buildRowCount, long probeRowCount, RowType keyType)

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

Constructors in org.apache.flink.table.runtime.operators.over.frame with parameters of type RowType

Constructor and Description
RangeSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator lboundComparator, GeneratedRecordComparator rboundComparator)
RangeUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, GeneratedRecordComparator boundComparator)
RowSlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound, long rightBound)
RowUnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction, long leftBound)
SlidingOverFrame(RowType inputType, RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)
UnboundedFollowingOverFrame(RowType valueType, GeneratedAggsHandleFunction aggsHandleFunction)
UnboundedOverWindowFrame(GeneratedAggsHandleFunction aggsHandleFunction, RowType valueType)

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

Fields in org.apache.flink.table.runtime.operators.python declared as RowType

Modifier and Type	Field and Description
protected RowType	AbstractStatelessFunctionOperator.inputType The input logical type.
protected RowType	AbstractStatelessFunctionOperator.outputType The output logical type.
protected RowType	AbstractStatelessFunctionOperator.userDefinedFunctionInputType The user-defined function input logical type.
protected RowType	AbstractStatelessFunctionOperator.userDefinedFunctionOutputType The user-defined function output logical type.

Constructors in org.apache.flink.table.runtime.operators.python with parameters of type RowType

Constructor and Description
AbstractStatelessFunctionOperator(Configuration config, RowType inputType, RowType outputType, int[] userDefinedFunctionInputOffsets)

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

Fields in org.apache.flink.table.runtime.operators.python.aggregate declared as RowType

Modifier and Type	Field and Description
protected RowType	PythonStreamGroupAggregateOperator.inputType The input logical type.
protected RowType	PythonStreamGroupAggregateOperator.outputType The output logical type.
protected RowType	PythonStreamGroupAggregateOperator.userDefinedFunctionInputType The user-defined function input logical type.

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

Modifier and Type	Method and Description
protected RowType	PythonStreamGroupAggregateOperator.getKeyType()

Constructors in org.apache.flink.table.runtime.operators.python.aggregate with parameters of type RowType

Constructor and Description
PythonStreamGroupAggregateOperator(Configuration config, RowType inputType, RowType outputType, PythonAggregateFunctionInfo[] aggregateFunctions, DataViewUtils.DataViewSpec[][] dataViewSpecs, int[] grouping, int indexOfCountStar, boolean countStarInserted, boolean generateUpdateBefore, long minRetentionTime, long maxRetentionTime)

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

Constructors in org.apache.flink.table.runtime.operators.python.aggregate.arrow with parameters of type RowType

Constructor and Description
AbstractArrowPythonAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int[] groupingSet, int[] udafInputOffsets)

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

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

Constructor and Description
BatchArrowPythonGroupAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int[] groupKey, int[] groupingSet, int[] udafInputOffsets)
BatchArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, int maxLimitSize, long windowSize, long slideSize, int[] namedProperties, int[] groupKey, int[] groupingSet, int[] udafInputOffsets)
BatchArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, long[] lowerBoundary, long[] upperBoundary, boolean[] isRangeWindows, int[] aggWindowIndex, int[] groupKey, int[] groupingSet, int[] udafInputOffsets, int inputTimeFieldIndex, boolean asc)

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

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

Constructor and Description
AbstractStreamArrowPythonBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
AbstractStreamArrowPythonBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonGroupWindowAggregateFunctionOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, WindowAssigner<W> windowAssigner, Trigger<W> trigger, long allowedLateness, int[] namedProperties, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonProcTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonProcTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonRowTimeBoundedRangeOperator(Configuration config, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)
StreamArrowPythonRowTimeBoundedRowsOperator(Configuration config, long minRetentionTime, long maxRetentionTime, PythonFunctionInfo[] pandasAggFunctions, RowType inputType, RowType outputType, int inputTimeFieldIndex, long lowerBoundary, int[] groupingSet, int[] udafInputOffsets)

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

Constructors in org.apache.flink.table.runtime.operators.python.scalar with parameters of type RowType

Constructor and Description
AbstractRowDataPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
AbstractRowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
PythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
RowDataPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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

Constructors in org.apache.flink.table.runtime.operators.python.scalar.arrow with parameters of type RowType

Constructor and Description
ArrowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
RowDataArrowPythonScalarFunctionOperator(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)

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

Constructors in org.apache.flink.table.runtime.operators.python.table with parameters of type RowType

Constructor and Description
AbstractPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)
PythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)
RowDataPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)

Uses of RowType in org.apache.flink.table.runtime.runners.python.beam

Constructors in org.apache.flink.table.runtime.runners.python.beam with parameters of type RowType

Constructor and Description
BeamTableStatefulPythonFunctionRunner(String taskName, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, String functionUrn, FlinkFnApi.UserDefinedAggregateFunctions userDefinedFunctions, String coderUrn, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer, KeyedStateBackend keyedStateBackend, TypeSerializer keySerializer, MemoryManager memoryManager, double managedMemoryFraction)
BeamTableStatelessPythonFunctionRunner(String taskName, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, String functionUrn, FlinkFnApi.UserDefinedFunctions userDefinedFunctions, String coderUrn, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer, MemoryManager memoryManager, double managedMemoryFraction)

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

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

Modifier and Type	Method and Description
RowType	InternalTypeInfo.toRowType()

Methods in org.apache.flink.table.runtime.typeutils with parameters of type RowType

Modifier and Type	Method and Description
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder	PythonTypeUtils.getRowCoderProto(RowType rowType, String coderUrn)
static InternalTypeInfo<RowData>	InternalTypeInfo.of(RowType type) Creates type information for a RowType represented by internal data structures.
FlinkFnApi.Schema.FieldType	PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(RowType rowType)

Constructors in org.apache.flink.table.runtime.typeutils with parameters of type RowType

Constructor and Description
RowDataSerializer(RowType rowType)

Uses of RowType in org.apache.flink.table.types.logical

Methods in org.apache.flink.table.types.logical that return RowType

Modifier and Type	Method and Description
static RowType	RowType.of(boolean isNullable, LogicalType... types)
static RowType	RowType.of(boolean nullable, LogicalType[] types, String[] names)
static RowType	RowType.of(LogicalType... types)
static RowType	RowType.of(LogicalType[] types, String[] names)

Methods in org.apache.flink.table.types.logical with parameters of type RowType

Modifier and Type	Method and Description
R	LogicalTypeVisitor.visit(RowType rowType)

Uses of RowType in org.apache.flink.table.types.logical.utils

Methods in org.apache.flink.table.types.logical.utils that return RowType

Modifier and Type	Method and Description
static RowType	LogicalTypeUtils.renameRowFields(RowType rowType, List<String> newFieldNames) Renames the fields of the given RowType.
static RowType	LogicalTypeUtils.toRowType(LogicalType t) Converts any logical type to a row type.

Methods in org.apache.flink.table.types.logical.utils with parameters of type RowType

Modifier and Type	Method and Description
static RowType	LogicalTypeUtils.renameRowFields(RowType rowType, List<String> newFieldNames) Renames the fields of the given RowType.
R	LogicalTypeDefaultVisitor.visit(RowType rowType)
LogicalType	LogicalTypeDuplicator.visit(RowType rowType)