public class ContinuousHivePendingSplitsCheckpoint extends PendingSplitsCheckpoint<HiveSourceSplit>
Constructor and Description |
---|
ContinuousHivePendingSplitsCheckpoint(Collection<HiveSourceSplit> splits,
Comparable<?> currentReadOffset,
Collection<List<String>> seenPartitionsSinceOffset) |
Modifier and Type | Method and Description |
---|---|
Comparable<?> |
getCurrentReadOffset() |
Collection<List<String>> |
getSeenPartitionsSinceOffset() |
fromCollectionSnapshot, fromCollectionSnapshot, getAlreadyProcessedPaths, getSplits, toString
public ContinuousHivePendingSplitsCheckpoint(Collection<HiveSourceSplit> splits, Comparable<?> currentReadOffset, Collection<List<String>> seenPartitionsSinceOffset)
public Comparable<?> getCurrentReadOffset()
public Collection<List<String>> getSeenPartitionsSinceOffset()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.