copy_files.sh

export FLINK_PLANNER_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table
export FLINK_JAVA_PLANNER_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner/src/main/java/org/apache/flink/table
export FLINK_PLANNER_TEST_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/
export BLINK_PLANNER_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table
export BLINK_JAVA_PLANNER_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table
export BLINK_PLANNER_TEST_DIR=/Users/wuchong/Workspace/Flink/flink/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/

rm -rf $BLINK_PLANNER_DIR/*;
rm -rf $BLINK_JAVA_PLANNER_DIR/*;
rm -rf $BLINK_PLANNER_TEST_DIR/*;
cd $BLINK_PLANNER_DIR; mkdir api; cd api; mkdir java; mkdir scala;
cd $BLINK_PLANNER_DIR; mkdir calcite; mkdir expressions;
cd $BLINK_PLANNER_DIR; mkdir functions; cd functions; mkdir sql; mkdir utils;
cd $BLINK_PLANNER_DIR; mkdir plan; cd plan; mkdir cost; mkdir logical; mkdir schema;
cd $BLINK_PLANNER_DIR; mkdir sinks; mkdir sources; mkdir typeutils; mkdir validate;
cd $BLINK_JAVA_PLANNER_DIR; mkdir expressions;
cd $BLINK_PLANNER_TEST_DIR; mkdir api; cd api; mkdir validation;
cd $BLINK_PLANNER_TEST_DIR; mkdir utils;

cd $FLINK_PLANNER_DIR/api/java; cp StreamTableEnvironment.scala windows.scala $BLINK_PLANNER_DIR/api/java
cd $FLINK_PLANNER_DIR/api/scala; cp DataStreamConversions.scala expressionDsl.scala package.scala StreamTableEnvironment.scala TableConversions.scala windows.scala $BLINK_PLANNER_DIR/api/scala
cd $FLINK_PLANNER_DIR/api; cp exceptions.scala package.scala StreamTableEnvironment.scala table.scala TableConfig.scala TableEnvironment.scala Types.scala windows.scala $BLINK_PLANNER_DIR/api
cd $FLINK_PLANNER_DIR/calcite; cp FlinkCalciteSqlValidator.scala FlinkPlannerImpl.scala FlinkRelBuilder.scala FlinkRelOptClusterFactory.scala FlinkTypeFactory.scala FlinkTypeSystem.scala $BLINK_PLANNER_DIR/calcite
cd $FLINK_PLANNER_DIR/expressions; cp -r ./ $BLINK_PLANNER_DIR/expressions/
cd $FLINK_PLANNER_DIR/functions/sql; cp -r ./ $BLINK_PLANNER_DIR/functions/sql/
cd $FLINK_PLANNER_DIR/functions/utils; cp -r ./ $BLINK_PLANNER_DIR/functions/utils/
cd $FLINK_PLANNER_DIR/functions; cp DistinctAggregateFunction.scala TemporalTableFunction.scala $BLINK_PLANNER_DIR/functions/
cd $FLINK_PLANNER_DIR/plan/cost; cp FlinkDefaultRelMetadataProvider.scala $BLINK_PLANNER_DIR/plan/cost
cd $FLINK_PLANNER_DIR/plan/logical; cp groupWindows.scala LogicalNode.scala LogicalWindow.scala MatchRecognize.scala operators.scala Resolvable.scala $BLINK_PLANNER_DIR/plan/logical
cd $FLINK_PLANNER_DIR/plan/schema; cp  StreamTableSourceTable.scala TableSinkTable.scala TableSourceSinkTable.scala TableSourceTable.scala ArrayRelDataType.scala CompositeRelDataType.scala DataStreamTable.scala FlinkTableFunctionImpl.scala GenericRelDataType.scala InlineTable.scala MapRelDataType.scala MultisetRelDataType.scala RelTable.scala RowSchema.scala TimeIndicatorRelDataType.scala $BLINK_PLANNER_DIR/plan/schema
cd $FLINK_PLANNER_DIR/plan; cp ProjectionTranslator.scala TreeNode.scala $BLINK_PLANNER_DIR/plan;
cd $FLINK_PLANNER_DIR/sinks; cp AppendStreamTableSink.scala RetractStreamTableSink.scala StreamTableSink.scala UpsertStreamTableSink.scala $BLINK_PLANNER_DIR/sinks
cd $FLINK_PLANNER_DIR/sources; cp definedTimeAttributes.scala StreamTableSource.scala TableSourceUtil.scala  $BLINK_PLANNER_DIR/sources;
cd $FLINK_PLANNER_DIR/sources/tsextractors; cp -r ./  $BLINK_PLANNER_DIR/sources/tsextractors/;
cd $FLINK_PLANNER_DIR/sources/wmstrategies; cp -r ./  $BLINK_PLANNER_DIR/sources/wmstrategies/;
cd $FLINK_PLANNER_DIR/typeutils; cp -r ./ $BLINK_PLANNER_DIR/typeutils/;
cd $FLINK_PLANNER_DIR/validate; cp -r ./ $BLINK_PLANNER_DIR/validate/;

cd $FLINK_JAVA_PLANNER_DIR/expressions; cp TableReferenceExpression.java $BLINK_JAVA_PLANNER_DIR/expressions/;

cd $FLINK_PLANNER_TEST_DIR/api/validation; cp TableSourceValidationTest.scala $BLINK_PLANNER_TEST_DIR/api/validation/;
cd $FLINK_PLANNER_TEST_DIR/utils; cp testTableSources.scala $BLINK_PLANNER_TEST_DIR/validation/;