This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b89fe85 [FLINK-13403][table-planner-blink] Fix some classes' package
name is not updated after class relocation
b89fe85 is described below
commit b89fe851ab90ee7c24c5a9694fa81d7cb57c84a6
Author: godfreyhe <[email protected]>
AuthorDate: Wed Jul 24 18:03:58 2019 +0800
[FLINK-13403][table-planner-blink] Fix some classes' package name is not
updated after class relocation
This closes #9216
---
.../table/planner/expressions/PlannerTypeInferenceUtilImpl.java | 6 +++---
.../flink/table/planner/codegen/calls/ScalarOperatorGens.scala | 2 +-
.../org/apache/flink/table/planner/expressions/InputTypeSpec.scala | 2 +-
.../apache/flink/table/planner/expressions/PlannerExpression.scala | 2 +-
.../org/apache/flink/table/planner/expressions/Reinterpret.scala | 4 ++--
.../flink/table/planner/expressions/ReturnTypeInference.scala | 2 +-
.../org/apache/flink/table/planner/expressions/aggregations.scala | 4 ++--
.../org/apache/flink/table/planner/expressions/arithmetic.scala | 6 +++---
.../scala/org/apache/flink/table/planner/expressions/call.scala | 2 +-
.../scala/org/apache/flink/table/planner/expressions/cast.scala | 4 ++--
.../org/apache/flink/table/planner/expressions/collection.scala | 4 ++--
.../org/apache/flink/table/planner/expressions/comparison.scala | 4 ++--
.../org/apache/flink/table/planner/expressions/composite.scala | 2 +-
.../apache/flink/table/planner/expressions/fieldExpression.scala | 2 +-
.../scala/org/apache/flink/table/planner/expressions/logic.scala | 2 +-
.../apache/flink/table/planner/expressions/mathExpressions.scala | 4 ++--
.../org/apache/flink/table/planner/expressions/ordering.scala | 2 +-
.../apache/flink/table/planner/expressions/stringExpressions.scala | 2 +-
.../org/apache/flink/table/planner/expressions/subquery.scala | 4 ++--
.../scala/org/apache/flink/table/planner/expressions/time.scala | 7 ++++---
.../apache/flink/table/planner/expressions/windowProperties.scala | 2 +-
.../main/scala/org/apache/flink/table/planner/plan/TreeNode.scala | 2 +-
.../plan/nodes/physical/batch/BatchExecTableSourceScan.scala | 3 ++-
.../plan/nodes/physical/stream/StreamExecTableSourceScan.scala | 3 ++-
.../apache/flink/table/planner/plan/schema/TableSourceTable.scala | 3 ++-
.../org/apache/flink/table/planner/sources/TableSourceUtil.scala | 3 ++-
.../org/apache/flink/table/planner/typeutils/TypeCoercion.scala | 2 +-
.../apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala | 5 +++--
.../org/apache/flink/table/planner/validate/ValidationResult.scala | 2 +-
.../flink/table/planner/calcite/CalciteConfigBuilderTest.scala | 3 +--
.../apache/flink/table/planner/calcite/FlinkTypeFactoryTest.scala | 3 +--
31 files changed, 51 insertions(+), 47 deletions(-)
diff --git
a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerTypeInferenceUtilImpl.java
b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerTypeInferenceUtilImpl.java
index 4b66c60..0b0b934 100644
---
a/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerTypeInferenceUtilImpl.java
+++
b/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/PlannerTypeInferenceUtilImpl.java
@@ -25,11 +25,11 @@ import
org.apache.flink.table.delegation.PlannerTypeInferenceUtil;
import org.apache.flink.table.expressions.Expression;
import org.apache.flink.table.expressions.ResolvedExpression;
import org.apache.flink.table.expressions.UnresolvedCallExpression;
+import org.apache.flink.table.planner.typeutils.TypeCoercion;
+import org.apache.flink.table.planner.validate.ValidationFailure;
+import org.apache.flink.table.planner.validate.ValidationResult;
import org.apache.flink.table.types.DataType;
import org.apache.flink.table.types.inference.TypeInferenceUtil;
-import org.apache.flink.table.typeutils.TypeCoercion;
-import org.apache.flink.table.validate.ValidationFailure;
-import org.apache.flink.table.validate.ValidationResult;
import java.util.List;
import java.util.Optional;
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala
index 7001450..e992a1b 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala
@@ -23,6 +23,7 @@ import
org.apache.flink.table.planner.codegen.CodeGenUtils.{binaryRowFieldSetAcc
import org.apache.flink.table.planner.codegen.GenerateUtils._
import
org.apache.flink.table.planner.codegen.GeneratedExpression.{ALWAYS_NULL,
NEVER_NULL, NO_CODE}
import org.apache.flink.table.planner.codegen.{CodeGenException,
CodeGeneratorContext, GeneratedExpression}
+import org.apache.flink.table.planner.typeutils.TypeCoercion
import
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromLogicalTypeToDataType
import org.apache.flink.table.runtime.types.PlannerTypeUtils
import org.apache.flink.table.runtime.types.PlannerTypeUtils.{isInteroperable,
isPrimitive}
@@ -30,7 +31,6 @@ import org.apache.flink.table.runtime.typeutils.TypeCheckUtils
import org.apache.flink.table.runtime.typeutils.TypeCheckUtils._
import org.apache.flink.table.types.logical.LogicalTypeRoot._
import org.apache.flink.table.types.logical._
-import org.apache.flink.table.typeutils.TypeCoercion
import org.apache.flink.util.Preconditions.checkArgument
import org.apache.calcite.avatica.util.DateTimeUtils.MILLIS_PER_DAY
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/InputTypeSpec.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/InputTypeSpec.scala
index c848a97..b524c35 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/InputTypeSpec.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/InputTypeSpec.scala
@@ -19,7 +19,7 @@
package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.validate._
import scala.collection.mutable
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpression.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpression.scala
index bdd41a1..4f3d0ef 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpression.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpression.scala
@@ -20,7 +20,7 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.table.expressions.{Expression, ExpressionVisitor}
import org.apache.flink.table.planner.plan.TreeNode
-import org.apache.flink.table.validate.{ValidationResult, ValidationSuccess}
+import org.apache.flink.table.planner.validate.{ValidationResult,
ValidationSuccess}
import java.util
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/Reinterpret.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/Reinterpret.scala
index 82cbab5..9991c66 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/Reinterpret.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/Reinterpret.scala
@@ -19,9 +19,9 @@
package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
+import org.apache.flink.table.planner.typeutils.TypeCoercion
+import org.apache.flink.table.planner.validate._
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType
-import org.apache.flink.table.typeutils.TypeCoercion
-import org.apache.flink.table.validate._
case class Reinterpret(child: PlannerExpression, resultType:
TypeInformation[_],
checkOverflow: Boolean) extends UnaryExpression {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ReturnTypeInference.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ReturnTypeInference.scala
index 9e3dbea..b2c90b0 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ReturnTypeInference.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ReturnTypeInference.scala
@@ -22,10 +22,10 @@ import org.apache.flink.table.api.TableException
import org.apache.flink.table.planner.calcite.{FlinkTypeFactory,
FlinkTypeSystem}
import org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
import org.apache.flink.table.planner.plan.`type`.FlinkReturnTypes
+import org.apache.flink.table.planner.typeutils.TypeCoercion
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.{fromLogicalTypeToTypeInfo,
fromTypeInfoToLogicalType}
import org.apache.flink.table.runtime.typeutils.{BigDecimalTypeInfo,
DecimalTypeInfo}
import org.apache.flink.table.types.logical.{DecimalType, LogicalType}
-import org.apache.flink.table.typeutils.TypeCoercion
import org.apache.calcite.rel.`type`.RelDataType
import org.apache.calcite.sql.`type`.SqlTypeUtil
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala
index 2141815..6406372 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala
@@ -22,10 +22,10 @@ import org.apache.flink.api.java.typeutils.MultisetTypeInfo
import org.apache.flink.table.functions.{AggregateFunction,
TableAggregateFunction, UserDefinedAggregateFunction}
import org.apache.flink.table.planner.calcite.FlinkTypeSystem
import
org.apache.flink.table.planner.functions.utils.UserDefinedFunctionUtils._
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.{fromLogicalTypeToTypeInfo,
fromTypeInfoToLogicalType}
import
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
abstract sealed class Aggregation extends PlannerExpression {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/arithmetic.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/arithmetic.scala
index 1d11834..a147a02 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/arithmetic.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/arithmetic.scala
@@ -19,10 +19,10 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
+import org.apache.flink.table.planner.typeutils.TypeCoercion
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils._
+import org.apache.flink.table.planner.validate._
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.{fromLogicalTypeToTypeInfo,
fromTypeInfoToLogicalType}
-import org.apache.flink.table.typeutils.TypeCoercion
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils._
-import org.apache.flink.table.validate._
import org.apache.calcite.sql.SqlOperator
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala
index 8629339..7dacccf 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/call.scala
@@ -20,13 +20,13 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation,
Types}
import org.apache.flink.table.functions._
import
org.apache.flink.table.planner.functions.utils.UserDefinedFunctionUtils._
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
import
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromLogicalTypeToDataType
import
org.apache.flink.table.runtime.types.TypeInfoDataTypeConverter.fromDataTypeToTypeInfo
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType
import org.apache.flink.table.types.logical.LogicalType
import
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType
import org.apache.flink.table.typeutils.TimeIntervalTypeInfo
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
/**
* Over call with unresolved alias for over window.
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/cast.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/cast.scala
index 0edad0d..4a1bf1e 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/cast.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/cast.scala
@@ -18,9 +18,9 @@
package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
+import org.apache.flink.table.planner.typeutils.TypeCoercion
+import org.apache.flink.table.planner.validate._
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType
-import org.apache.flink.table.typeutils.TypeCoercion
-import org.apache.flink.table.validate._
case class Cast(child: PlannerExpression, resultType: TypeInformation[_])
extends UnaryExpression {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/collection.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/collection.scala
index 5d4ea56..f67c09b 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/collection.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/collection.scala
@@ -21,8 +21,8 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo.INT_TYPE_INFO
import org.apache.flink.api.common.typeinfo.{BasicArrayTypeInfo,
BasicTypeInfo, PrimitiveArrayTypeInfo, TypeInformation}
import org.apache.flink.api.java.typeutils.{MapTypeInfo, ObjectArrayTypeInfo,
RowTypeInfo}
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils.{isArray, isMap}
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils.{isArray,
isMap}
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
case class RowConstructor(elements: Seq[PlannerExpression]) extends
PlannerExpression {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/comparison.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/comparison.scala
index 0659c77..b0684df 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/comparison.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/comparison.scala
@@ -20,8 +20,8 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo._
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation}
import org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils.{isArray,
isComparable, isNumeric}
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils.{isArray,
isComparable, isNumeric}
+import org.apache.flink.table.planner.validate._
import org.apache.calcite.sql.SqlOperator
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/composite.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/composite.scala
index 0e15cb5..8c4bcc8 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/composite.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/composite.scala
@@ -21,7 +21,7 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.api.common.typeutils.CompositeType
import org.apache.flink.table.api.UnresolvedException
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
/**
* Flattening of composite types. All flattenings are resolved into
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala
index 23dd32b..89e71db 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/fieldExpression.scala
@@ -23,9 +23,9 @@ import org.apache.flink.table.operations.QueryOperation
import
org.apache.flink.table.planner.calcite.FlinkRelBuilder.NamedWindowProperty
import org.apache.flink.table.planner.calcite.FlinkTypeFactory
import org.apache.flink.table.planner.calcite.FlinkTypeFactory._
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.fromLogicalTypeToTypeInfo
import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
import org.apache.calcite.rex.RexNode
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/logic.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/logic.scala
index c88b732..7ef2adc 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/logic.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/logic.scala
@@ -18,7 +18,7 @@
package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.validate._
abstract class BinaryPredicate extends BinaryExpression {
override private[flink] def resultType = BasicTypeInfo.BOOLEAN_TYPE_INFO
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/mathExpressions.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/mathExpressions.scala
index 3178392..cdc4d46 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/mathExpressions.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/mathExpressions.scala
@@ -19,8 +19,8 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo._
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation}
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils
+import org.apache.flink.table.planner.validate._
case class Abs(child: PlannerExpression) extends UnaryExpression {
override private[flink] def resultType: TypeInformation[_] = child.resultType
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ordering.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ordering.scala
index f2e5421..956f8fb 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ordering.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ordering.scala
@@ -18,7 +18,7 @@
package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.TypeInformation
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.validate._
abstract class Ordering extends UnaryExpression {
override private[flink] def validateInput(): ValidationResult = {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/stringExpressions.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/stringExpressions.scala
index 6d04ea1..a24e2d8 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/stringExpressions.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/stringExpressions.scala
@@ -20,7 +20,7 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo._
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation}
import
org.apache.flink.table.planner.expressions.PlannerTrimMode.PlannerTrimMode
-import org.apache.flink.table.validate._
+import org.apache.flink.table.planner.validate._
/**
* Returns the length of this `str`.
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala
index dfc48a2..19acb89 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/subquery.scala
@@ -21,8 +21,8 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.BasicTypeInfo._
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.table.operations.QueryOperation
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils._
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils._
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
case class In(expression: PlannerExpression, elements: Seq[PlannerExpression])
extends PlannerExpression {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/time.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/time.scala
index 6cebf80..2429881 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/time.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/time.scala
@@ -23,9 +23,10 @@ import
org.apache.flink.api.common.typeinfo.{SqlTimeTypeInfo, TypeInformation}
import org.apache.flink.table.planner.calcite.FlinkRelBuilder
import
org.apache.flink.table.planner.expressions.PlannerTimeIntervalUnit.PlannerTimeIntervalUnit
import org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils.isTimeInterval
-import org.apache.flink.table.typeutils.{TimeIntervalTypeInfo,
TypeInfoCheckUtils}
-import org.apache.flink.table.validate.{ValidationFailure, ValidationResult,
ValidationSuccess}
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils
+import
org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils.isTimeInterval
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationResult, ValidationSuccess}
+import org.apache.flink.table.typeutils.TimeIntervalTypeInfo
import org.apache.calcite.rex._
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/windowProperties.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/windowProperties.scala
index 7602b00..0e68163 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/windowProperties.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/windowProperties.scala
@@ -20,7 +20,7 @@ package org.apache.flink.table.planner.expressions
import org.apache.flink.api.common.typeinfo.{SqlTimeTypeInfo, TypeInformation}
import
org.apache.flink.table.planner.calcite.FlinkRelBuilder.NamedWindowProperty
-import org.apache.flink.table.validate.{ValidationFailure, ValidationSuccess}
+import org.apache.flink.table.planner.validate.{ValidationFailure,
ValidationSuccess}
trait WindowProperty {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/TreeNode.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/TreeNode.scala
index 9aefab1..103d287 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/TreeNode.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/TreeNode.scala
@@ -17,7 +17,7 @@
*/
package org.apache.flink.table.planner.plan
-import org.apache.flink.table.typeutils.TypeInfoCheckUtils
+import org.apache.flink.table.planner.typeutils.TypeInfoCheckUtils
/**
* Generic base class for trees that can be transformed and traversed.
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
index 3ca32b3..f4b188c 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala
@@ -30,7 +30,8 @@ import
org.apache.flink.table.planner.plan.nodes.exec.{BatchExecNode, ExecNode}
import
org.apache.flink.table.planner.plan.nodes.physical.PhysicalTableSourceScan
import org.apache.flink.table.planner.plan.schema.FlinkRelOptTable
import org.apache.flink.table.planner.plan.utils.ScanUtil
-import org.apache.flink.table.sources.{StreamTableSource, TableSourceUtil}
+import org.apache.flink.table.planner.sources.TableSourceUtil
+import org.apache.flink.table.sources.StreamTableSource
import
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType
import org.apache.calcite.plan._
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
index ce10237..bca83ce 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala
@@ -34,9 +34,10 @@ import
org.apache.flink.table.planner.plan.nodes.exec.{ExecNode, StreamExecNode}
import
org.apache.flink.table.planner.plan.nodes.physical.PhysicalTableSourceScan
import org.apache.flink.table.planner.plan.schema.FlinkRelOptTable
import org.apache.flink.table.planner.plan.utils.ScanUtil
+import org.apache.flink.table.planner.sources.TableSourceUtil
import org.apache.flink.table.runtime.operators.AbstractProcessStreamOperator
import org.apache.flink.table.sources.wmstrategies.{PeriodicWatermarkAssigner,
PreserveWatermarks, PunctuatedWatermarkAssigner}
-import org.apache.flink.table.sources.{RowtimeAttributeDescriptor,
StreamTableSource, TableSourceUtil}
+import org.apache.flink.table.sources.{RowtimeAttributeDescriptor,
StreamTableSource}
import
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType
import org.apache.flink.table.types.{DataType, FieldsDataType}
import org.apache.flink.types.Row
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala
index 167dbd6..ab11823 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala
@@ -20,7 +20,8 @@ package org.apache.flink.table.planner.plan.schema
import org.apache.flink.table.planner.calcite.FlinkTypeFactory
import org.apache.flink.table.planner.plan.stats.FlinkStatistic
-import org.apache.flink.table.sources.{TableSource, TableSourceUtil}
+import org.apache.flink.table.planner.sources.TableSourceUtil
+import org.apache.flink.table.sources.TableSource
import org.apache.calcite.rel.`type`.{RelDataType, RelDataTypeFactory}
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala
index d01aae3..2f15be2 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.sources
+package org.apache.flink.table.planner.sources
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.api.common.typeutils.CompositeType
@@ -28,6 +28,7 @@ import org.apache.flink.table.planner.calcite.FlinkTypeFactory
import org.apache.flink.table.planner.expressions.RexNodeConverter
import org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter
import
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter.fromTypeInfoToLogicalType
+import org.apache.flink.table.sources.{DefinedFieldMapping,
DefinedProctimeAttribute, DefinedRowtimeAttributes, RowtimeAttributeDescriptor,
TableSource}
import org.apache.flink.table.types.logical.{LogicalType, TimestampKind,
TimestampType, TinyIntType}
import
org.apache.flink.table.types.utils.TypeConversions.fromDataTypeToLegacyInfo
import org.apache.flink.table.typeutils.TimeIndicatorTypeInfo
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeCoercion.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeCoercion.scala
index bc4fb8c..e9ad96e 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeCoercion.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeCoercion.scala
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.typeutils
+package org.apache.flink.table.planner.typeutils
import org.apache.flink.table.runtime.typeutils.TypeCheckUtils._
import org.apache.flink.table.types.logical.LogicalTypeRoot._
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala
index d73d9aa..80f4a57 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/TypeInfoCheckUtils.scala
@@ -15,15 +15,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.flink.table.typeutils
+package org.apache.flink.table.planner.typeutils
import org.apache.flink.api.common.typeinfo.BasicTypeInfo._
import org.apache.flink.api.common.typeinfo._
import org.apache.flink.api.common.typeutils.CompositeType
import org.apache.flink.api.java.typeutils.{MapTypeInfo, ObjectArrayTypeInfo,
PojoTypeInfo}
import org.apache.flink.table.api.ValidationException
+import org.apache.flink.table.planner.validate._
import org.apache.flink.table.typeutils.TimeIntervalTypeInfo.{INTERVAL_MILLIS,
INTERVAL_MONTHS}
-import org.apache.flink.table.validate._
+import org.apache.flink.table.typeutils.{TimeIndicatorTypeInfo,
TimeIntervalTypeInfo}
object TypeInfoCheckUtils {
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/validate/ValidationResult.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/validate/ValidationResult.scala
index 64a568b..fef376d 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/validate/ValidationResult.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/validate/ValidationResult.scala
@@ -15,7 +15,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.flink.table.validate
+package org.apache.flink.table.planner.validate
/**
* Represents the result of a validation.
diff --git
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/CalciteConfigBuilderTest.scala
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/CalciteConfigBuilderTest.scala
index edf70cf..03b7582 100644
---
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/CalciteConfigBuilderTest.scala
+++
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/CalciteConfigBuilderTest.scala
@@ -16,10 +16,9 @@
* limitations under the License.
*/
-package org.apache.flink.table.calcite
+package org.apache.flink.table.planner.calcite
import org.apache.flink.table.api.TableConfig
-import org.apache.flink.table.planner.calcite.{CalciteConfig,
CalciteConfigBuilder}
import org.apache.flink.table.planner.plan.optimize.program.FlinkStreamProgram
import org.apache.calcite.config.Lex
diff --git
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactoryTest.scala
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactoryTest.scala
index 955cb24..9d9df62 100644
---
a/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactoryTest.scala
+++
b/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactoryTest.scala
@@ -16,9 +16,8 @@
* limitations under the License.
*/
-package org.apache.flink.table.calcite
+package org.apache.flink.table.planner.calcite
-import org.apache.flink.table.planner.calcite.{FlinkTypeFactory,
FlinkTypeSystem}
import org.apache.flink.table.types.logical.{ArrayType, BigIntType,
BooleanType, DateType, DecimalType, DoubleType, FloatType, IntType,
LocalZonedTimestampType, LogicalType, MapType, RowType, SmallIntType, TimeType,
TimestampType, TinyIntType, VarBinaryType, VarCharType}
import org.junit.{Assert, Test}
