org.apache.flink.connectors.hive

Class DynamicHiveSplitEnumerator

java.lang.Object

org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator<HiveSourceSplit>

org.apache.flink.connectors.hive.DynamicHiveSplitEnumerator

All Implemented Interfaces:

AutoCloseable, CheckpointListener, SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>>, SupportsHandleExecutionAttemptSourceEvent

public class DynamicHiveSplitEnumerator
extends DynamicFileSplitEnumerator<HiveSourceSplit>

DynamicFileSplitEnumerator for hive source.

Constructor Summary

Constructors

Constructor and Description
DynamicHiveSplitEnumerator(SplitEnumeratorContext<HiveSourceSplit> context, DynamicFileEnumerator.Provider fileEnumeratorFactory, FileSplitAssigner.Provider splitAssignerFactory)

Method Summary

Methods inherited from class org.apache.flink.connector.file.src.impl.DynamicFileSplitEnumerator

addReader, addSplitsBack, close, handleSourceEvent, handleSourceEvent, handleSplitRequest, snapshotState, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.connector.source.SplitEnumerator

notifyCheckpointComplete

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

DynamicHiveSplitEnumerator

public DynamicHiveSplitEnumerator(SplitEnumeratorContext<HiveSourceSplit> context,
                                  DynamicFileEnumerator.Provider fileEnumeratorFactory,
                                  FileSplitAssigner.Provider splitAssignerFactory)