Uses of Class
org.apache.paimon.io.DataFileMeta

Packages that use DataFileMeta

Package	Description
org.apache.paimon.append
org.apache.paimon.compact
org.apache.paimon.deletionvectors
org.apache.paimon.flink.sink
org.apache.paimon.flink.source.align
org.apache.paimon.iceberg
org.apache.paimon.io
org.apache.paimon.manifest
org.apache.paimon.mergetree
org.apache.paimon.mergetree.compact
org.apache.paimon.migrate
org.apache.paimon.operation
org.apache.paimon.table
org.apache.paimon.table.query
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.system
org.apache.paimon.utils

Uses of DataFileMeta in org.apache.paimon.append

Methods in org.apache.paimon.append that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	BucketedAppendCompactManager.allFiles()
List<DataFileMeta>	UnawareAppendCompactionTask.compactAfter()
List<DataFileMeta>	UnawareAppendCompactionTask.compactBefore()
Collection<DataFileMeta>	AppendOnlyWriter.dataFiles()
static Comparator<DataFileMeta>	BucketedAppendCompactManager.fileComparator(boolean ignoreOverlap) New files may be created during the compaction process, then the results of the compaction may be put after the new files, and this order will be disrupted.
List<DataFileMeta>	BucketedAppendCompactManager.CompactRewriter.rewrite(List<DataFileMeta> compactBefore)

Methods in org.apache.paimon.append with parameters of type DataFileMeta

Modifier and Type	Method and Description
void	BucketedAppendCompactManager.addNewFile(DataFileMeta file)

Method parameters in org.apache.paimon.append with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	AppendOnlyWriter.addNewFiles(List<DataFileMeta> files)
List<DataFileMeta>	BucketedAppendCompactManager.CompactRewriter.rewrite(List<DataFileMeta> compactBefore)

Constructor parameters in org.apache.paimon.append with type arguments of type DataFileMeta

Constructor and Description
AppendOnlyWriter(FileIO fileIO, IOManager ioManager, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, long maxSequenceNumber, CompactManager compactManager, IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead, boolean forceCompact, DataFilePathFactory pathFactory, CommitIncrement increment, boolean useWriteBuffer, boolean spillable, String fileCompression, CompressOptions spillCompression, SimpleColStatsCollector.Factory[] statsCollectors, MemorySize maxDiskSize, FileIndexOptions fileIndexOptions, boolean asyncFileWrite)
AutoCompactTask(DeletionVectorsMaintainer dvMaintainer, List<DataFileMeta> toCompact, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)
BucketedAppendCompactManager(ExecutorService executor, List<DataFileMeta> restored, DeletionVectorsMaintainer dvMaintainer, int minFileNum, int maxFileNum, long targetFileSize, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)
FullCompactTask(DeletionVectorsMaintainer dvMaintainer, Collection<DataFileMeta> inputs, long targetFileSize, BucketedAppendCompactManager.CompactRewriter rewriter, CompactionMetrics.Reporter metricsReporter)
MultiTableUnawareAppendCompactionTask(BinaryRow partition, List<DataFileMeta> files, Identifier identifier)
UnawareAppendCompactionTask(BinaryRow partition, List<DataFileMeta> files)

Uses of DataFileMeta in org.apache.paimon.compact

Methods in org.apache.paimon.compact that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	CompactResult.after()
List<DataFileMeta>	NoopCompactManager.allFiles()
Collection<DataFileMeta>	CompactManager.allFiles()
List<DataFileMeta>	CompactResult.before()
List<DataFileMeta>	CompactResult.changelog()
List<DataFileMeta>	CompactUnit.files()

Methods in org.apache.paimon.compact with parameters of type DataFileMeta

Modifier and Type	Method and Description
void	NoopCompactManager.addNewFile(DataFileMeta file)
void	CompactManager.addNewFile(DataFileMeta file) Add a new file.

Method parameters in org.apache.paimon.compact with type arguments of type DataFileMeta

Modifier and Type	Method and Description
static CompactUnit	CompactUnit.fromFiles(int outputLevel, List<DataFileMeta> files)
protected String	CompactTask.logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)
protected String	CompactTask.logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)

Constructors in org.apache.paimon.compact with parameters of type DataFileMeta

Constructor and Description
CompactResult(DataFileMeta before, DataFileMeta after)

