This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8c6cc45 [FLINK-12905][table-planner-blink] Support CatalogView in blink planner add 297530c [FLINK-14135][table-runtime-blink] Introduce DecimalColumnVector add 5066f79 [FLINK-14135][table-planner-blink] Fix source explain in PlanUtil.explainStreamGraph add 3c1ecbf [FLINK-14135][orc] Introduce OrcSplitReader to refactor orc input format add ab68932 [FLINK-14135][orc] Introduce OrcColumnarRowSplitReader to orc add 1f9cd8a [FLINK-14135][hive] Introduce HiveVectorizedOrcSplitReader to hive No new revisions were added by this update. Summary of changes: flink-connectors/flink-connector-hive/pom.xml | 21 + .../{HiveTableInputSplit.java => HiveOptions.java} | 31 +- .../flink/connectors/hive/HiveTableFactory.java | 12 +- .../connectors/hive/HiveTableInputFormat.java | 277 --------- .../flink/connectors/hive/HiveTablePartition.java | 7 +- .../flink/connectors/hive/HiveTableSink.java | 2 +- .../flink/connectors/hive/HiveTableSource.java | 48 +- .../hive/read/HiveMapredSplitReader.java | 198 ++++++ .../connectors/hive/read/HiveTableInputFormat.java | 258 ++++++++ .../hive/{ => read}/HiveTableInputSplit.java | 3 +- .../hive/read/HiveVectorizedOrcSplitReader.java | 91 +++ .../flink/connectors/hive/read/SplitReader.java | 49 ++ .../connectors/hive/FlinkStandaloneHiveRunner.java | 2 +- .../flink/connectors/hive/HiveTableSourceTest.java | 13 +- .../connectors/hive/TableEnvHiveConnectorTest.java | 4 +- flink-formats/flink-orc/pom.xml | 7 + .../flink/orc/OrcColumnarRowSplitReader.java | 87 +++ .../java/org/apache/flink/orc/OrcInputFormat.java | 214 +++++++ .../org/apache/flink/orc/OrcRowInputFormat.java | 691 +-------------------- .../org/apache/flink/orc/OrcRowSplitReader.java | 69 ++ ...{OrcRowInputFormat.java => OrcSplitReader.java} | 417 ++++--------- .../org/apache/flink/orc/OrcSplitReaderUtil.java | 181 ++++++ .../java/org/apache/flink/orc/OrcTableSource.java | 44 +- .../flink/orc/vector/AbstractOrcColumnVector.java | 198 ++++++ .../flink/orc/vector/OrcBytesColumnVector.java | 44 ++ .../flink/orc/vector/OrcDecimalColumnVector.java | 46 ++ .../flink/orc/vector/OrcDoubleColumnVector.java | 46 ++ .../flink/orc/vector/OrcLongColumnVector.java | 65 ++ .../flink/orc/vector/OrcTimestampColumnVector.java | 46 ++ .../flink/orc/OrcColumnarRowSplitReaderTest.java | 429 +++++++++++++ .../apache/flink/orc/OrcRowInputFormatTest.java | 141 +++-- .../apache/flink/orc/OrcSplitReaderUtilTest.java | 66 ++ .../org/apache/flink/orc/OrcTableSourceTest.java | 6 +- .../flink/table/planner/utils/PlanUtil.scala | 2 +- .../apache/flink/table/api/batch/ExplainTest.xml | 44 +- .../apache/flink/table/api/stream/ExplainTest.xml | 52 +- .../plan/stream/sql/MiniBatchIntervalInferTest.xml | 4 +- .../dataformat/vector/DecimalColumnVector.java | 28 + .../dataformat/vector/VectorizedColumnBatch.java | 13 +- .../vector/VectorizedColumnBatchTest.java | 51 +- 40 files changed, 2521 insertions(+), 1486 deletions(-) copy flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{HiveTableInputSplit.java => HiveOptions.java} (50%) delete mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableInputFormat.java create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveMapredSplitReader.java create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java rename flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/{ => read}/HiveTableInputSplit.java (93%) create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveVectorizedOrcSplitReader.java create mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/SplitReader.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcColumnarRowSplitReader.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcInputFormat.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcRowSplitReader.java copy flink-formats/flink-orc/src/main/java/org/apache/flink/orc/{OrcRowInputFormat.java => OrcSplitReader.java} (61%) create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReaderUtil.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcBytesColumnVector.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcDecimalColumnVector.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcDoubleColumnVector.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcLongColumnVector.java create mode 100644 flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcTimestampColumnVector.java create mode 100644 flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcColumnarRowSplitReaderTest.java create mode 100644 flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcSplitReaderUtilTest.java create mode 100644 flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/DecimalColumnVector.java