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 869f0bc [FLINK-19885][webui] FLIP-104: Add More Metrics to JobManager
in Web UI
add 56207e8 [FLINK-19365][hive] Migrate Hive source to FLIP-27 source
interface for batch
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-connector-hive/pom.xml | 14 +
.../connectors/hive/HiveParallelismInference.java | 6 +-
.../apache/flink/connectors/hive/HiveSource.java | 92 +++++++
.../connectors/hive/HiveSourceFileEnumerator.java | 135 ++++++++++
.../connectors/hive/HiveSourceSplitSerializer.java | 100 +++++++
.../flink/connectors/hive/HiveTableSource.java | 27 +-
.../hive/read/HiveBulkFormatAdapter.java | 295 +++++++++++++++++++++
...veTableInputSplit.java => HiveSourceSplit.java} | 64 +++--
.../connectors/hive/read/HiveTableInputFormat.java | 10 +-
.../table/module/hive/HiveModuleFactoryTest.java | 1 -
10 files changed, 701 insertions(+), 43 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSource.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceFileEnumerator.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceSplitSerializer.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveBulkFormatAdapter.java
copy
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/{HiveTableInputSplit.java
=> HiveSourceSplit.java} (52%)
