This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 32bd094 [FLINK-17435][hive] Hive non-partitioned source supports
streaming read
add e69d21b Revert "[FLINK-17435][hive] Hive non-partitioned source
supports streaming read"
No new revisions were added by this update.
Summary of changes:
.../apache/flink/connectors/hive/ConsumeOrder.java | 63 -------------
.../flink/connectors/hive/HiveTableSource.java | 82 +++++-----------
.../read/HiveContinuousMonitoringFunction.java | 12 ++-
.../hive/read/HiveTableFileInputFormat.java | 104 ---------------------
.../connectors/hive/read/HiveTableInputFormat.java | 4 -
.../flink/connectors/hive/HiveTableSourceTest.java | 81 +---------------
.../source/ContinuousFileMonitoringFunction.java | 15 +--
.../flink/table/filesystem/FileSystemOptions.java | 8 +-
8 files changed, 40 insertions(+), 329 deletions(-)
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ConsumeOrder.java
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java
