git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Orc Sink Table


Hi Timo, David

Thx for your quick answer

BR
Jose

On Thu, 13 Sep 2018 at 12:41, Timo Walther <twalthr@xxxxxxxxxx> wrote:
Hi Jose,

you have to add additional Maven modules depending on the connector/format you want to use. See this page [1] for more information.

Feel free to ask further questions if the description is not enough for you.

Regards,
Timo

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#further-tablesources-and-tablesinks


Am 13.09.18 um 11:50 schrieb jose farfan:
Hi

I am checking the documentation


Register a TableSink

A registered TableSink can be used to emit the result of a Table API or SQL query 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 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