Uses of Class
org.apache.paimon.operation.DefaultValueAssigner

Packages that use DefaultValueAssigner

Package	Description
org.apache.paimon.flink.lookup
org.apache.paimon.operation
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot

Uses of DefaultValueAssigner in org.apache.paimon.flink.lookup

Constructors in org.apache.paimon.flink.lookup with parameters of type DefaultValueAssigner

Constructor and Description
LookupDataTableScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Uses of DefaultValueAssigner in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return DefaultValueAssigner

Modifier and Type	Method and Description
static DefaultValueAssigner	DefaultValueAssigner.create(TableSchema schema)
DefaultValueAssigner	DefaultValueAssigner.handleReadRowType(RowType readRowType)

Uses of DefaultValueAssigner in org.apache.paimon.table.source

Constructors in org.apache.paimon.table.source with parameters of type DefaultValueAssigner

Constructor and Description
DataTableBatchScan(boolean pkTable, CoreOptions options, SnapshotReader snapshotReader, DefaultValueAssigner defaultValueAssigner)
DataTableStreamScan(CoreOptions options, SnapshotReader snapshotReader, SnapshotManager snapshotManager, boolean supportStreamingReadOverwrite, DefaultValueAssigner defaultValueAssigner)

Uses of DefaultValueAssigner in org.apache.paimon.table.source.snapshot

Constructors in org.apache.paimon.table.source.snapshot with parameters of type DefaultValueAssigner

Constructor and Description
SnapshotReaderImpl(FileStoreScan scan, TableSchema tableSchema, CoreOptions options, SnapshotManager snapshotManager, SplitGenerator splitGenerator, java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer, DefaultValueAssigner defaultValueAssigner, FileStorePathFactory pathFactory, String tableName, IndexFileHandler indexFileHandler)