public class MicroBatches
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
MicroBatches.MicroBatch |
static class |
MicroBatches.MicroBatchBuilder |
Modifier and Type | Method and 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) |
public static java.util.List<Pair<ManifestFile,java.lang.Integer>> skippedManifestIndexesFromSnapshot(FileIO io, Snapshot snapshot, long startFileIndex, boolean scanAllFiles)
public static CloseableIterable<FileScanTask> openManifestFile(FileIO io, java.util.Map<java.lang.Integer,PartitionSpec> specsById, boolean caseSensitive, Snapshot snapshot, ManifestFile manifestFile, boolean scanAllFiles)
public static MicroBatches.MicroBatchBuilder from(Snapshot snapshot, FileIO io)