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 6c82d0b [FLINK-24690][runtime] Changed the calculation of reaching
buffer debloat threshold into more expected way
add c8e6a6f [FLINK-24685][table] Let planner offer RowData to string
casting for printing
No new revisions were added by this update.
Summary of changes:
.../functions/AdvancedFunctionsExampleITCase.java | 18 +-
.../examples/utils/ExampleOutputTestBase.java | 4 +-
.../table/client/cli/CliChangelogResultView.java | 26 +-
.../apache/flink/table/client/cli/CliClient.java | 19 +-
.../flink/table/client/cli/CliResultView.java | 8 +-
.../flink/table/client/cli/CliTableResultView.java | 23 +-
.../table/client/cli/CliTableauResultView.java | 58 +-
.../table/client/gateway/ResultDescriptor.java | 13 +-
.../table/client/gateway/local/LocalExecutor.java | 6 +-
.../flink/table/client/cli/CliResultViewTest.java | 8 +-
.../table/client/cli/CliTableauResultViewTest.java | 76 ++-
.../table/client/cli/utils/TestTableResult.java | 7 +
.../client/gateway/local/LocalExecutorITCase.java | 48 +-
.../src/test/resources/sql/catalog_database.q | 6 +-
.../src/test/resources/sql/module.q | 16 +-
.../src/test/resources/sql/table.q | 128 ++--
.../flink-sql-client/src/test/resources/sql/view.q | 130 ++--
.../table/api/internal/InsertResultProvider.java | 6 +
.../flink/table/api/internal/ResultProvider.java | 3 +
.../table/api/internal/StaticResultProvider.java | 28 +
.../table/api/internal/TableEnvironmentImpl.java | 33 +-
.../flink/table/api/internal/TableResultImpl.java | 138 +---
.../table/api/internal/TableResultInternal.java | 3 +
.../table/operations/CollectModifyOperation.java | 15 +
.../org/apache/flink/table/utils/PrintUtils.java | 695 ---------------------
.../flink/table/utils/TimestampStringUtils.java | 181 ------
.../apache/flink/table/utils/print/PrintStyle.java | 112 ++++
.../flink/table/utils/print/RawContentStyle.java | 23 +-
.../print/RowDataToStringConverter.java} | 11 +-
.../flink/table/utils/print/TableauStyle.java | 385 ++++++++++++
.../TableauStyleTest.java} | 270 ++------
.../planner/connectors/CollectDynamicSink.java | 29 +-
.../table/planner/connectors/DynamicSinkUtils.java | 16 +-
.../casting/RowDataToStringConverterImpl.java | 97 +++
34 files changed, 1115 insertions(+), 1524 deletions(-)
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java
delete mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TimestampStringUtils.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/print/PrintStyle.java
copy
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/StaticIndexGenerator.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/print/RawContentStyle.java
(58%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{functions/python/PythonFunctionKind.java
=> utils/print/RowDataToStringConverter.java} (76%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/print/TableauStyle.java
rename
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/{PrintUtilsTest.java
=> print/TableauStyleTest.java} (57%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RowDataToStringConverterImpl.java
