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%)