[flink] branch master updated (ecbb71a -> 5982cb9)

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from ecbb71a  [hotfix] Fix checkstyile violations in BashJavaUtilsTest
     add 285b7e7  [hotfix][core] Fix typo in SerializationSchema
     add 0bbccdd  [FLINK-18380][examples-table] Add a ChangelogSocketExample
     add d9283c0  [hotfix][table-common] Fix typo in EncodingFormatFactory
     add 2c5e7d0  [FLINK-18066][docs] Rename old Table source/sink doc to legacySourceSinks.md
     add 9e552f7  [FLINK-18066] Add new Table source/sink documentation
     add 5982cb9  [hotfix][table-common] Fix typos in docs of new source/sink interfaces

No new revisions were added by this update.

Summary of changes:
 .../table/{sourceSinks.md => legacySourceSinks.md} |    6 +-
 docs/dev/table/sourceSinks.md                      | 1162 +++++++++-----------
 docs/fig/table_connectors.svg                      |  666 +++++++++++
 .../common/serialization/SerializationSchema.java  |    2 +-
 flink-examples/flink-examples-table/pom.xml        |   40 +-
 .../java/{ => basics}/StreamSQLExample.java        |    2 +-
 .../java/{ => basics}/StreamWindowSQLExample.java  |    2 +-
 .../examples/java/{ => basics}/WordCountSQL.java   |    2 +-
 .../examples/java/{ => basics}/WordCountTable.java |    2 +-
 .../java/connectors/ChangelogCsvDeserializer.java  |   98 ++
 .../java/connectors/ChangelogCsvFormat.java        |   71 ++
 .../java/connectors/ChangelogCsvFormatFactory.java |   76 ++
 .../java/connectors/ChangelogSocketExample.java    |   96 ++
 .../java/connectors/SocketDynamicTableFactory.java |  104 ++
 .../java/connectors/SocketDynamicTableSource.java  |   90 ++
 .../java/connectors/SocketSourceFunction.java      |  107 ++
 .../org.apache.flink.table.factories.Factory       |   17 +
 .../table/connector/sink/DynamicTableSink.java     |    2 +-
 .../table/connector/source/LookupTableSource.java  |    4 +-
 .../table/factories/EncodingFormatFactory.java     |    2 +-
 20 files changed, 1911 insertions(+), 640 deletions(-)
 copy docs/dev/table/{sourceSinks.md => legacySourceSinks.md} (99%)
 create mode 100644 docs/fig/table_connectors.svg
 rename flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/{ => basics}/StreamSQLExample.java (98%)
 rename flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/{ => basics}/StreamWindowSQLExample.java (98%)
 rename flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/{ => basics}/WordCountSQL.java (98%)
 rename flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/{ => basics}/WordCountTable.java (98%)
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvDeserializer.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormat.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogCsvFormatFactory.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/ChangelogSocketExample.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/SocketDynamicTableFactory.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/SocketDynamicTableSource.java
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/connectors/SocketSourceFunction.java
 create mode 100644 flink-examples/flink-examples-table/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory