@PublicEvolving public class PendingSplitsCheckpoint<SplitT extends FileSourceSplit> extends Object
Modifier | Constructor and Description |
---|---|
protected |
PendingSplitsCheckpoint(Collection<SplitT> splits,
Collection<Path> alreadyProcessedPaths) |
Modifier and Type | Method and Description |
---|---|
static <T extends FileSourceSplit> |
fromCollectionSnapshot(Collection<T> splits) |
static <T extends FileSourceSplit> |
fromCollectionSnapshot(Collection<T> splits,
Collection<Path> alreadyProcessedPaths) |
Collection<Path> |
getAlreadyProcessedPaths() |
Collection<SplitT> |
getSplits() |
String |
toString() |
protected PendingSplitsCheckpoint(Collection<SplitT> splits, Collection<Path> alreadyProcessedPaths)
public Collection<SplitT> getSplits()
public Collection<Path> getAlreadyProcessedPaths()
public static <T extends FileSourceSplit> PendingSplitsCheckpoint<T> fromCollectionSnapshot(Collection<T> splits)
public static <T extends FileSourceSplit> PendingSplitsCheckpoint<T> fromCollectionSnapshot(Collection<T> splits, Collection<Path> alreadyProcessedPaths)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.