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

Posted to dev@flink.apache.org by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2022/02/22 19:57:00 UTC

[jira] [Created] (FLINK-26311) Test CsvFormat

Alexander Fedulov created FLINK-26311:
-----------------------------------------

             Summary: Test CsvFormat
                 Key: FLINK-26311
                 URL: https://issues.apache.org/jira/browse/FLINK-26311
             Project: Flink
          Issue Type: Improvement
            Reporter: Alexander Fedulov


https://issues.apache.org/jira/browse/FLINK-24703 adds new implementation for CSV format based on StreamFormat and BulkWriter and add support for . 

The following needs to be tested:
 # Reading CSV with the DataStream API using FileSource based on POJO schema [1]
 # Reading CSV with the DataStream API using FileSource based on customized schema Jackson (i.e., non-default delimiter)[1] 
 # Writing CSV with DataStream API using FileSink [TBD]
 # Reading and writing CSV with SQL and 'filesystem' connector, including an option of skipping malformed rows [2]

 

[1] [https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/filesystem/]

[2] [https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/formats/csv/] 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)