Constructor parameters in org.apache.paimon.compact with type arguments of type DataFileMeta

Constructor and Description
CompactResult(List<DataFileMeta> before, List<DataFileMeta> after)
CompactResult(List<DataFileMeta> before, List<DataFileMeta> after)
CompactResult(List<DataFileMeta> before, List<DataFileMeta> after, List<DataFileMeta> changelog)
CompactResult(List<DataFileMeta> before, List<DataFileMeta> after, List<DataFileMeta> changelog)
CompactResult(List<DataFileMeta> before, List<DataFileMeta> after, List<DataFileMeta> changelog)

Uses of DataFileMeta in org.apache.paimon.deletionvectors

Method parameters in org.apache.paimon.deletionvectors with type arguments of type DataFileMeta

Modifier and Type	Method and Description
static DeletionVector.Factory	DeletionVector.factory(FileIO fileIO, List<DataFileMeta> files, List<DeletionFile> deletionFiles)

Uses of DataFileMeta in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return DataFileMeta

Modifier and Type	Method and Description
DataFileMeta	RewriteFileIndexSink.FileIndexProcessor.process(BinaryRow partition, int bucket, DataFileMeta dataFileMeta)

Methods in org.apache.paimon.flink.sink with parameters of type DataFileMeta

Modifier and Type	Method and Description
DataFileMeta	RewriteFileIndexSink.FileIndexProcessor.process(BinaryRow partition, int bucket, DataFileMeta dataFileMeta)

Method parameters in org.apache.paimon.flink.sink with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	StoreSinkWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)
void	StoreSinkWriteImpl.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)

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

Methods in org.apache.paimon.flink.source.align that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	PlaceholderSplit.beforeFiles()
List<DataFileMeta>	PlaceholderSplit.dataFiles()

Uses of DataFileMeta in org.apache.paimon.iceberg

Methods in org.apache.paimon.iceberg with parameters of type DataFileMeta

Modifier and Type	Method and Description
protected abstract boolean	AbstractIcebergCommitCallback.shouldAddFileToIceberg(DataFileMeta meta)
protected boolean	PrimaryKeyIcebergCommitCallback.shouldAddFileToIceberg(DataFileMeta meta)
protected boolean	AppendOnlyIcebergCommitCallback.shouldAddFileToIceberg(DataFileMeta meta)

Uses of DataFileMeta in org.apache.paimon.io

Methods in org.apache.paimon.io that return DataFileMeta

Modifier and Type	Method and Description
DataFileMeta	DataFileMeta.copy(byte[] newEmbeddedIndex)
DataFileMeta	DataFileMeta.copy(List<String> newExtraFiles)
DataFileMeta	DataFileMeta08Serializer.deserialize(DataInputView in)
static DataFileMeta	DataFileMeta.forAppend(String fileName, long fileSize, long rowCount, SimpleStats rowStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, FileSource fileSource)
static DataFileMeta	DataFileMeta.forAppend(String fileName, long fileSize, long rowCount, SimpleStats rowStats, long minSequenceNumber, long maxSequenceNumber, long schemaId, List<String> extraFiles, byte[] embeddedIndex, FileSource fileSource)
DataFileMeta	DataFileMetaSerializer.fromRow(InternalRow row)
DataFileMeta	DataFileMeta.rename(String newFileName)
DataFileMeta	KeyValueDataFileWriter.result()
DataFileMeta	RowDataFileWriter.result()
DataFileMeta	DataFileMeta.upgrade(int newLevel)

Methods in org.apache.paimon.io that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	DataIncrement.changelogFiles()
List<DataFileMeta>	CompactIncrement.changelogFiles()
List<DataFileMeta>	CompactIncrement.compactAfter()
List<DataFileMeta>	CompactIncrement.compactBefore()
RollingFileWriter<KeyValue,DataFileMeta>	KeyValueFileWriterFactory.createRollingChangelogFileWriter(int level)
RollingFileWriter<KeyValue,DataFileMeta>	KeyValueFileWriterFactory.createRollingMergeTreeFileWriter(int level, FileSource fileSource)
List<DataFileMeta>	DataIncrement.deletedFiles()
List<DataFileMeta>	DataFileMeta08Serializer.deserializeList(DataInputView source)
List<DataFileMeta>	DataIncrement.newFiles()

Methods in org.apache.paimon.io with parameters of type DataFileMeta

