You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/12/02 20:23:15 UTC
[flink] branch master updated (8827f5f -> b2f1207)
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8827f5f [Hotfix] Fix typos.
add 575aa2d [FLINK-24859][doc][formats] Make new formats name coherent
add e6ad17f [FLINK-24859][doc][formats] document text file reading
add ac8b96b [FLINK-24859][doc][formats] document parquet file reading
add b2f1207 Address review comments
No new revisions were added by this update.
Summary of changes:
.../docs/connectors/datastream/hybridsource.md | 2 +-
.../docs/connectors/datastream/formats/parquet.md | 98 ++++++++++++++++++++++
.../connectors/datastream/formats/text_files.md | 68 +++++++++++++++
.../docs/connectors/datastream/hybridsource.md | 2 +-
.../connector/base/source/hybrid/HybridSource.java | 2 +-
...extLineFormat.java => TextLineInputFormat.java} | 8 +-
.../file/src/FileSourceTextLinesITCase.java | 8 +-
.../file/src/impl/FileSourceReaderTest.java | 4 +-
.../flink/connectors/hive/HiveSourceBuilder.java | 4 +-
.../hive/read/HiveCompactReaderFactory.java | 4 +-
...BulkFormatAdapter.java => HiveInputFormat.java} | 12 +--
.../examples/windowing/TopSpeedWindowing.java | 4 +-
.../examples/windowing/WindowWordCount.java | 4 +-
.../streaming/examples/wordcount/WordCount.java | 4 +-
.../examples/windowing/TopSpeedWindowing.scala | 4 +-
.../scala/examples/windowing/WindowWordCount.scala | 4 +-
.../scala/examples/wordcount/WordCount.scala | 4 +-
.../nohive/OrcNoHiveColumnarRowInputFormat.java | 10 +--
...tFormat.java => OrcColumnarRowInputFormat.java} | 10 +--
.../org/apache/flink/orc/OrcFileFormatFactory.java | 2 +-
...est.java => OrcColumnarRowInputFormatTest.java} | 34 ++++----
flink-python/pyflink/datastream/connectors.py | 2 +-
.../table/filesystem/LimitableBulkFormatTest.java | 8 +-
23 files changed, 236 insertions(+), 66 deletions(-)
create mode 100644 docs/content/docs/connectors/datastream/formats/parquet.md
create mode 100644 docs/content/docs/connectors/datastream/formats/text_files.md
rename flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/{TextLineFormat.java => TextLineInputFormat.java} (93%)
rename flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/{HiveBulkFormatAdapter.java => HiveInputFormat.java} (97%)
rename flink-formats/flink-orc/src/main/java/org/apache/flink/orc/{OrcColumnarRowFileInputFormat.java => OrcColumnarRowInputFormat.java} (95%)
rename flink-formats/flink-orc/src/test/java/org/apache/flink/orc/{OrcColumnarRowFileInputFormatTest.java => OrcColumnarRowInputFormatTest.java} (93%)