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/11 08:40:37 UTC

[flink] branch master updated (5f744d3 -> d90b5e0)

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 5f744d3  [FLINK-17454][python] Specify a port number for gateway callback server from python gateway.
     add d90b5e0  [FLINK-17603][table][core] Prepare Hive partitioned streaming source

No new revisions were added by this update.

Summary of changes:
 .../connectors/hive/read/HiveTableInputFormat.java | 23 +++++--
 .../hive/read/HiveVectorizedOrcSplitReader.java    |  5 ++
 .../read/HiveVectorizedParquetSplitReader.java     |  5 ++
 .../flink/connectors/hive/read/SplitReader.java    | 13 ++++
 .../java/org/apache/flink/orc/OrcSplitReader.java  |  7 +++
 .../vector/ParquetColumnarRowSplitReader.java      | 31 +++++++++
 .../vector/ParquetColumnarRowSplitReaderTest.java  | 13 +++-
 .../ContinuousFileProcessingMigrationTest.java     |  2 +-
 .../hdfstests/ContinuousFileProcessingTest.java    |  3 +-
 .../environment/StreamExecutionEnvironment.java    |  4 +-
 .../source/ContinuousFileReaderOperator.java       | 73 ++++++++++++----------
 .../ContinuousFileReaderOperatorFactory.java       | 19 +++---
 .../source/TimestampedFileInputSplit.java          | 36 ++++-------
 .../functions/source/TimestampedInputSplit.java    | 62 ++++++++++++++++++
 14 files changed, 222 insertions(+), 74 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedInputSplit.java