Package org.apache.iceberg

Class MicroBatches

java.lang.Object

org.apache.iceberg.MicroBatches

public class MicroBatches
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MicroBatches.MicroBatch
static class	MicroBatches.MicroBatchBuilder

Method Summary

Modifier and Type	Method	Description
static MicroBatches.MicroBatchBuilder	from(Snapshot snapshot, FileIO io)
static CloseableIterable<FileScanTask>	openManifestFile(FileIO io, java.util.Map<java.lang.Integer,PartitionSpec> specsById, boolean caseSensitive, Snapshot snapshot, ManifestFile manifestFile, boolean scanAllFiles)
static java.util.List<Pair<ManifestFile,java.lang.Integer>>	skippedManifestIndexesFromSnapshot(FileIO io, Snapshot snapshot, long startFileIndex, boolean scanAllFiles)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

skippedManifestIndexesFromSnapshot

public static java.util.List<Pair<ManifestFile,java.lang.Integer>> skippedManifestIndexesFromSnapshot(FileIO io,
                                                                                                            Snapshot snapshot,
                                                                                                            long startFileIndex,
                                                                                                            boolean scanAllFiles)

openManifestFile

public static CloseableIterable<FileScanTask> openManifestFile(FileIO io,
                                                               java.util.Map<java.lang.Integer,PartitionSpec> specsById,
                                                               boolean caseSensitive,
                                                               Snapshot snapshot,
                                                               ManifestFile manifestFile,
                                                               boolean scanAllFiles)

from

public static MicroBatches.MicroBatchBuilder from(Snapshot snapshot,
                                                  FileIO io)