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

Re: Orc Sink Table

Hi Timo, David

Thx for your quick answer


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.



Am 13.09.18 um 11:50 schrieb jose farfan:

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