Uses of Class
org.apache.paimon.flink.NestedProjectedRowData

Packages that use NestedProjectedRowData

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.source
org.apache.paimon.flink.source.align
org.apache.paimon.flink.source.operator

Uses of NestedProjectedRowData in org.apache.paimon.flink

Methods in org.apache.paimon.flink that return NestedProjectedRowData

Modifier and Type	Method and Description
static NestedProjectedRowData	NestedProjectedRowData.copy(NestedProjectedRowData rowData)
abstract NestedProjectedRowData	Projection.getOuterProjectRow(RowType rowType)
NestedProjectedRowData	NestedProjectedRowData.replaceRow(org.apache.flink.table.data.RowData row)

Methods in org.apache.paimon.flink with parameters of type NestedProjectedRowData

Modifier and Type	Method and Description
static NestedProjectedRowData	NestedProjectedRowData.copy(NestedProjectedRowData rowData)

Uses of NestedProjectedRowData in org.apache.paimon.flink.source

Fields in org.apache.paimon.flink.source declared as NestedProjectedRowData

Modifier and Type	Field and Description
protected NestedProjectedRowData	FlinkSource.rowData

Methods in org.apache.paimon.flink.source with parameters of type NestedProjectedRowData

Modifier and Type	Method and Description
static FlinkSource	LogHybridSourceFactory.buildHybridFirstSource(Table table, RowType readType, Predicate predicate, NestedProjectedRowData rowData)
static void	FlinkRecordsWithSplitIds.emitRecord(org.apache.flink.api.connector.source.SourceReaderContext context, org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData> element, org.apache.flink.api.connector.source.SourceOutput<org.apache.flink.table.data.RowData> output, FileStoreSourceSplitState state, FileStoreSourceReaderMetrics metrics, NestedProjectedRowData nestedProjectedRowData)

Constructors in org.apache.paimon.flink.source with parameters of type NestedProjectedRowData

Constructor and Description
ContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode, NestedProjectedRowData rowData)
FileStoreSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, NestedProjectedRowData rowData)
FlinkSource(ReadBuilder readBuilder, Long limit, NestedProjectedRowData rowData)
StaticFileStoreSource(ReadBuilder readBuilder, Long limit, int splitBatchSize, FlinkConnectorOptions.SplitAssignMode splitAssignMode, DynamicPartitionFilteringInfo dynamicPartitionFilteringInfo, NestedProjectedRowData rowData)

Uses of NestedProjectedRowData in org.apache.paimon.flink.source.align

Constructors in org.apache.paimon.flink.source.align with parameters of type NestedProjectedRowData

Constructor and Description
AlignedContinuousFileStoreSource(ReadBuilder readBuilder, Map<String,String> options, Long limit, BucketMode bucketMode, NestedProjectedRowData rowData)
AlignedSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, TableRead tableRead, FileStoreSourceReaderMetrics metrics, IOManager ioManager, Long limit, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.flink.connector.file.src.reader.BulkFormat.RecordIterator<org.apache.flink.table.data.RowData>>> elementsQueue, NestedProjectedRowData rowData)

Uses of NestedProjectedRowData in org.apache.paimon.flink.source.operator

Methods in org.apache.paimon.flink.source.operator with parameters of type NestedProjectedRowData

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	MonitorSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, ReadBuilder readBuilder, long monitorInterval, boolean emitSnapshotWatermark, boolean shuffleBucketWithPartition, BucketMode bucketMode, NestedProjectedRowData nestedProjectedRowData)

Constructors in org.apache.paimon.flink.source.operator with parameters of type NestedProjectedRowData

Constructor and Description
ReadOperator(ReadBuilder readBuilder, NestedProjectedRowData nestedProjectedRowData)