You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/16 02:08:36 UTC

[flink] branch master updated (3f487c9 -> bb11993)

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 3f487c9  [FLINK-17590][fs-connector] Support bucket lifecycle listener in streaming file sink buckets
     add bb11993  [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     |  81 +++++++++++-----
 .../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, 329 insertions(+), 39 deletions(-)
 create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/ConsumeOrder.java
 create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java