Package | Description |
---|---|
org.apache.flink.connector.file.src.impl | |
org.apache.flink.connectors.hive |
Constructor and Description |
---|
DynamicFileSplitEnumerator(SplitEnumeratorContext<SplitT> context,
DynamicFileEnumerator.Provider fileEnumeratorFactory,
FileSplitAssigner.Provider splitAssignerFactory) |
Modifier and Type | Class and Description |
---|---|
static class |
HiveSourceDynamicFileEnumerator.Provider
A factory to create
HiveSourceDynamicFileEnumerator . |
Constructor and Description |
---|
DynamicHiveSplitEnumerator(SplitEnumeratorContext<HiveSourceSplit> context,
DynamicFileEnumerator.Provider fileEnumeratorFactory,
FileSplitAssigner.Provider splitAssignerFactory) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.