Skip to content

Commit

Permalink
[FLINK-22879][table] Rename flink-table-planner-blink to flink-table-…
Browse files Browse the repository at this point in the history 
…planner

It might be required to update job dependencies. Note that flink-table-planner
used to contain the legacy planner before Flink 1.14 and now cotains the
only officially supported planner (i.e. previously known as 'Blink' planner).

This closes apache#16386.
  • Loading branch information
@twalthr
twalthr committed Jul 6, 2021
1 parent a18c0cd commit ab70dcf
Show file tree
Hide file tree
Showing 1,889 changed files with 44 additions and 44 deletions.
2 changes: 1 addition & 1 deletion docs/content.zh/docs/dev/table/overview.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ $ python -m pip install apache-flink
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink{{< scala_version >}}</artifactId>
<artifactId>flink-table-planner{{< scala_version >}}</artifactId>
<version>{{< version >}}</version>
<scope>provided</scope>
</dependency>
Expand Down
2 changes: 1 addition & 1 deletion docs/content/docs/dev/table/overview.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ following set of modules.
```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink{{< scala_version >}}</artifactId>
<artifactId>flink-table-planner{{< scala_version >}}</artifactId>
<version>{{< version >}}</version>
<scope>provided</scope>
</dependency>
Expand Down
2 changes: 1 addition & 1 deletion flink-connectors/flink-connector-cassandra/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ under the License.
<!-- A planner dependency won't be necessary once FLIP-32 has been completed. -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
<optional>true</optional>
Expand Down
2 changes: 1 addition & 1 deletion flink-connectors/flink-connector-elasticsearch6/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ under the License.
<!-- Table API integration tests -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
Expand Down
2 changes: 1 addition & 1 deletion flink-connectors/flink-connector-elasticsearch7/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ under the License.
<!-- Table API integration tests -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
Expand Down
4 changes: 2 additions & 2 deletions flink-connectors/flink-connector-hbase-1.4/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -129,14 +129,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-connectors/flink-connector-hbase-2.2/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -254,14 +254,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-connectors/flink-connector-hive/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
Expand Down Expand Up @@ -531,7 +531,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-connectors/flink-connector-jdbc/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -103,15 +103,15 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
Expand Down
4 changes: 2 additions & 2 deletions flink-connectors/flink-connector-kafka/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -173,14 +173,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
2 changes: 1 addition & 1 deletion flink-connectors/flink-connector-kinesis/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ under the License.
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
2 changes: 1 addition & 1 deletion flink-end-to-end-tests/flink-tpcds-test/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ under the License.
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
Expand Down
4 changes: 2 additions & 2 deletions flink-end-to-end-tests/test-scripts/test_table_shaded_dependencies.sh
View file
Original file line number Diff line number Diff line change
Expand Up @@ -103,7 +103,7 @@ checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-api-scala/ta
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-api-java-bridge/target/flink-table-api-java-bridge_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-api-scala-bridge/target/flink-table-api-scala-bridge_${FLINK_SCALA_VERSION}.jar"

checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-planner-blink/target/flink-table-planner-blink_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-planner/target/flink-table-planner_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-runtime/target/flink-table-runtime_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${FLINK_DIR}/lib/flink-table_${FLINK_SCALA_VERSION}.jar"

Expand All @@ -112,6 +112,6 @@ checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-scala/tar
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-java-bridge/target/flink-table-api-java-bridge_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-scala-bridge/target/flink-table-api-scala-bridge_${FLINK_SCALA_VERSION}.jar"

checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-planner-blink/target/flink-table-planner-blink_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-planner/target/flink-table-planner_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-runtime/target/flink-table-runtime_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${FLINK_DIR}/lib/flink-table_${FLINK_SCALA_VERSION}.jar"
2 changes: 1 addition & 1 deletion flink-examples/flink-examples-table/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ under the License.
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down
4 changes: 2 additions & 2 deletions flink-formats/flink-avro/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -126,14 +126,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-formats/flink-csv/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ under the License.
<!-- CSV RowData (de)serialization schema testing -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
Expand All @@ -100,7 +100,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-formats/flink-json/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -85,15 +85,15 @@ under the License.
<!-- JSON RowData schema test dependency -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<!-- Json filesystem format factory ITCase test dependency -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
<type>test-jar</type>
Expand Down
4 changes: 2 additions & 2 deletions flink-formats/flink-orc/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -125,14 +125,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
<type>test-jar</type>
Expand Down
4 changes: 2 additions & 2 deletions flink-formats/flink-parquet/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -159,14 +159,14 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
4 changes: 2 additions & 2 deletions flink-python/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ under the License.
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
Expand Down Expand Up @@ -198,7 +198,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
2 changes: 1 addition & 1 deletion flink-scala-shell/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ under the License.
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
Expand Down
4 changes: 2 additions & 2 deletions flink-table/flink-sql-client/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down Expand Up @@ -179,7 +179,7 @@ under the License.

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<type>test-jar</type>
<scope>test</scope>
Expand Down
6 changes: 3 additions & 3 deletions ...k-table/flink-table-planner-blink/pom.xml → flink-table/flink-table-planner/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ under the License.
<relativePath>..</relativePath>
</parent>

<artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
<name>Flink : Table : Planner</name>
<description>
This module connects Table/SQL API and runtime. It is responsible
Expand Down Expand Up @@ -347,7 +347,7 @@ under the License.
<filter>
<artifact>*:*</artifact>
<excludes>
<!-- Excluded all these files for a clean flink-table-planner-blink JAR -->
<!-- Excluded all these files for a clean flink-table-planner JAR -->
<exclude>org-apache-calcite-jdbc.properties</exclude>
<exclude>common.proto</exclude>
<exclude>requests.proto</exclude>
Expand Down Expand Up @@ -378,7 +378,7 @@ under the License.
<include>commons-codec:commons-codec</include>
<include>commons-io:commons-io</include>

<!-- flink-table-planner-blink dependencies -->
<!-- flink-table-planner dependencies -->
<include>org.apache.flink:flink-sql-parser</include>
<include>org.apache.flink:flink-sql-parser-hive</include>

Expand Down
0 ...he/calcite/jdbc/CalciteSchemaBuilder.java → ...he/calcite/jdbc/CalciteSchemaBuilder.java
View file
File renamed without changes.
0 .../calcite/rel/logical/LogicalSnapshot.java → .../calcite/rel/logical/LogicalSnapshot.java
View file
File renamed without changes.
0 ...calcite/rel/logical/LogicalTableScan.java → ...calcite/rel/logical/LogicalTableScan.java
View file
File renamed without changes.
0 ...va/org/apache/calcite/rex/RexLiteral.java → ...va/org/apache/calcite/rex/RexLiteral.java
View file
File renamed without changes.
0 ...a/org/apache/calcite/rex/RexSimplify.java → ...a/org/apache/calcite/rex/RexSimplify.java
View file
File renamed without changes.
0 ...calcite/sql/SqlGroupedWindowFunction.java → ...calcite/sql/SqlGroupedWindowFunction.java
View file
File renamed without changes.
0 ...apache/calcite/sql/SqlMatchRecognize.java → ...apache/calcite/sql/SqlMatchRecognize.java
View file
File renamed without changes.
0 ...a/org/apache/calcite/sql/SqlTableRef.java → ...a/org/apache/calcite/sql/SqlTableRef.java
View file
File renamed without changes.
0 ...pache/calcite/sql/fun/SqlDotOperator.java → ...pache/calcite/sql/fun/SqlDotOperator.java
View file
File renamed without changes.
0 ...ache/calcite/sql/fun/SqlItemOperator.java → ...ache/calcite/sql/fun/SqlItemOperator.java
View file
File renamed without changes.
0 .../calcite/sql/validate/AliasNamespace.java → .../calcite/sql/validate/AliasNamespace.java
View file
File renamed without changes.
0 ...cite/sql/validate/ProcedureNamespace.java → ...cite/sql/validate/ProcedureNamespace.java
View file
File renamed without changes.
0 ...alcite/sql/validate/SqlValidatorImpl.java → ...alcite/sql/validate/SqlValidatorImpl.java
View file
File renamed without changes.
0 ...e/calcite/sql2rel/AuxiliaryConverter.java → ...e/calcite/sql2rel/AuxiliaryConverter.java
View file
File renamed without changes.
0 ...ache/calcite/sql2rel/RelDecorrelator.java → ...ache/calcite/sql2rel/RelDecorrelator.java
View file
File renamed without changes.
0 ...ner/calcite/FlinkCalciteSqlValidator.java → ...ner/calcite/FlinkCalciteSqlValidator.java
View file
File renamed without changes.
0 ...able/planner/calcite/FlinkRexBuilder.java → ...able/planner/calcite/FlinkRexBuilder.java
View file
File renamed without changes.
0 .../planner/calcite/FlinkSqlNameMatcher.java → .../planner/calcite/FlinkSqlNameMatcher.java
View file
File renamed without changes.
0 ...lanner/calcite/SqlExprToRexConverter.java → ...lanner/calcite/SqlExprToRexConverter.java
View file
File renamed without changes.
0 ...calcite/SqlExprToRexConverterFactory.java → ...calcite/SqlExprToRexConverterFactory.java
View file
File renamed without changes.
0 ...er/calcite/SqlExprToRexConverterImpl.java → ...er/calcite/SqlExprToRexConverterImpl.java
View file
File renamed without changes.
0 ...planner/catalog/CatalogCalciteSchema.java → ...planner/catalog/CatalogCalciteSchema.java
View file
File renamed without changes.
0 .../catalog/CatalogManagerCalciteSchema.java → .../catalog/CatalogManagerCalciteSchema.java
View file
File renamed without changes.
0 ...e/planner/catalog/CatalogSchemaTable.java → ...e/planner/catalog/CatalogSchemaTable.java
View file
File renamed without changes.
0 ...lanner/catalog/DatabaseCalciteSchema.java → ...lanner/catalog/DatabaseCalciteSchema.java
View file
File renamed without changes.
0 ...nk/table/planner/catalog/FlinkSchema.java → ...nk/table/planner/catalog/FlinkSchema.java
View file
File renamed without changes.
0 ...catalog/FunctionCatalogOperatorTable.java → ...catalog/FunctionCatalogOperatorTable.java
View file
File renamed without changes.
0 ...talog/QueryOperationCatalogViewTable.java → ...talog/QueryOperationCatalogViewTable.java
View file
File renamed without changes.
0 .../planner/catalog/SqlCatalogViewTable.java → .../planner/catalog/SqlCatalogViewTable.java
View file
File renamed without changes.
0 ...lanner/connectors/CollectDynamicSink.java → ...lanner/connectors/CollectDynamicSink.java
View file
File renamed without changes.
0 .../planner/connectors/DynamicSinkUtils.java → .../planner/connectors/DynamicSinkUtils.java
View file
File renamed without changes.
0 ...lanner/connectors/DynamicSourceUtils.java → ...lanner/connectors/DynamicSourceUtils.java
View file
File renamed without changes.
0 ...anner/connectors/ExternalDynamicSink.java → ...anner/connectors/ExternalDynamicSink.java
View file
File renamed without changes.
0 ...ner/connectors/ExternalDynamicSource.java → ...ner/connectors/ExternalDynamicSource.java
View file
File renamed without changes.
0 ...lanner/connectors/InlineCatalogTable.java → ...lanner/connectors/InlineCatalogTable.java
View file
File renamed without changes.
0 ...onnectors/TransformationScanProvider.java → ...onnectors/TransformationScanProvider.java
View file
File renamed without changes.
0 ...onnectors/TransformationSinkProvider.java → ...onnectors/TransformationSinkProvider.java
View file
File renamed without changes.
0 ...ble/planner/delegation/BatchExecutor.java → ...ble/planner/delegation/BatchExecutor.java
View file
File renamed without changes.
0 ...nner/delegation/BlinkExecutorFactory.java → ...nner/delegation/BlinkExecutorFactory.java
View file
File renamed without changes.
0 ...anner/delegation/BlinkPlannerFactory.java → ...anner/delegation/BlinkPlannerFactory.java
View file
File renamed without changes.
0 ...nner/delegation/DefaultParserFactory.java → ...nner/delegation/DefaultParserFactory.java
View file
File renamed without changes.
0 ...able/planner/delegation/ExecutorBase.java → ...able/planner/delegation/ExecutorBase.java
View file
File renamed without changes.
0 ...r/delegation/FlinkSqlParserFactories.java → ...r/delegation/FlinkSqlParserFactories.java
View file
File renamed without changes.
0 ...ble/planner/delegation/ParserFactory.java → ...ble/planner/delegation/ParserFactory.java
View file
File renamed without changes.
0 .../table/planner/delegation/ParserImpl.java → .../table/planner/delegation/ParserImpl.java
View file
File renamed without changes.
0 ...le/planner/delegation/PlannerContext.java → ...le/planner/delegation/PlannerContext.java
View file
File renamed without changes.
0 ...le/planner/delegation/StreamExecutor.java → ...le/planner/delegation/StreamExecutor.java
View file
File renamed without changes.
0 ...ssions/AbstractPlannerWindowProperty.java → ...ssions/AbstractPlannerWindowProperty.java
View file
File renamed without changes.
0 ...r/expressions/CallExpressionResolver.java → ...r/expressions/CallExpressionResolver.java
View file
File renamed without changes.
0 ...ssions/DeclarativeExpressionResolver.java → ...ssions/DeclarativeExpressionResolver.java
View file
File renamed without changes.
0 ...lanner/expressions/ExpressionBuilder.java → ...lanner/expressions/ExpressionBuilder.java
View file
File renamed without changes.
0 ...pressions/PlannerNamedWindowProperty.java → ...pressions/PlannerNamedWindowProperty.java
View file
File renamed without changes.
0 ...expressions/PlannerProctimeAttribute.java → ...expressions/PlannerProctimeAttribute.java
View file
File renamed without changes.
0 .../expressions/PlannerRowtimeAttribute.java → .../expressions/PlannerRowtimeAttribute.java
View file
File renamed without changes.
0 .../planner/expressions/PlannerSliceEnd.java → .../planner/expressions/PlannerSliceEnd.java
View file
File renamed without changes.
0 ...essions/PlannerTypeInferenceUtilImpl.java → ...essions/PlannerTypeInferenceUtilImpl.java
View file
File renamed without changes.
0 ...planner/expressions/PlannerWindowEnd.java → ...planner/expressions/PlannerWindowEnd.java
View file
File renamed without changes.
0 ...er/expressions/PlannerWindowProperty.java → ...er/expressions/PlannerWindowProperty.java
View file
File renamed without changes.
0 ...r/expressions/PlannerWindowReference.java → ...r/expressions/PlannerWindowReference.java
View file
File renamed without changes.
0 ...anner/expressions/PlannerWindowStart.java → ...anner/expressions/PlannerWindowStart.java
View file
File renamed without changes.
0 ...lanner/expressions/RexNodeExpression.java → ...lanner/expressions/RexNodeExpression.java
View file
File renamed without changes.
0 ...er/expressions/SqlAggFunctionVisitor.java → ...er/expressions/SqlAggFunctionVisitor.java
View file
File renamed without changes.
0 .../converter/CallExpressionConvertRule.java → .../converter/CallExpressionConvertRule.java
View file
File renamed without changes.
0 ...ions/converter/CustomizedConvertRule.java → ...ions/converter/CustomizedConvertRule.java
View file
File renamed without changes.
0 ...ressions/converter/DirectConvertRule.java → ...ressions/converter/DirectConvertRule.java
View file
File renamed without changes.
0 ...ssions/converter/ExpressionConverter.java → ...ssions/converter/ExpressionConverter.java
View file
File renamed without changes.
0 ...verter/FunctionDefinitionConvertRule.java → ...verter/FunctionDefinitionConvertRule.java
View file
File renamed without changes.
0 ...rter/LegacyScalarFunctionConvertRule.java → ...rter/LegacyScalarFunctionConvertRule.java
View file
File renamed without changes.
0 ...xpressions/converter/OverConvertRule.java → ...xpressions/converter/OverConvertRule.java
View file
File renamed without changes.
0 ...unctions/InternalFunctionDefinitions.java → ...unctions/InternalFunctionDefinitions.java
View file
File renamed without changes.
0 ...unctions/aggfunctions/AvgAggFunction.java → ...unctions/aggfunctions/AvgAggFunction.java
View file
File renamed without changes.
0 ...ions/aggfunctions/CollectAggFunction.java → ...ions/aggfunctions/CollectAggFunction.java
View file
File renamed without changes.
0 ...tions/aggfunctions/Count1AggFunction.java → ...tions/aggfunctions/Count1AggFunction.java
View file
File renamed without changes.
0 ...ctions/aggfunctions/CountAggFunction.java → ...ctions/aggfunctions/CountAggFunction.java
View file
File renamed without changes.
0 ...nctions/DeclarativeAggregateFunction.java → ...nctions/DeclarativeAggregateFunction.java
View file
File renamed without changes.
0 ...ns/aggfunctions/DenseRankAggFunction.java → ...ns/aggfunctions/DenseRankAggFunction.java
View file
File renamed without changes.
0 ...s/aggfunctions/FirstValueAggFunction.java → ...s/aggfunctions/FirstValueAggFunction.java
View file
File renamed without changes.
0 ...ons/FirstValueWithRetractAggFunction.java → ...ons/FirstValueWithRetractAggFunction.java
View file
File renamed without changes.
0 ...ions/aggfunctions/IncrSumAggFunction.java → ...ions/aggfunctions/IncrSumAggFunction.java
View file
File renamed without changes.
0 ...ctions/IncrSumWithRetractAggFunction.java → ...ctions/IncrSumWithRetractAggFunction.java
View file
File renamed without changes.
0 ...unctions/aggfunctions/LagAggFunction.java → ...unctions/aggfunctions/LagAggFunction.java
View file
File renamed without changes.
0 ...ns/aggfunctions/LastValueAggFunction.java → ...ns/aggfunctions/LastValueAggFunction.java
View file
File renamed without changes.
0 ...ions/LastValueWithRetractAggFunction.java → ...ions/LastValueWithRetractAggFunction.java
View file
File renamed without changes.
0 ...ions/aggfunctions/LeadLagAggFunction.java → ...ions/aggfunctions/LeadLagAggFunction.java
View file
File renamed without changes.
0 ...nctions/aggfunctions/ListAggFunction.java → ...nctions/aggfunctions/ListAggFunction.java
View file
File renamed without changes.
0 ...ctions/ListAggWithRetractAggFunction.java → ...ctions/ListAggWithRetractAggFunction.java
View file
File renamed without changes.
0 ...ions/ListAggWsWithRetractAggFunction.java → ...ions/ListAggWsWithRetractAggFunction.java
View file
File renamed without changes.
0 ...unctions/aggfunctions/MaxAggFunction.java → ...unctions/aggfunctions/MaxAggFunction.java
View file
File renamed without changes.
0 ...gfunctions/MaxWithRetractAggFunction.java → ...gfunctions/MaxWithRetractAggFunction.java
View file
File renamed without changes.
0 ...unctions/aggfunctions/MinAggFunction.java → ...unctions/aggfunctions/MinAggFunction.java
View file
File renamed without changes.
0 ...gfunctions/MinWithRetractAggFunction.java → ...gfunctions/MinWithRetractAggFunction.java
View file
File renamed without changes.
0 ...nctions/aggfunctions/RankAggFunction.java → ...nctions/aggfunctions/RankAggFunction.java
View file
File renamed without changes.
0 ...aggfunctions/RankLikeAggFunctionBase.java → ...aggfunctions/RankLikeAggFunctionBase.java
View file
File renamed without changes.
0 ...ns/aggfunctions/RowNumberAggFunction.java → ...ns/aggfunctions/RowNumberAggFunction.java
View file
File renamed without changes.
0 .../aggfunctions/SingleValueAggFunction.java → .../aggfunctions/SingleValueAggFunction.java
View file
File renamed without changes.
0 ...nctions/aggfunctions/Sum0AggFunction.java → ...nctions/aggfunctions/Sum0AggFunction.java
View file
File renamed without changes.
0 ...unctions/aggfunctions/SumAggFunction.java → ...unctions/aggfunctions/SumAggFunction.java
View file
File renamed without changes.
0 ...gfunctions/SumWithRetractAggFunction.java → ...gfunctions/SumWithRetractAggFunction.java
View file
File renamed without changes.
0 ...ions/bridging/BridgingSqlAggFunction.java → ...ions/bridging/BridgingSqlAggFunction.java
View file
File renamed without changes.
0 ...nctions/bridging/BridgingSqlFunction.java → ...nctions/bridging/BridgingSqlFunction.java
View file
File renamed without changes.
0 ...ner/functions/bridging/BridgingUtils.java → ...ner/functions/bridging/BridgingUtils.java
View file
File renamed without changes.
0 ...ons/inference/AbstractSqlCallContext.java → ...ons/inference/AbstractSqlCallContext.java
View file
File renamed without changes.
0 ...nctions/inference/ArgumentCountRange.java → ...nctions/inference/ArgumentCountRange.java
View file
File renamed without changes.
0 ...ons/inference/CallBindingCallContext.java → ...ons/inference/CallBindingCallContext.java
View file
File renamed without changes.
0 ...unctions/inference/LookupCallContext.java → ...unctions/inference/LookupCallContext.java
View file
File renamed without changes.
0 ...inference/OperatorBindingCallContext.java → ...inference/OperatorBindingCallContext.java
View file
File renamed without changes.
0 ...nference/TypeInferenceOperandChecker.java → ...nference/TypeInferenceOperandChecker.java
View file
File renamed without changes.
0 ...erence/TypeInferenceOperandInference.java → ...erence/TypeInferenceOperandInference.java
View file
File renamed without changes.
0 ...ference/TypeInferenceReturnInference.java → ...ference/TypeInferenceReturnInference.java
View file
File renamed without changes.
0 ...ner/functions/sql/CalciteSqlFunction.java → ...ner/functions/sql/CalciteSqlFunction.java
View file
File renamed without changes.
0 .../functions/sql/FlinkSqlOperatorTable.java → .../functions/sql/FlinkSqlOperatorTable.java
View file
File renamed without changes.
0 ...ctions/sql/FlinkSqlTimestampFunction.java → ...ctions/sql/FlinkSqlTimestampFunction.java
View file
File renamed without changes.
0 ...s/sql/ProctimeMaterializeSqlFunction.java → ...s/sql/ProctimeMaterializeSqlFunction.java
View file
File renamed without changes.
0 ...er/functions/sql/SqlArrayConstructor.java → ...er/functions/sql/SqlArrayConstructor.java
View file
File renamed without changes.
0 ...nctions/sql/SqlCumulateTableFunction.java → ...nctions/sql/SqlCumulateTableFunction.java
View file
File renamed without changes.
0 .../functions/sql/SqlDescriptorOperator.java → .../functions/sql/SqlDescriptorOperator.java
View file
File renamed without changes.
0 ...ons/sql/SqlFirstLastValueAggFunction.java → ...ons/sql/SqlFirstLastValueAggFunction.java
View file
File renamed without changes.
0 ...er/functions/sql/SqlHopTableFunction.java → ...er/functions/sql/SqlHopTableFunction.java
View file
File renamed without changes.
0 ...ner/functions/sql/SqlListAggFunction.java → ...ner/functions/sql/SqlListAggFunction.java
View file
File renamed without changes.
0 ...nner/functions/sql/SqlMapConstructor.java → ...nner/functions/sql/SqlMapConstructor.java
View file
File renamed without changes.
0 ...ctions/sql/SqlThrowExceptionFunction.java → ...ctions/sql/SqlThrowExceptionFunction.java
View file
File renamed without changes.
0 ...functions/sql/SqlTumbleTableFunction.java → ...functions/sql/SqlTumbleTableFunction.java
View file
File renamed without changes.
0 ...functions/sql/SqlWindowTableFunction.java → ...functions/sql/SqlWindowTableFunction.java
View file
File renamed without changes.
0 ...sql/StreamRecordTimestampSqlFunction.java → ...sql/StreamRecordTimestampSqlFunction.java
View file
File renamed without changes.
0 ...nternal/SqlAuxiliaryGroupAggFunction.java → ...nternal/SqlAuxiliaryGroupAggFunction.java
View file
File renamed without changes.
0 ...nctions/tablefunctions/ReplicateRows.java → ...nctions/tablefunctions/ReplicateRows.java
View file
File renamed without changes.
0 ...r/functions/utils/HiveAggSqlFunction.java → ...r/functions/utils/HiveAggSqlFunction.java
View file
File renamed without changes.
0 ...er/functions/utils/HiveFunctionUtils.java → ...er/functions/utils/HiveFunctionUtils.java
View file
File renamed without changes.
0 ...functions/utils/HiveTableSqlFunction.java → ...functions/utils/HiveTableSqlFunction.java
View file
File renamed without changes.
0 ...er/functions/utils/SqlValidatorUtils.java → ...er/functions/utils/SqlValidatorUtils.java
View file
File renamed without changes.
0 ...ble/planner/hint/FlinkHintStrategies.java → ...ble/planner/hint/FlinkHintStrategies.java
View file
File renamed without changes.
0 .../flink/table/planner/hint/FlinkHints.java → .../flink/table/planner/hint/FlinkHints.java
View file
File renamed without changes.
0 .../operations/DataStreamQueryOperation.java → .../operations/DataStreamQueryOperation.java
View file
File renamed without changes.
0 ...lanner/operations/MergeTableLikeUtil.java → ...lanner/operations/MergeTableLikeUtil.java
View file
File renamed without changes.
0 ...ner/operations/PlannerQueryOperation.java → ...ner/operations/PlannerQueryOperation.java
View file
File renamed without changes.
0 ...ations/RichTableSourceQueryOperation.java → ...ations/RichTableSourceQueryOperation.java
View file
File renamed without changes.
0 ...r/operations/SqlCreateTableConverter.java → ...r/operations/SqlCreateTableConverter.java
View file
File renamed without changes.
0 ...r/operations/SqlToOperationConverter.java → ...r/operations/SqlToOperationConverter.java
View file
File renamed without changes.
0 ...ner/parse/AbstractRegexParseStrategy.java → ...ner/parse/AbstractRegexParseStrategy.java
View file
File renamed without changes.
0 ...nk/table/planner/parse/CalciteParser.java → ...nk/table/planner/parse/CalciteParser.java
View file
File renamed without changes.
0 ...er/parse/ClearOperationParseStrategy.java → ...er/parse/ClearOperationParseStrategy.java
View file
File renamed without changes.
0 .../planner/parse/ExtendedParseStrategy.java → .../planner/parse/ExtendedParseStrategy.java
View file
File renamed without changes.
0 ...k/table/planner/parse/ExtendedParser.java → ...k/table/planner/parse/ExtendedParser.java
View file
File renamed without changes.
0 ...ner/parse/HelpOperationParseStrategy.java → ...ner/parse/HelpOperationParseStrategy.java
View file
File renamed without changes.
0 ...ner/parse/QuitOperationParseStrategy.java → ...ner/parse/QuitOperationParseStrategy.java
View file
File renamed without changes.
0 ...er/parse/ResetOperationParseStrategy.java → ...er/parse/ResetOperationParseStrategy.java
View file
File renamed without changes.
0 ...nner/parse/SetOperationParseStrategy.java → ...nner/parse/SetOperationParseStrategy.java
View file
File renamed without changes.
0 ...anner/plan/FlinkCalciteCatalogReader.java → ...anner/plan/FlinkCalciteCatalogReader.java
View file
File renamed without changes.
0 .../table/planner/plan/PartialFinalType.java → .../table/planner/plan/PartialFinalType.java
View file
File renamed without changes.
0 ...planner/plan/QueryOperationConverter.java → ...planner/plan/QueryOperationConverter.java
View file
File renamed without changes.
0 ...er/plan/abilities/sink/OverwriteSpec.java → ...er/plan/abilities/sink/OverwriteSpec.java
View file
File renamed without changes.
0 ...plan/abilities/sink/PartitioningSpec.java → ...plan/abilities/sink/PartitioningSpec.java
View file
File renamed without changes.
0 .../plan/abilities/sink/SinkAbilitySpec.java → .../plan/abilities/sink/SinkAbilitySpec.java
View file
File renamed without changes.
0 ...n/abilities/sink/WritingMetadataSpec.java → ...n/abilities/sink/WritingMetadataSpec.java
View file
File renamed without changes.
0 .../abilities/source/FilterPushDownSpec.java → .../abilities/source/FilterPushDownSpec.java
View file
File renamed without changes.
0 ...n/abilities/source/LimitPushDownSpec.java → ...n/abilities/source/LimitPushDownSpec.java
View file
File renamed without changes.
0 ...ilities/source/PartitionPushDownSpec.java → ...ilities/source/PartitionPushDownSpec.java
View file
File renamed without changes.
0 ...abilities/source/ProjectPushDownSpec.java → ...abilities/source/ProjectPushDownSpec.java
View file
File renamed without changes.
0 ...abilities/source/ReadingMetadataSpec.java → ...abilities/source/ReadingMetadataSpec.java
View file
File renamed without changes.
0 ...bilities/source/SourceAbilityContext.java → ...bilities/source/SourceAbilityContext.java
View file
File renamed without changes.
0 ...n/abilities/source/SourceAbilitySpec.java → ...n/abilities/source/SourceAbilitySpec.java
View file
File renamed without changes.
0 ...ilities/source/SourceAbilitySpecBase.java → ...ilities/source/SourceAbilitySpecBase.java
View file
File renamed without changes.
0 ...abilities/source/SourceWatermarkSpec.java → ...abilities/source/SourceWatermarkSpec.java
View file
File renamed without changes.
0 ...ilities/source/WatermarkPushDownSpec.java → ...ilities/source/WatermarkPushDownSpec.java
View file
File renamed without changes.
0 ...er/plan/logical/CumulativeWindowSpec.java → ...er/plan/logical/CumulativeWindowSpec.java
View file
File renamed without changes.
0 ...anner/plan/logical/HoppingWindowSpec.java → ...anner/plan/logical/HoppingWindowSpec.java
View file
File renamed without changes.
0 ...gical/SliceAttachedWindowingStrategy.java → ...gical/SliceAttachedWindowingStrategy.java
View file
File renamed without changes.
0 ...gical/TimeAttributeWindowingStrategy.java → ...gical/TimeAttributeWindowingStrategy.java
View file
File renamed without changes.
0 ...nner/plan/logical/TumblingWindowSpec.java → ...nner/plan/logical/TumblingWindowSpec.java
View file
File renamed without changes.
0 ...ical/WindowAttachedWindowingStrategy.java → ...ical/WindowAttachedWindowingStrategy.java
View file
File renamed without changes.
0 ...able/planner/plan/logical/WindowSpec.java → ...able/planner/plan/logical/WindowSpec.java
View file
File renamed without changes.
0 ...anner/plan/logical/WindowingStrategy.java → ...anner/plan/logical/WindowingStrategy.java
View file
File renamed without changes.
0 .../planner/plan/metadata/FlinkMetadata.java → .../planner/plan/metadata/FlinkMetadata.java
View file
File renamed without changes.
0 ...er/plan/metadata/FlinkRelMdCollation.java → ...er/plan/metadata/FlinkRelMdCollation.java
View file
File renamed without changes.
0 .../plan/metadata/FlinkRelMetadataQuery.java → .../plan/metadata/FlinkRelMetadataQuery.java
View file
File renamed without changes.
0 ...ble/planner/plan/nodes/exec/ExecEdge.java → ...ble/planner/plan/nodes/exec/ExecEdge.java
View file
File renamed without changes.
0 ...ble/planner/plan/nodes/exec/ExecNode.java → ...ble/planner/plan/nodes/exec/ExecNode.java
View file
File renamed without changes.
0 ...planner/plan/nodes/exec/ExecNodeBase.java → ...planner/plan/nodes/exec/ExecNodeBase.java
View file
File renamed without changes.
0 ...lanner/plan/nodes/exec/ExecNodeGraph.java → ...lanner/plan/nodes/exec/ExecNodeGraph.java
View file
File renamed without changes.
0 ...an/nodes/exec/ExecNodeGraphGenerator.java → ...an/nodes/exec/ExecNodeGraphGenerator.java
View file
File renamed without changes.
0 ...r/plan/nodes/exec/ExecNodeTranslator.java → ...r/plan/nodes/exec/ExecNodeTranslator.java
View file
File renamed without changes.
0 ...lanner/plan/nodes/exec/InputProperty.java → ...lanner/plan/nodes/exec/InputProperty.java
View file
File renamed without changes.
0 ...xec/MultipleTransformationTranslator.java → ...xec/MultipleTransformationTranslator.java
View file
File renamed without changes.
0 .../exec/SingleTransformationTranslator.java → .../exec/SingleTransformationTranslator.java
View file
File renamed without changes.
0 ...xec/batch/BatchExecBoundedStreamScan.java → ...xec/batch/BatchExecBoundedStreamScan.java
View file
File renamed without changes.
0 .../plan/nodes/exec/batch/BatchExecCalc.java → .../plan/nodes/exec/batch/BatchExecCalc.java
View file
File renamed without changes.
0 .../nodes/exec/batch/BatchExecCorrelate.java → .../nodes/exec/batch/BatchExecCorrelate.java
View file
File renamed without changes.
0 ...n/nodes/exec/batch/BatchExecExchange.java → ...n/nodes/exec/batch/BatchExecExchange.java
View file
File renamed without changes.
0 ...lan/nodes/exec/batch/BatchExecExpand.java → ...lan/nodes/exec/batch/BatchExecExpand.java
View file
File renamed without changes.
0 ...es/exec/batch/BatchExecHashAggregate.java → ...es/exec/batch/BatchExecHashAggregate.java
View file
File renamed without changes.
0 ...n/nodes/exec/batch/BatchExecHashJoin.java → ...n/nodes/exec/batch/BatchExecHashJoin.java
View file
File renamed without changes.
0 ...c/batch/BatchExecHashWindowAggregate.java → ...c/batch/BatchExecHashWindowAggregate.java
View file
File renamed without changes.
0 ...nodes/exec/batch/BatchExecLegacySink.java → ...nodes/exec/batch/BatchExecLegacySink.java
View file
File renamed without changes.
0 ...batch/BatchExecLegacyTableSourceScan.java → ...batch/BatchExecLegacyTableSourceScan.java
View file
File renamed without changes.
0 ...plan/nodes/exec/batch/BatchExecLimit.java → ...plan/nodes/exec/batch/BatchExecLimit.java
View file
File renamed without changes.
0 ...nodes/exec/batch/BatchExecLookupJoin.java → ...nodes/exec/batch/BatchExecLookupJoin.java
View file
File renamed without changes.
0 ...es/exec/batch/BatchExecMultipleInput.java → ...es/exec/batch/BatchExecMultipleInput.java
View file
File renamed without changes.
0 ...s/exec/batch/BatchExecNestedLoopJoin.java → ...s/exec/batch/BatchExecNestedLoopJoin.java
View file
File renamed without changes.
0 .../plan/nodes/exec/batch/BatchExecNode.java → .../plan/nodes/exec/batch/BatchExecNode.java
View file
File renamed without changes.
0 ...es/exec/batch/BatchExecOverAggregate.java → ...es/exec/batch/BatchExecOverAggregate.java
View file
File renamed without changes.
0 ...xec/batch/BatchExecOverAggregateBase.java → ...xec/batch/BatchExecOverAggregateBase.java
View file
File renamed without changes.
0 ...nodes/exec/batch/BatchExecPythonCalc.java → ...nodes/exec/batch/BatchExecPythonCalc.java
View file
File renamed without changes.
0 .../exec/batch/BatchExecPythonCorrelate.java → .../exec/batch/BatchExecPythonCorrelate.java
View file
File renamed without changes.
0 .../batch/BatchExecPythonGroupAggregate.java → .../batch/BatchExecPythonGroupAggregate.java
View file
File renamed without changes.
0 .../BatchExecPythonGroupWindowAggregate.java → .../BatchExecPythonGroupWindowAggregate.java
View file
File renamed without changes.
0 ...c/batch/BatchExecPythonOverAggregate.java → ...c/batch/BatchExecPythonOverAggregate.java
View file
File renamed without changes.
0 .../plan/nodes/exec/batch/BatchExecRank.java → .../plan/nodes/exec/batch/BatchExecRank.java
View file
File renamed without changes.
0 .../plan/nodes/exec/batch/BatchExecSink.java → .../plan/nodes/exec/batch/BatchExecSink.java
View file
File renamed without changes.
0 .../plan/nodes/exec/batch/BatchExecSort.java → .../plan/nodes/exec/batch/BatchExecSort.java
View file
File renamed without changes.
0 ...es/exec/batch/BatchExecSortAggregate.java → ...es/exec/batch/BatchExecSortAggregate.java
View file
File renamed without changes.
0 .../nodes/exec/batch/BatchExecSortLimit.java → .../nodes/exec/batch/BatchExecSortLimit.java
View file
File renamed without changes.
0 ...es/exec/batch/BatchExecSortMergeJoin.java → ...es/exec/batch/BatchExecSortMergeJoin.java
View file
File renamed without changes.
0 ...c/batch/BatchExecSortWindowAggregate.java → ...c/batch/BatchExecSortWindowAggregate.java
View file
File renamed without changes.
0 .../exec/batch/BatchExecTableSourceScan.java → .../exec/batch/BatchExecTableSourceScan.java
View file
File renamed without changes.
0 ...plan/nodes/exec/batch/BatchExecUnion.java → ...plan/nodes/exec/batch/BatchExecUnion.java
View file
File renamed without changes.
0 ...lan/nodes/exec/batch/BatchExecValues.java → ...lan/nodes/exec/batch/BatchExecValues.java
View file
File renamed without changes.
0 ...lan/nodes/exec/common/CommonExecCalc.java → ...lan/nodes/exec/common/CommonExecCalc.java
View file
File renamed without changes.
0 ...odes/exec/common/CommonExecCorrelate.java → ...odes/exec/common/CommonExecCorrelate.java
View file
File renamed without changes.
0 ...nodes/exec/common/CommonExecExchange.java → ...nodes/exec/common/CommonExecExchange.java
View file
File renamed without changes.
0 ...n/nodes/exec/common/CommonExecExpand.java → ...n/nodes/exec/common/CommonExecExpand.java
View file
File renamed without changes.
0 ...des/exec/common/CommonExecLegacySink.java → ...des/exec/common/CommonExecLegacySink.java
View file
File renamed without changes.
0 ...mmon/CommonExecLegacyTableSourceScan.java → ...mmon/CommonExecLegacyTableSourceScan.java
View file
File renamed without changes.
0 ...des/exec/common/CommonExecLookupJoin.java → ...des/exec/common/CommonExecLookupJoin.java
View file
File renamed without changes.
0 ...des/exec/common/CommonExecPythonCalc.java → ...des/exec/common/CommonExecPythonCalc.java
View file
File renamed without changes.
0 ...xec/common/CommonExecPythonCorrelate.java → ...xec/common/CommonExecPythonCorrelate.java
View file
File renamed without changes.
0 ...lan/nodes/exec/common/CommonExecSink.java → ...lan/nodes/exec/common/CommonExecSink.java
View file
File renamed without changes.
0 ...xec/common/CommonExecTableSourceScan.java → ...xec/common/CommonExecTableSourceScan.java
View file
File renamed without changes.
0 ...an/nodes/exec/common/CommonExecUnion.java → ...an/nodes/exec/common/CommonExecUnion.java
View file
File renamed without changes.
0 ...n/nodes/exec/common/CommonExecValues.java → ...n/nodes/exec/common/CommonExecValues.java
View file
File renamed without changes.
0 ...c/processor/DeadlockBreakupProcessor.java → ...c/processor/DeadlockBreakupProcessor.java
View file
File renamed without changes.
0 ...xec/processor/ExecNodeGraphProcessor.java → ...xec/processor/ExecNodeGraphProcessor.java
View file
File renamed without changes.
0 ...r/MultipleInputNodeCreationProcessor.java → ...r/MultipleInputNodeCreationProcessor.java
View file
File renamed without changes.
0 ...odes/exec/processor/ProcessorContext.java → ...odes/exec/processor/ProcessorContext.java
View file
File renamed without changes.
0 ...processor/utils/InputOrderCalculator.java → ...processor/utils/InputOrderCalculator.java
View file
File renamed without changes.
0 .../utils/InputPriorityConflictResolver.java → .../utils/InputPriorityConflictResolver.java
View file
File renamed without changes.
0 ...or/utils/InputPriorityGraphGenerator.java → ...or/utils/InputPriorityGraphGenerator.java
View file
File renamed without changes.
0 ...s/exec/processor/utils/TopologyGraph.java → ...s/exec/processor/utils/TopologyGraph.java
View file
File renamed without changes.
0 .../serde/AggregateCallJsonDeserializer.java → .../serde/AggregateCallJsonDeserializer.java
View file
File renamed without changes.
0 ...ec/serde/AggregateCallJsonSerializer.java → ...ec/serde/AggregateCallJsonSerializer.java
View file
File renamed without changes.
0 ...c/serde/CatalogTableJsonDeserializer.java → ...c/serde/CatalogTableJsonDeserializer.java
View file
File renamed without changes.
0 ...xec/serde/CatalogTableJsonSerializer.java → ...xec/serde/CatalogTableJsonSerializer.java
View file
File renamed without changes.
0 .../serde/ChangelogModeJsonDeserializer.java → .../serde/ChangelogModeJsonDeserializer.java
View file
File renamed without changes.
0 ...ec/serde/ChangelogModeJsonSerializer.java → ...ec/serde/ChangelogModeJsonSerializer.java
View file
File renamed without changes.
0 .../exec/serde/DurationJsonDeserializer.java → .../exec/serde/DurationJsonDeserializer.java
View file
File renamed without changes.
0 ...es/exec/serde/DurationJsonSerializer.java → ...es/exec/serde/DurationJsonSerializer.java
View file
File renamed without changes.
0 ...serde/ExecNodeGraphJsonPlanGenerator.java → ...serde/ExecNodeGraphJsonPlanGenerator.java
View file
File renamed without changes.
0 ...ec/serde/FlinkDeserializationContext.java → ...ec/serde/FlinkDeserializationContext.java
View file
File renamed without changes.
0 .../plan/nodes/exec/serde/JsonSerdeUtil.java → .../plan/nodes/exec/serde/JsonSerdeUtil.java
View file
File renamed without changes.
0 ...ec/serde/LogicalTypeJsonDeserializer.java → ...ec/serde/LogicalTypeJsonDeserializer.java
View file
File renamed without changes.
0 ...exec/serde/LogicalTypeJsonSerializer.java → ...exec/serde/LogicalTypeJsonSerializer.java
View file
File renamed without changes.
0 .../serde/LogicalWindowJsonDeserializer.java → .../serde/LogicalWindowJsonDeserializer.java
View file
File renamed without changes.
0 ...ec/serde/LogicalWindowJsonSerializer.java → ...ec/serde/LogicalWindowJsonSerializer.java
View file
File renamed without changes.
0 ...rde/ObjectIdentifierJsonDeserializer.java → ...rde/ObjectIdentifierJsonDeserializer.java
View file
File renamed without changes.
0 ...serde/ObjectIdentifierJsonSerializer.java → ...serde/ObjectIdentifierJsonSerializer.java
View file
File renamed without changes.
0 ...ec/serde/RelDataTypeJsonDeserializer.java → ...ec/serde/RelDataTypeJsonDeserializer.java
View file
File renamed without changes.
0 ...exec/serde/RelDataTypeJsonSerializer.java → ...exec/serde/RelDataTypeJsonSerializer.java
View file
File renamed without changes.
0 ...RequiredDistributionJsonDeserializer.java → ...RequiredDistributionJsonDeserializer.java
View file
File renamed without changes.
0 ...e/RequiredDistributionJsonSerializer.java → ...e/RequiredDistributionJsonSerializer.java
View file
File renamed without changes.
0 ...xec/serde/RexLiteralJsonDeserializer.java → ...xec/serde/RexLiteralJsonDeserializer.java
View file
File renamed without changes.
0 ...s/exec/serde/RexNodeJsonDeserializer.java → ...s/exec/serde/RexNodeJsonDeserializer.java
View file
File renamed without changes.
0 ...des/exec/serde/RexNodeJsonSerializer.java → ...des/exec/serde/RexNodeJsonSerializer.java
View file
File renamed without changes.
0 ...serde/RexWindowBoundJsonDeserializer.java → ...serde/RexWindowBoundJsonDeserializer.java
View file
File renamed without changes.
0 ...c/serde/RexWindowBoundJsonSerializer.java → ...c/serde/RexWindowBoundJsonSerializer.java
View file
File renamed without changes.
0 ...r/plan/nodes/exec/serde/SerdeContext.java → ...r/plan/nodes/exec/serde/SerdeContext.java
View file
File renamed without changes.
0 ...s/exec/serde/ShuffleJsonDeserializer.java → ...s/exec/serde/ShuffleJsonDeserializer.java
View file
File renamed without changes.
0 ...des/exec/serde/ShuffleJsonSerializer.java → ...des/exec/serde/ShuffleJsonSerializer.java
View file
File renamed without changes.
0 ...nodes/exec/spec/CatalogTableSpecBase.java → ...nodes/exec/spec/CatalogTableSpecBase.java
View file
File renamed without changes.
0 ...nodes/exec/spec/DynamicTableSinkSpec.java → ...nodes/exec/spec/DynamicTableSinkSpec.java
View file
File renamed without changes.
0 ...des/exec/spec/DynamicTableSourceSpec.java → ...des/exec/spec/DynamicTableSourceSpec.java
View file
File renamed without changes.
0 ...lan/nodes/exec/spec/IntervalJoinSpec.java → ...lan/nodes/exec/spec/IntervalJoinSpec.java
View file
File renamed without changes.
0 ...lanner/plan/nodes/exec/spec/JoinSpec.java → ...lanner/plan/nodes/exec/spec/JoinSpec.java
View file
File renamed without changes.
0 ...anner/plan/nodes/exec/spec/MatchSpec.java → ...anner/plan/nodes/exec/spec/MatchSpec.java
View file
File renamed without changes.
0 ...lanner/plan/nodes/exec/spec/OverSpec.java → ...lanner/plan/nodes/exec/spec/OverSpec.java
View file
File renamed without changes.
0 ...r/plan/nodes/exec/spec/PartitionSpec.java → ...r/plan/nodes/exec/spec/PartitionSpec.java
View file
File renamed without changes.
0 ...lanner/plan/nodes/exec/spec/SortSpec.java → ...lanner/plan/nodes/exec/spec/SortSpec.java
View file
File renamed without changes.
0 ...es/exec/spec/TemporalTableSourceSpec.java → ...es/exec/spec/TemporalTableSourceSpec.java
View file
File renamed without changes.
0 .../exec/stream/StreamExecAggregateBase.java → .../exec/stream/StreamExecAggregateBase.java
View file
File renamed without changes.
Loading

0 comments on commit ab70dcf

Please sign in to comment.