This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 39ffff0 [hotfix][python][docs] Fix the mistakes of connector options
in the examples
add fc581da [FLINK-19888][hive] Migrate Hive source to FLIP-27 source
interface for streaming
No new revisions were added by this update.
Summary of changes:
.../connector/file/src/AbstractFileSource.java | 14 ++
.../file/src/ContinuousEnumerationSettings.java | 4 +-
.../file/src/PendingSplitsCheckpoint.java | 4 +-
.../ContinuousHivePendingSplitsCheckpoint.java | 53 +++++
...nuousHivePendingSplitsCheckpointSerializer.java | 139 ++++++++++++
.../hive/ContinuousHiveSplitEnumerator.java | 230 ++++++++++++++++++++
.../apache/flink/connectors/hive/HiveSource.java | 205 +++++++++++++++---
.../flink/connectors/hive/HiveTableSource.java | 195 +++++------------
.../read/HiveContinuousMonitoringFunction.java | 241 ---------------------
.../hive/read/HiveContinuousPartitionFetcher.java | 2 +-
.../filesystem/ContinuousPartitionFetcher.java | 4 +-
.../flink/table/filesystem/PartitionFetcher.java | 2 +-
12 files changed, 669 insertions(+), 424 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ContinuousHivePendingSplitsCheckpoint.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ContinuousHivePendingSplitsCheckpointSerializer.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ContinuousHiveSplitEnumerator.java
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java
