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 7280f98 [FLINK-17067][table] CatalogManager#createTable and
createTemporaryTable should provide consistent semantics
add 8127339 [FLINK-16951][parquet] Integrate parquet to file system
connector
No new revisions were added by this update.
Summary of changes:
flink-formats/flink-parquet/pom.xml | 15 ++
.../parquet/ParquetFileSystemFormatFactory.java | 248 +++++++++++++++++++++
.../org.apache.flink.table.factories.TableFactory | 2 +-
.../formats/parquet/ParquetFileSystemITCase.java | 35 ++-
.../planner/runtime/batch/sql/CalcITCase.scala | 2 +-
.../table/filesystem/RowPartitionComputer.java | 50 ++++-
6 files changed, 339 insertions(+), 13 deletions(-)
create mode 100644
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileSystemFormatFactory.java
copy {flink-connectors/flink-hbase =>
flink-formats/flink-parquet}/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
(92%)
copy
flink-core/src/test/java/org/apache/flink/core/memory/HybridOffHeapDirectMemorySegmentTest.java
=>
flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetFileSystemITCase.java
(52%)