Modifier and Type	Method and Description
RecordReader<T>	FileReaderFactory.createRecordReader(DataFileMeta file)
RecordReader<KeyValue>	KeyValueFileReaderFactory.createRecordReader(DataFileMeta file)
void	DataFileMeta08Serializer.serialize(DataFileMeta meta, DataOutputView target)
static boolean	FileIndexSkipper.skip(FileIO fileIO, TableSchema dataSchema, List<Predicate> dataFilter, DataFilePathFactory dataFilePathFactory, DataFileMeta file)
InternalRow	DataFileMetaSerializer.toRow(DataFileMeta meta)

Method parameters in org.apache.paimon.io with type arguments of type DataFileMeta

Modifier and Type	Method and Description
static long	DataFileMeta.getMaxSequenceNumber(List<DataFileMeta> fileMetas)
void	DataFileMeta08Serializer.serializeList(List<DataFileMeta> records, DataOutputView target)

Constructor parameters in org.apache.paimon.io with type arguments of type DataFileMeta

Constructor and Description
CompactIncrement(List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter, List<DataFileMeta> changelogFiles)
CompactIncrement(List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter, List<DataFileMeta> changelogFiles)
CompactIncrement(List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter, List<DataFileMeta> changelogFiles)
DataIncrement(List<DataFileMeta> newFiles, List<DataFileMeta> deletedFiles, List<DataFileMeta> changelogFiles)
DataIncrement(List<DataFileMeta> newFiles, List<DataFileMeta> deletedFiles, List<DataFileMeta> changelogFiles)
DataIncrement(List<DataFileMeta> newFiles, List<DataFileMeta> deletedFiles, List<DataFileMeta> changelogFiles)

Uses of DataFileMeta in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return DataFileMeta

Modifier and Type	Method and Description
DataFileMeta	ManifestEntry.file()

Constructors in org.apache.paimon.manifest with parameters of type DataFileMeta

Constructor and Description
ManifestEntry(FileKind kind, BinaryRow partition, int bucket, int totalBuckets, DataFileMeta file)

Uses of DataFileMeta in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree that return DataFileMeta

Modifier and Type	Method and Description
DataFileMeta	DataFileReader.remoteFile()
DataFileMeta	LookupFile.remoteFile()

Methods in org.apache.paimon.mergetree that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	Levels.allFiles()
Collection<DataFileMeta>	MergeTreeWriter.dataFiles()
List<DataFileMeta>	SortedRun.files()
TreeSet<DataFileMeta>	Levels.level0()

Methods in org.apache.paimon.mergetree with parameters of type DataFileMeta

Modifier and Type	Method and Description
void	Levels.addLevel0File(DataFileMeta file)
static SortedRun	SortedRun.fromSingle(DataFileMeta file)

