This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 56e91700ca5 [FLINK-28701] Remove WIP prefix of
ALL_EXCHANGE_HYBRID_FULL and ALL_EXCHANGE_HYBRID_SELECTIVE in BatchShuffleMode
and expose them to documents.
add dd16b080130 [FLINK-27338][hive] Improve splitting file for Hive source
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/table/hive/hive_read_write.md | 35 ++++++
.../docs/connectors/table/hive/hive_read_write.md | 35 ++++++
.../hive/ContinuousHiveSplitEnumerator.java | 19 ++--
.../apache/flink/connectors/hive/HiveOptions.java | 18 ++++
.../apache/flink/connectors/hive/HiveSource.java | 9 --
.../flink/connectors/hive/HiveSourceBuilder.java | 32 ++++--
.../hive/HiveSourceDynamicFileEnumerator.java | 9 +-
.../connectors/hive/HiveSourceFileEnumerator.java | 119 ++++++++++++++++++---
.../flink/connectors/hive/HiveTableSource.java | 11 +-
.../hive/HiveSourceDynamicFileEnumeratorTest.java | 1 -
.../hive/HiveSourceFileEnumeratorTest.java | 98 +++++++++++++++++
.../connectors/hive/PartitionMonitorTest.java | 7 +-
.../src/test/resources/orc/test.orc | Bin 0 -> 4591 bytes
13 files changed, 334 insertions(+), 59 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceFileEnumeratorTest.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/orc/test.orc
