flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhueske <...@git.apache.org>
Subject [GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ...
Date Mon, 18 Sep 2017 20:52:13 GMT
Github user fhueske commented on a diff in the pull request:

    --- Diff: docs/dev/table/common.md ---
    @@ -407,6 +506,14 @@ A batch `Table` can only be written to a `BatchTableSink`, while
a streaming tab
     Please see the documentation about [Table Sources & Sinks]({{ site.baseurl }}/dev/table/sourceSinks.html)
for details about available sinks and instructions for how to implement a custom `TableSink`.
    +There're two ways to emit a table:
    +1. Using `Table.writeToSink` which derives output schema from the input table.
    --- End diff --
    1. `Table.writeToSink(TableSink sink)` emit the table using the provided TableSink and
configures the sink with the schema of the table to emit.
    2. `Table.insertInto(String table)` looks up the TableSink in the catalog that was registered
with a specific schema as `table`. The emission fails if `table` was not registered or if
the schema of the registered TableSink does match the schema of the table to emit.


View raw message