Hi

I am checking the documentation

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/common.html#register-a-tablesink

Register a TableSink
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#register-a-tablesink>

A registered TableSink can be used to emit the result of a Table API or SQL
query
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#emit-a-table>
to
an external storage system, such as a database, key-value store, message
queue, or file system (in different encodings, e.g., CSV, Apache [Parquet,
Avro, ORC], …).

Flink aims to provide TableSinks for common data formats and storage
systems. Please see the documentation about Table Sources and Sinks
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sourceSinks.html>
page
for details about available sinks and instructions for how to implement a
custom TableSink.


You can read that we can define different encodigos CSV, ORC, etc.


But in the source code, I can only find CsvTableFlink

How I can get a OrcTableFlink? Do I need to extend the TableSinkBase, of
there is another place to find that implementation


BR

Jose

Reply via email to