org.apache.flink.connectors.hive

Class ContinuousHivePendingSplitsCheckpoint

java.lang.Object

org.apache.flink.connector.file.src.PendingSplitsCheckpoint<HiveSourceSplit>

org.apache.flink.connectors.hive.ContinuousHivePendingSplitsCheckpoint

public class ContinuousHivePendingSplitsCheckpoint
extends PendingSplitsCheckpoint<HiveSourceSplit>

The checkpoint of current state of continuous hive source reading.

Constructor Summary

Constructors

Constructor and Description
ContinuousHivePendingSplitsCheckpoint(Collection<HiveSourceSplit> splits, Comparable<?> currentReadOffset, Collection<List<String>> seenPartitionsSinceOffset)

Method Summary

Modifier and Type	Method and Description
Comparable<?>	getCurrentReadOffset()
Collection<List<String>>	getSeenPartitionsSinceOffset()

Methods inherited from class org.apache.flink.connector.file.src.PendingSplitsCheckpoint

fromCollectionSnapshot, fromCollectionSnapshot, getAlreadyProcessedPaths, getSplits, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ContinuousHivePendingSplitsCheckpoint

public ContinuousHivePendingSplitsCheckpoint(Collection<HiveSourceSplit> splits,
                                             Comparable<?> currentReadOffset,
                                             Collection<List<String>> seenPartitionsSinceOffset)

Method Detail

getCurrentReadOffset

public Comparable<?> getCurrentReadOffset()

getSeenPartitionsSinceOffset

public Collection<List<String>> getSeenPartitionsSinceOffset()