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 965c101 [FLINK-11395][avro] Support for Avro StreamingFileSink
add 32bd094 [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, 329 insertions(+), 40 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
