Package | Description |
---|---|
org.apache.flink.connector.file.src.enumerate | |
org.apache.flink.connector.file.src.impl | |
org.apache.flink.connectors.hive |
Modifier and Type | Interface and Description |
---|---|
interface |
DynamicFileEnumerator
FileEnumerator that supports dynamic filtering. |
Modifier and Type | Class and Description |
---|---|
class |
BlockSplittingRecursiveEnumerator
This
FileEnumerator enumerates all files under the given paths recursively, and creates a
separate split for each file block. |
class |
NonSplittingRecursiveEnumerator
This
FileEnumerator enumerates all files under the given paths recursively. |
Modifier and Type | Method and Description |
---|---|
FileEnumerator |
FileEnumerator.Provider.create() |
Constructor and Description |
---|
ContinuousFileSplitEnumerator(SplitEnumeratorContext<FileSourceSplit> context,
FileEnumerator enumerator,
FileSplitAssigner splitAssigner,
Path[] paths,
Collection<Path> alreadyDiscoveredPaths,
long discoveryInterval) |
Modifier and Type | Class and Description |
---|---|
class |
HiveSourceDynamicFileEnumerator
A
DynamicFileEnumerator implementation for hive source. |
class |
HiveSourceFileEnumerator
A
FileEnumerator implementation for hive source, which generates splits based on HiveTablePartition s. |
Modifier and Type | Method and Description |
---|---|
FileEnumerator |
HiveSourceFileEnumerator.Provider.create() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.