This is an automated email from the ASF dual-hosted git repository.
ron pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ce0b61f376b [FLINK-35351][checkpoint] Clean up and unify code for the
custom partitioner test case
add bc14d551e04 [FLINK-35195][test/test-filesystem] test-filesystem
support partition.fields option
add 2c35e48addf [FLINK-35348][table] Introduce refresh materialized table
rest api
No new revisions were added by this update.
Summary of changes:
.../file/table/FileSystemTableFactory.java | 2 +-
.../flink/table/gateway/api/SqlGatewayService.java | 28 ++
.../gateway/api/utils/MockedSqlGatewayService.java | 14 +
.../table/gateway/rest/SqlGatewayRestEndpoint.java | 15 +
.../RefreshMaterializedTableHandler.java | 95 ++++
.../RefreshMaterializedTableHeaders.java | 96 ++++
.../MaterializedTableIdentifierPathParameter.java | 46 ++
.../RefreshMaterializedTableParameters.java | 56 +++
.../RefreshMaterializedTableRequestBody.java | 99 ++++
.../RefreshMaterializedTableResponseBody.java | 43 ++
.../gateway/service/SqlGatewayServiceImpl.java | 31 ++
.../MaterializedTableManager.java | 127 ++++-
.../service/operation/OperationExecutor.java | 24 +
.../AbstractMaterializedTableStatementITCase.java | 339 +++++++++++++
...GatewayRestEndpointMaterializedTableITCase.java | 187 +++++++
.../service/MaterializedTableStatementITCase.java | 535 +++++++++++----------
.../MaterializedTableManagerTest.java | 77 ++-
.../resources/sql_gateway_rest_api_v3.snapshot | 57 +++
.../api/config/MaterializedTableConfigOptions.java | 2 +
.../file/testutils/TestFileSystemTableFactory.java | 16 +
.../testutils/TestFileSystemTableFactoryTest.java | 3 +
21 files changed, 1602 insertions(+), 290 deletions(-)
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/materializedtable/RefreshMaterializedTableHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/materializedtable/RefreshMaterializedTableHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/materializedtable/MaterializedTableIdentifierPathParameter.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/materializedtable/RefreshMaterializedTableParameters.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/materializedtable/RefreshMaterializedTableRequestBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/materializedtable/RefreshMaterializedTableResponseBody.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/AbstractMaterializedTableStatementITCase.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointMaterializedTableITCase.java