Method parameters in org.apache.paimon.mergetree with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	MergeTreeWriter.addNewFiles(List<DataFileMeta> files)
static SortedRun	SortedRun.fromSorted(List<DataFileMeta> sortedFiles)
static SortedRun	SortedRun.fromUnsorted(List<DataFileMeta> unsortedFiles, Comparator<InternalRow> keyComparator)
static <T> T	LookupUtils.lookup(Comparator<InternalRow> keyComparator, InternalRow target, SortedRun level, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	LookupUtils.lookup(Levels levels, InternalRow key, int startLevel, BiFunctionWithIOE<InternalRow,SortedRun,T> lookup, BiFunctionWithIOE<InternalRow,TreeSet<DataFileMeta>,T> level0Lookup)
static <T> T	LookupUtils.lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
static <T> T	LookupUtils.lookupLevel0(Comparator<InternalRow> keyComparator, InternalRow target, TreeSet<DataFileMeta> level0, BiFunctionWithIOE<InternalRow,DataFileMeta,T> lookup)
void	Levels.update(List<DataFileMeta> before, List<DataFileMeta> after)
void	Levels.update(List<DataFileMeta> before, List<DataFileMeta> after)

Constructors in org.apache.paimon.mergetree with parameters of type DataFileMeta

Constructor and Description
DataFileReader(File localFile, DataFileMeta remoteFile, LookupStoreReader reader)
LookupFile(File localFile, DataFileMeta remoteFile, LookupStoreReader reader, Runnable callback)

Constructor parameters in org.apache.paimon.mergetree with type arguments of type DataFileMeta

Constructor and Description
Levels(Comparator<InternalRow> keyComparator, List<DataFileMeta> inputFiles, int numLevels)
LookupLevels(Levels levels, Comparator<InternalRow> keyComparator, RowType keyType, LookupLevels.ValueProcessor<T> valueProcessor, IOFunction<DataFileMeta,RecordReader<KeyValue>> fileReaderFactory, java.util.function.Function<String,File> localFileFactory, LookupStoreFactory lookupStoreFactory, java.util.function.Function<Long,BloomFilter.Builder> bfGenerator, org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> lookupFileCache)

Uses of DataFileMeta in org.apache.paimon.mergetree.compact

Methods in org.apache.paimon.mergetree.compact that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	MergeTreeCompactManager.allFiles()
protected static List<DataFileMeta>	AbstractCompactRewriter.extractFilesFromSections(List<List<SortedRun>> sections)

Methods in org.apache.paimon.mergetree.compact with parameters of type DataFileMeta

Modifier and Type	Method and Description
void	MergeTreeCompactManager.addNewFile(DataFileMeta file)
CompactResult	CompactRewriter.upgrade(int outputLevel, DataFileMeta file) Upgrade file to new level, usually file data is not rewritten, only the metadata is updated.
CompactResult	AbstractCompactRewriter.upgrade(int outputLevel, DataFileMeta file)
CompactResult	ChangelogMergeTreeRewriter.upgrade(int outputLevel, DataFileMeta file)
protected ChangelogMergeTreeRewriter.UpgradeStrategy	LookupMergeTreeCompactRewriter.upgradeStrategy(int outputLevel, DataFileMeta file)
protected ChangelogMergeTreeRewriter.UpgradeStrategy	FullChangelogMergeTreeCompactRewriter.upgradeStrategy(int outputLevel, DataFileMeta file)
protected abstract ChangelogMergeTreeRewriter.UpgradeStrategy	ChangelogMergeTreeRewriter.upgradeStrategy(int outputLevel, DataFileMeta file)

Method parameters in org.apache.paimon.mergetree.compact with type arguments of type DataFileMeta

Modifier and Type	Method and Description
protected String	MergeTreeCompactTask.logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)
protected String	MergeTreeCompactTask.logMetric(long startMillis, List<DataFileMeta> compactBefore, List<DataFileMeta> compactAfter)
protected void	MergeTreeCompactRewriter.notifyRewriteCompactBefore(List<DataFileMeta> files)
protected void	LookupMergeTreeCompactRewriter.notifyRewriteCompactBefore(List<DataFileMeta> files)

Constructor parameters in org.apache.paimon.mergetree.compact with type arguments of type DataFileMeta

Constructor and Description
IntervalPartition(List<DataFileMeta> inputFiles, Comparator<InternalRow> keyComparator)

Uses of DataFileMeta in org.apache.paimon.migrate

Methods in org.apache.paimon.migrate that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
static List<DataFileMeta>	FileMetaUtils.construct(FileIO fileIO, String format, String location, Table paimonTable, java.util.function.Predicate<FileStatus> filter, Path dir, Map<Path,Path> rollback)

Method parameters in org.apache.paimon.migrate with type arguments of type DataFileMeta

Modifier and Type	Method and Description
static CommitMessage	FileMetaUtils.commitFile(BinaryRow partition, List<DataFileMeta> dataFileMetas)

Uses of DataFileMeta in org.apache.paimon.operation

Fields in org.apache.paimon.operation with type parameters of type DataFileMeta

Modifier and Type	Field and Description
protected List<DataFileMeta>	FileStoreWrite.State.dataFiles

Methods in org.apache.paimon.operation that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	AppendOnlyFileStoreWrite.compactRewrite(BinaryRow partition, int bucket, java.util.function.Function<String,DeletionVector> dvFactory, List<DataFileMeta> toCompact)
static Map<BinaryRow,Map<Integer,List<DataFileMeta>>>	FileStoreScan.Plan.groupByPartFiles(List<ManifestEntry> files) Return a map group by partition and bucket.

