Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/3829#discussion_r139466642
  
    --- Diff: docs/dev/table/common.md ---
    @@ -236,6 +236,52 @@ tableEnv.registerTableSource("CsvTable", csvSource)
     
     {% top %}
     
    +### Register a TableSink
    +
    +A `TableSink` [emits a 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, Parquet, or ORC).
    +
    +Flink aims to provide TableSources for common data formats and storage 
systems. Please see the documentation about [Table Sources and Sinks]({{ 
site.baseurl }}/dev/table/sourceSinks.html) page for details about available 
sinks and instructions for how to implement a custom `TableSink`.
    +
    +A `TableSink` is registered in a `TableEnvironment` as follows:
    --- End diff --
    
    We should add a short paragraph why Table, TableSource, and TableSink need 
to be registered to the `Register a Table in the Catalog` section. The 
subsection should have links to the sections that show how registered tables 
are used (SQL: `FROM`, `INSERT INTO`, Table API: `scan()`, `insertInto()`).


---

Reply via email to