Package | Description |
---|---|
org.apache.flink.connector.file.src.enumerate | |
org.apache.flink.connectors.hive | |
org.apache.flink.table.connector.source |
Modifier and Type | Method and Description |
---|---|
void |
DynamicFileEnumerator.setDynamicFilteringData(DynamicFilteringData data)
Provides a
DynamicFilteringData for filtering while the enumerator is enumerating
splits. |
Modifier and Type | Method and Description |
---|---|
void |
HiveSourceDynamicFileEnumerator.setDynamicFilteringData(DynamicFilteringData data) |
Modifier and Type | Method and Description |
---|---|
DynamicFilteringData |
DynamicFilteringEvent.getData() |
Modifier and Type | Method and Description |
---|---|
static boolean |
DynamicFilteringData.isEqual(DynamicFilteringData data,
DynamicFilteringData another) |
Constructor and Description |
---|
DynamicFilteringEvent(DynamicFilteringData data) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.