[flink] branch master updated (d21f5d9 -> fc89abb)

[lz...@apache.org]

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

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


    from d21f5d9  [FLINK-19275][connector-kafka] Support reading and writing Kafka metadata
     add fc89abb  [FLINK-19720][table-api] Introduce new Providers and parallelism API

No new revisions were added by this update.

Summary of changes:
 .../connector/sink/DataStreamSinkProvider.java}    | 21 ++++++-------
 ...onProvider.java => DataStreamScanProvider.java} | 32 +++++++-------------
 .../ParallelismProvider.java}                      | 35 +++++++++-------------
 .../table/connector/sink/DynamicTableSink.java     |  3 ++
 ...nputFormatProvider.java => SourceProvider.java} | 21 ++++++-------
 .../apache/flink/table/factories/FactoryUtil.java  |  8 +++++
 6 files changed, 55 insertions(+), 65 deletions(-)
 copy flink-table/{flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java => flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/DataStreamSinkProvider.java} (58%)
 copy flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/{SourceFunctionProvider.java => DataStreamScanProvider.java} (58%)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/{module/Module.java => connector/ParallelismProvider.java} (52%)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/{InputFormatProvider.java => SourceProvider.java} (65%)