Hi Jose,
Flink provides only OrcTableSource that is BatchTableSource only
as of now. You can read more here[1]. As of now there is no
support for orc sink file. The community is working extensively
though on extending the set of supported connectors for Table
API/SQL, so it might change in the future.
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#orctablesource
On 13/09/18 11:50, jose farfan wrote:
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
Locked
signature.asc (849 bytes)