You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2020/09/25 14:51:34 UTC

[flink] branch master updated (7bfd8ec -> ef4d997)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 7bfd8ec  [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs
     add ef4d997  [FLINK-19098][json][csv] Make RowData CSV and JSON converters public

No new revisions were added by this update.

Summary of changes:
 .../formats/csv/CsvFileSystemFormatFactory.java    |  10 +-
 .../csv/CsvRowDataDeserializationSchema.java       | 262 +--------------
 .../formats/csv/CsvRowDataSerializationSchema.java | 267 +--------------
 ...tionSchema.java => CsvToRowDataConverters.java} | 191 +----------
 ...tionSchema.java => RowDataToCsvConverters.java} | 191 +----------
 .../json/JsonRowDataDeserializationSchema.java     | 363 +--------------------
 .../json/JsonRowDataSerializationSchema.java       | 260 +--------------
 ...ionSchema.java => JsonToRowDataConverters.java} | 135 ++------
 ...ionSchema.java => RowDataToJsonConverters.java} | 100 ++----
 9 files changed, 110 insertions(+), 1669 deletions(-)
 copy flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/{CsvRowDataDeserializationSchema.java => CsvToRowDataConverters.java} (56%)
 copy flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/{CsvRowDataSerializationSchema.java => RowDataToCsvConverters.java} (64%)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{JsonRowDataDeserializationSchema.java => JsonToRowDataConverters.java} (72%)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{JsonRowDataSerializationSchema.java => RowDataToJsonConverters.java} (74%)