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 3761bbf [FLINK-24980] Introduce numBytesProduced counter into
ResultPartition to record the size of result partition.
add 30644a0 [FLINK-25060][table-common] Replace projection methods of
FLINK-24399 with the new Projection util
No new revisions were added by this update.
Summary of changes:
.../table/ElasticsearchDynamicSinkFactoryBase.java | 3 +-
.../source/AbstractHBaseDynamicTableSource.java | 3 +-
.../jdbc/table/JdbcDynamicTableSource.java | 3 +-
.../connectors/kafka/table/KafkaDynamicSink.java | 4 +-
.../connectors/kafka/table/KafkaDynamicSource.java | 4 +-
.../confluent/RegistryAvroFormatFactory.java | 3 +-
.../debezium/DebeziumAvroFormatFactory.java | 3 +-
.../flink/formats/avro/AvroFormatFactory.java | 3 +-
.../flink/formats/json/JsonFormatFactory.java | 3 +-
.../json/canal/CanalJsonDecodingFormat.java | 3 +-
.../json/debezium/DebeziumJsonDecodingFormat.java | 3 +-
.../json/maxwell/MaxwellJsonDecodingFormat.java | 3 +-
.../formats/parquet/ParquetFileFormatFactory.java | 4 +-
.../flink/table/catalog/SchemaTranslator.java | 4 +-
.../apache/flink/table/connector/Projection.java | 64 ++++++++++++++++++++--
.../table/connector/format/DecodingFormat.java | 4 +-
.../format/ProjectableDecodingFormat.java | 2 +-
.../flink/table/factories/DynamicTableFactory.java | 12 ++--
.../org/apache/flink/table/types/DataType.java | 51 -----------------
.../flink/table/types/utils/DataTypeUtils.java | 63 ++++-----------------
.../org/apache/flink/table/types/DataTypeTest.java | 17 ------
.../flink/table/types/utils/DataTypeUtilsTest.java | 31 -----------
.../PushProjectIntoTableSourceScanRule.java | 15 +----
.../filesystem/TestCsvFileSystemFormatFactory.java | 3 +-
24 files changed, 112 insertions(+), 196 deletions(-)