Method parameters in org.apache.paimon.operation with type arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	AppendOnlyFileStoreWrite.compactRewrite(BinaryRow partition, int bucket, java.util.function.Function<String,DeletionVector> dvFactory, List<DataFileMeta> toCompact)
RecordReader<KeyValue>	MergeFileSplitRead.createMergeReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<DeletionFile> deletionFiles, boolean keepDelete)
RecordReader<KeyValue>	MergeFileSplitRead.createNoMergeReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<DeletionFile> deletionFiles, boolean onlyFilterKey)
RecordReader<InternalRow>	RawFileSplitRead.createReader(BinaryRow partition, int bucket, List<DataFileMeta> files, List<IOExceptionSupplier<DeletionVector>> dvFactories)
protected RecordWriter<InternalRow>	AppendOnlyFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected MergeTreeWriter	KeyValueFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected abstract RecordWriter<T>	AbstractFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer deletionVectorsMaintainer)
void	FileStoreWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files) Notify that some new files are created at given snapshot in given bucket.
void	AbstractFileStoreWrite.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files)

Constructor parameters in org.apache.paimon.operation with type arguments of type DataFileMeta

Constructor and Description
State(BinaryRow partition, int bucket, long baseSnapshotId, long lastModifiedCommitIdentifier, Collection<DataFileMeta> dataFiles, long maxSequenceNumber, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, CommitIncrement commitIncrement)

Uses of DataFileMeta in org.apache.paimon.table

Methods in org.apache.paimon.table with parameters of type DataFileMeta

Modifier and Type	Method and Description
default SimpleStats	FileStoreTable.getSchemaFieldStats(DataFileMeta dataFileMeta)

Uses of DataFileMeta in org.apache.paimon.table.query

Method parameters in org.apache.paimon.table.query with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	LocalTableQuery.refreshFiles(BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)
void	LocalTableQuery.refreshFiles(BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)

Uses of DataFileMeta in org.apache.paimon.table.sink

Method parameters in org.apache.paimon.table.sink with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	TableWriteImpl.notifyNewFiles(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> files) Notify that some new files are created at given snapshot in given bucket.

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

Fields in org.apache.paimon.table.source with type parameters of type DataFileMeta

Modifier and Type	Field and Description
List<DataFileMeta>	SplitGenerator.SplitGroup.files

Methods in org.apache.paimon.table.source that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	DataSplit.beforeFiles()
List<DataFileMeta>	DataSplit.dataFiles()

Method parameters in org.apache.paimon.table.source with type arguments of type DataFileMeta

Modifier and Type	Method and Description
static DeletionFile.Factory	DeletionFile.factory(List<DataFileMeta> files, List<DeletionFile> deletionFiles)
static SplitGenerator.SplitGroup	SplitGenerator.SplitGroup.nonRawConvertibleGroup(List<DataFileMeta> files)
static SplitGenerator.SplitGroup	SplitGenerator.SplitGroup.rawConvertibleGroup(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	SplitGenerator.splitForBatch(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	AppendOnlySplitGenerator.splitForBatch(List<DataFileMeta> input)
List<SplitGenerator.SplitGroup>	MergeTreeSplitGenerator.splitForBatch(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	SplitGenerator.splitForStreaming(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	AppendOnlySplitGenerator.splitForStreaming(List<DataFileMeta> files)
List<SplitGenerator.SplitGroup>	MergeTreeSplitGenerator.splitForStreaming(List<DataFileMeta> files)
DataSplit.Builder	DataSplit.Builder.withBeforeFiles(List<DataFileMeta> beforeFiles)
DataSplit.Builder	DataSplit.Builder.withDataFiles(List<DataFileMeta> dataFiles)

Uses of DataFileMeta in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
List<DataFileMeta>	FileMonitorTable.FileChange.beforeFiles()
List<DataFileMeta>	FileMonitorTable.FileChange.dataFiles()

Constructor parameters in org.apache.paimon.table.system with type arguments of type DataFileMeta

Constructor and Description
FileChange(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)
FileChange(long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)

Uses of DataFileMeta in org.apache.paimon.utils

Methods in org.apache.paimon.utils that return types with arguments of type DataFileMeta

Modifier and Type	Method and Description
Collection<DataFileMeta>	RecordWriter.dataFiles() Get all data files maintained by this writer.

Method parameters in org.apache.paimon.utils with type arguments of type DataFileMeta

Modifier and Type	Method and Description
void	RecordWriter.addNewFiles(List<DataFileMeta> files) Add files to the internal CompactManager.