protected BulkFormat<RowData,HiveSourceSplit> |
HiveSourceBuilder.createDefaultBulkFormat() |
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.createEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext) |
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.createEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext) |
static List<HiveSourceSplit> |
HiveSourceFileEnumerator.createInputSplits(int minNumSplits,
List<HiveTablePartition> partitions,
org.apache.hadoop.mapred.JobConf jobConf,
boolean isForParallelismInfer) |
PendingSplitsCheckpoint<HiveSourceSplit> |
ContinuousHivePendingSplitsCheckpointSerializer.deserialize(int version,
byte[] serialized) |
SimpleVersionedSerializer<PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.getEnumeratorCheckpointSerializer() |
SimpleVersionedSerializer<HiveSourceSplit> |
HiveSource.getSplitSerializer() |
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext,
PendingSplitsCheckpoint<HiveSourceSplit> checkpoint) |
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext,
PendingSplitsCheckpoint<HiveSourceSplit> checkpoint) |
PendingSplitsCheckpoint<HiveSourceSplit> |
ContinuousHiveSplitEnumerator.snapshotState(long checkpointId) |