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 c4acb6f [FLINK-14672][sql-client] Make Executor stateful in sql client
add 035a233 [FLINK-14254][table-runtime-blink] Introduce
FileSystemOutputFormat for batch
add 9576a3f [FLINK-14254][hive] Integrate hive table sink with
FileSystemOutputFormat
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HadoopFileSystemFactory.java | 48 ++
.../connectors/hive/HiveOutputFormatFactory.java | 216 +++++++++
.../connectors/hive/HiveTableMetaStoreFactory.java | 113 +++++
.../connectors/hive/HiveTableOutputFormat.java | 486 ---------------------
.../flink/connectors/hive/HiveTableSink.java | 103 ++---
.../flink/connectors/hive/JobConfWrapper.java | 62 +++
.../table/filesystem/DynamicPartitionWriter.java | 70 +++
.../table/filesystem/FileSystemCommitter.java | 120 +++++
.../flink/table/filesystem/FileSystemFactory.java | 45 ++
.../table/filesystem/FileSystemOutputFormat.java | 216 +++++++++
.../table/filesystem/GroupedPartitionWriter.java | 72 +++
.../table/filesystem/OutputFormatFactory.java | 39 ++
.../flink/table/filesystem/PartitionComputer.java | 51 +++
.../flink/table/filesystem/PartitionLoader.java | 134 ++++++
.../flink/table/filesystem/PartitionPathUtils.java | 231 ++++++++++
.../table/filesystem/PartitionTempFileManager.java | 172 ++++++++
.../flink/table/filesystem/PartitionWriter.java | 74 ++++
.../table/filesystem/PartitionWriterFactory.java | 52 +++
.../table/filesystem/RowPartitionComputer.java | 74 ++++
.../table/filesystem/SingleDirectoryWriter.java | 59 +++
.../table/filesystem/TableMetaStoreFactory.java | 72 +++
.../table/filesystem/FileSystemCommitterTest.java | 158 +++++++
.../filesystem/FileSystemOutputFormatTest.java | 233 ++++++++++
.../table/filesystem/PartitionWriterTest.java | 173 ++++++++
.../table/filesystem/RowPartitionComputerTest.java | 69 +++
25 files changed, 2593 insertions(+), 549 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HadoopFileSystemFactory.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOutputFormatFactory.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableMetaStoreFactory.java
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableOutputFormat.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/JobConfWrapper.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/DynamicPartitionWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemCommitter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemFactory.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/GroupedPartitionWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/OutputFormatFactory.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionComputer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionLoader.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionPathUtils.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionTempFileManager.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionWriterFactory.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/RowPartitionComputer.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/SingleDirectoryWriter.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/TableMetaStoreFactory.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/FileSystemCommitterTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/FileSystemOutputFormatTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/PartitionWriterTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/RowPartitionComputerTest.java
