rename

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Oct 11, 2024 · 528f886 · 528f886
1 parent fd0c74d
commit 528f886
Show file tree

Hide file tree

Showing 87 changed files with 6 additions and 14 deletions.
diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh
@@ -149,9 +149,9 @@ echo "--- e2e, ci-kafka, legacy kafka tests"
 export RUST_MIN_STACK=4194304
 RUST_LOG="info,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
 risedev ci-start ci-kafka
-./e2e_test/source/kafka_legacy/script/prepare_ci_kafka.sh
-risedev slt './e2e_test/source/kafka_legacy/*.slt'
-risedev slt './e2e_test/source/kafka_legacy/old_row_format_syntax/*.slt'
+./e2e_test/source_legacy/kafka/script/prepare_ci_kafka.sh
+risedev slt './e2e_test/source_legacy/kafka/*.slt'
+risedev slt './e2e_test/source_legacy/kafka/old_row_format_syntax/*.slt'
 
 echo "--- Run CH-benCHmark"
 risedev slt './e2e_test/ch_benchmark/batch/ch_benchmark.slt'

diff --git a/e2e_test/source/kafka_legacy/README.md b/e2e_test/source/kafka_legacy/README.md
diff --git a/...ark_endless_mvs/nexmark_endless_part1.slt → ...ark_endless_mvs/nexmark_endless_part1.slt b/...ark_endless_mvs/nexmark_endless_part1.slt → ...ark_endless_mvs/nexmark_endless_part1.slt
diff --git a/...ark_endless_mvs/nexmark_endless_part2.slt → ...ark_endless_mvs/nexmark_endless_part2.slt b/...ark_endless_mvs/nexmark_endless_part2.slt → ...ark_endless_mvs/nexmark_endless_part2.slt
diff --git a/...ark_endless_mvs/nexmark_endless_part3.slt → ...ark_endless_mvs/nexmark_endless_part3.slt b/...ark_endless_mvs/nexmark_endless_part3.slt → ...ark_endless_mvs/nexmark_endless_part3.slt
diff --git a/...ark_endless_mvs/nexmark_endless_part4.slt → ...ark_endless_mvs/nexmark_endless_part4.slt b/...ark_endless_mvs/nexmark_endless_part4.slt → ...ark_endless_mvs/nexmark_endless_part4.slt
diff --git a/...k_endless_sinks/nexmark_endless_part1.slt → ...k_endless_sinks/nexmark_endless_part1.slt b/...k_endless_sinks/nexmark_endless_part1.slt → ...k_endless_sinks/nexmark_endless_part1.slt
diff --git a/...k_endless_sinks/nexmark_endless_part2.slt → ...k_endless_sinks/nexmark_endless_part2.slt b/...k_endless_sinks/nexmark_endless_part2.slt → ...k_endless_sinks/nexmark_endless_part2.slt
diff --git a/...k_endless_sinks/nexmark_endless_part3.slt → ...k_endless_sinks/nexmark_endless_part3.slt b/...k_endless_sinks/nexmark_endless_part3.slt → ...k_endless_sinks/nexmark_endless_part3.slt
diff --git a/...k_endless_sinks/nexmark_endless_part4.slt → ...k_endless_sinks/nexmark_endless_part4.slt b/...k_endless_sinks/nexmark_endless_part4.slt → ...k_endless_sinks/nexmark_endless_part4.slt
diff --git a/...k_endless_sinks/nexmark_endless_part5.slt → ...k_endless_sinks/nexmark_endless_part5.slt b/...k_endless_sinks/nexmark_endless_part5.slt → ...k_endless_sinks/nexmark_endless_part5.slt
diff --git a/...k_endless_sinks/nexmark_endless_part6.slt → ...k_endless_sinks/nexmark_endless_part6.slt b/...k_endless_sinks/nexmark_endless_part6.slt → ...k_endless_sinks/nexmark_endless_part6.slt
diff --git a/e2e_test/source/README.md → e2e_test/source_legacy/README.md b/e2e_test/source/README.md → e2e_test/source_legacy/README.md
diff --git a/e2e_test/source/cdc/cdc.check.slt → e2e_test/source_legacy/cdc/cdc.check.slt b/e2e_test/source/cdc/cdc.check.slt → e2e_test/source_legacy/cdc/cdc.check.slt
diff --git a/e2e_test/source/cdc/cdc.check_new_rows.slt → .../source_legacy/cdc/cdc.check_new_rows.slt b/e2e_test/source/cdc/cdc.check_new_rows.slt → .../source_legacy/cdc/cdc.check_new_rows.slt
diff --git a/e2e_test/source/cdc/cdc.load.slt → e2e_test/source_legacy/cdc/cdc.load.slt b/e2e_test/source/cdc/cdc.load.slt → e2e_test/source_legacy/cdc/cdc.load.slt
diff --git a/e2e_test/source/cdc/cdc.share_stream.slt → ...st/source_legacy/cdc/cdc.share_stream.slt b/e2e_test/source/cdc/cdc.share_stream.slt → ...st/source_legacy/cdc/cdc.share_stream.slt
diff --git a/e2e_test/source/cdc/cdc.validate.mysql.slt → .../source_legacy/cdc/cdc.validate.mysql.slt b/e2e_test/source/cdc/cdc.validate.mysql.slt → .../source_legacy/cdc/cdc.validate.mysql.slt
diff --git a/...test/source/cdc/cdc.validate.postgres.slt → ...urce_legacy/cdc/cdc.validate.postgres.slt b/...test/source/cdc/cdc.validate.postgres.slt → ...urce_legacy/cdc/cdc.validate.postgres.slt
diff --git a/...test/source/cdc/cdc_share_stream_drop.slt → ...urce_legacy/cdc/cdc_share_stream_drop.slt b/...test/source/cdc/cdc_share_stream_drop.slt → ...urce_legacy/cdc/cdc_share_stream_drop.slt
diff --git a/...test/source/cdc/mongodb/mongodb_basic.slt → ...urce_legacy/cdc/mongodb/mongodb_basic.slt b/...test/source/cdc/mongodb/mongodb_basic.slt → ...urce_legacy/cdc/mongodb/mongodb_basic.slt
diff --git a/e2e_test/source/cdc/mysql_cdc.sql → e2e_test/source_legacy/cdc/mysql_cdc.sql b/e2e_test/source/cdc/mysql_cdc.sql → e2e_test/source_legacy/cdc/mysql_cdc.sql
diff --git a/e2e_test/source/cdc/mysql_cdc_insert.sql → ...st/source_legacy/cdc/mysql_cdc_insert.sql b/e2e_test/source/cdc/mysql_cdc_insert.sql → ...st/source_legacy/cdc/mysql_cdc_insert.sql
diff --git a/e2e_test/source/cdc/mysql_create.sql → e2e_test/source_legacy/cdc/mysql_create.sql b/e2e_test/source/cdc/mysql_create.sql → e2e_test/source_legacy/cdc/mysql_create.sql
diff --git a/e2e_test/source/cdc/mysql_init_data.sql → ...est/source_legacy/cdc/mysql_init_data.sql b/e2e_test/source/cdc/mysql_init_data.sql → ...est/source_legacy/cdc/mysql_init_data.sql
diff --git a/e2e_test/source/cdc/postgres_cdc.sql → e2e_test/source_legacy/cdc/postgres_cdc.sql b/e2e_test/source/cdc/postgres_cdc.sql → e2e_test/source_legacy/cdc/postgres_cdc.sql
diff --git a/e2e_test/source/cdc/postgres_cdc_insert.sql → ...source_legacy/cdc/postgres_cdc_insert.sql b/e2e_test/source/cdc/postgres_cdc_insert.sql → ...source_legacy/cdc/postgres_cdc_insert.sql
diff --git a/..._inline/alter/cdc_backfill_rate_limit.slt → ..._inline/alter/cdc_backfill_rate_limit.slt b/..._inline/alter/cdc_backfill_rate_limit.slt → ..._inline/alter/cdc_backfill_rate_limit.slt
diff --git a/...urce/cdc_inline/alter/cdc_table_alter.slt → ...gacy/cdc_inline/alter/cdc_table_alter.slt b/...urce/cdc_inline/alter/cdc_table_alter.slt → ...gacy/cdc_inline/alter/cdc_table_alter.slt
diff --git a/...ource/cdc_inline/alter/postgres_alter.slt → ...egacy/cdc_inline/alter/postgres_alter.slt b/...ource/cdc_inline/alter/postgres_alter.slt → ...egacy/cdc_inline/alter/postgres_alter.slt
diff --git a/...e/cdc_inline/auto_schema_change_mysql.slt → ...y/cdc_inline/auto_schema_change_mysql.slt b/...e/cdc_inline/auto_schema_change_mysql.slt → ...y/cdc_inline/auto_schema_change_mysql.slt
diff --git a/...urce/cdc_inline/auto_schema_map_mysql.slt → ...gacy/cdc_inline/auto_schema_map_mysql.slt b/...urce/cdc_inline/auto_schema_map_mysql.slt → ...gacy/cdc_inline/auto_schema_map_mysql.slt
diff --git a/.../source/cdc_inline/auto_schema_map_pg.slt → ..._legacy/cdc_inline/auto_schema_map_pg.slt b/.../source/cdc_inline/auto_schema_map_pg.slt → ..._legacy/cdc_inline/auto_schema_map_pg.slt
diff --git a/...ource/cdc_inline/postgres_create_drop.slt → ...egacy/cdc_inline/postgres_create_drop.slt b/...ource/cdc_inline/postgres_create_drop.slt → ...egacy/cdc_inline/postgres_create_drop.slt
@@ -57,4 +57,4 @@ SELECT * FROM tt1;
 1 2023-10-23 10:00:00+00:00
 
 statement ok
-drop table tt1;
+drop table tt1;
diff --git a/..._inline/sql_server_cdc/sql_server_cdc.slt → ..._inline/sql_server_cdc/sql_server_cdc.slt b/..._inline/sql_server_cdc/sql_server_cdc.slt → ..._inline/sql_server_cdc/sql_server_cdc.slt
diff --git a/.../sql_server_cdc/sql_server_cdc_insert.sql → .../sql_server_cdc/sql_server_cdc_insert.sql b/.../sql_server_cdc/sql_server_cdc_insert.sql → .../sql_server_cdc/sql_server_cdc_insert.sql
diff --git a/...sql_server_cdc/sql_server_cdc_prepare.sql → ...sql_server_cdc/sql_server_cdc_prepare.sql b/...sql_server_cdc/sql_server_cdc_prepare.sql → ...sql_server_cdc/sql_server_cdc_prepare.sql
diff --git a/e2e_test/source/kafka_legacy/ddl.slt → e2e_test/source_legacy/kafka/ddl.slt b/e2e_test/source/kafka_legacy/ddl.slt → e2e_test/source_legacy/kafka/ddl.slt
diff --git a/e2e_test/source/kafka_legacy/kafka.slt → e2e_test/source_legacy/kafka/kafka.slt b/e2e_test/source/kafka_legacy/kafka.slt → e2e_test/source_legacy/kafka/kafka.slt
diff --git a/e2e_test/source/kafka_legacy/kafka_batch.slt → e2e_test/source_legacy/kafka/kafka_batch.slt b/e2e_test/source/kafka_legacy/kafka_batch.slt → e2e_test/source_legacy/kafka/kafka_batch.slt
diff --git a/e2e_test/source/kafka_legacy/nosim_kafka.slt → e2e_test/source_legacy/kafka/nosim_kafka.slt b/e2e_test/source/kafka_legacy/nosim_kafka.slt → e2e_test/source_legacy/kafka/nosim_kafka.slt
diff --git a/..._legacy/old_row_format_syntax/datagen.slt → ...y/kafka/old_row_format_syntax/datagen.slt b/..._legacy/old_row_format_syntax/datagen.slt → ...y/kafka/old_row_format_syntax/datagen.slt
diff --git a/...afka_legacy/old_row_format_syntax/ddl.slt → ...egacy/kafka/old_row_format_syntax/ddl.slt b/...afka_legacy/old_row_format_syntax/ddl.slt → ...egacy/kafka/old_row_format_syntax/ddl.slt
diff --git a/...ka_legacy/old_row_format_syntax/kafka.slt → ...acy/kafka/old_row_format_syntax/kafka.slt b/...ka_legacy/old_row_format_syntax/kafka.slt → ...acy/kafka/old_row_format_syntax/kafka.slt
diff --git a/...acy/old_row_format_syntax/kafka_batch.slt → ...fka/old_row_format_syntax/kafka_batch.slt b/...acy/old_row_format_syntax/kafka_batch.slt → ...fka/old_row_format_syntax/kafka_batch.slt
diff --git a/...test/source/kafka_legacy/script/README.md → ...test/source_legacy/kafka/script/README.md b/...test/source/kafka_legacy/script/README.md → ...test/source_legacy/kafka/script/README.md
diff --git a/...e/kafka_legacy/script/prepare_ci_kafka.sh → ...e_legacy/kafka/script/prepare_ci_kafka.sh b/...e/kafka_legacy/script/prepare_ci_kafka.sh → ...e_legacy/kafka/script/prepare_ci_kafka.sh
@@ -4,8 +4,8 @@
 set -e
 
 SCRIPT_PATH="$(cd "$(dirname "$0")" >/dev/null 2>&1 && pwd)"
-# SCRIPT_PATH is e2e_test/source/kafka_legacy/script/
-# cwd is e2e_test/source/kafka_legacy/
+# SCRIPT_PATH is e2e_test/source_legacy/kafka/script/
+# cwd is e2e_test/source_legacy/kafka/
 
 echo "$SCRIPT_PATH"
 

diff --git a/...legacy/script/schema_registry_producer.py → .../kafka/script/schema_registry_producer.py b/...legacy/script/schema_registry_producer.py → .../kafka/script/schema_registry_producer.py
diff --git a/.../source/kafka_legacy/script/test_data.zip → .../source_legacy/kafka/script/test_data.zip b/.../source/kafka_legacy/script/test_data.zip → .../source_legacy/kafka/script/test_data.zip
diff --git a/...cript/test_data/avro_complex_schema_bin.1 → ...cript/test_data/avro_complex_schema_bin.1 b/...cript/test_data/avro_complex_schema_bin.1 → ...cript/test_data/avro_complex_schema_bin.1
diff --git a/...script/test_data/avro_simple_schema_bin.1 → ...script/test_data/avro_simple_schema_bin.1 b/...script/test_data/avro_simple_schema_bin.1 → ...script/test_data/avro_simple_schema_bin.1
diff --git a/.../kafka_legacy/script/test_data/bug_bash.1 → ..._legacy/kafka/script/test_data/bug_bash.1 b/.../kafka_legacy/script/test_data/bug_bash.1 → ..._legacy/kafka/script/test_data/bug_bash.1
diff --git a/...cript/test_data/canal_json_double_field.1 → ...cript/test_data/canal_json_double_field.1 b/...cript/test_data/canal_json_double_field.1 → ...cript/test_data/canal_json_double_field.1
diff --git a/...fka_legacy/script/test_data/cannal_json.1 → ...gacy/kafka/script/test_data/cannal_json.1 b/...fka_legacy/script/test_data/cannal_json.1 → ...gacy/kafka/script/test_data/cannal_json.1
diff --git a/...pt/test_data/debezium_compact_avro_json.1 → ...pt/test_data/debezium_compact_avro_json.1 b/...pt/test_data/debezium_compact_avro_json.1 → ...pt/test_data/debezium_compact_avro_json.1
diff --git a/...ipt/test_data/debezium_ignore_case_json.1 → ...ipt/test_data/debezium_ignore_case_json.1 b/...ipt/test_data/debezium_ignore_case_json.1 → ...ipt/test_data/debezium_ignore_case_json.1
diff --git a/...ka_legacy/script/test_data/debezium_log.1 → ...acy/kafka/script/test_data/debezium_log.1 b/...ka_legacy/script/test_data/debezium_log.1 → ...acy/kafka/script/test_data/debezium_log.1
diff --git a/.../test_data/debezium_log_no_schema_field.1 → .../test_data/debezium_log_no_schema_field.1 b/.../test_data/debezium_log_no_schema_field.1 → .../test_data/debezium_log_no_schema_field.1
diff --git a/...gacy/script/test_data/debezium_mess_key.1 → ...afka/script/test_data/debezium_mess_key.1 b/...gacy/script/test_data/debezium_mess_key.1 → ...afka/script/test_data/debezium_mess_key.1
diff --git a/...test_data/debezium_mongo_json_customers.1 → ...test_data/debezium_mongo_json_customers.1 b/...test_data/debezium_mongo_json_customers.1 → ...test_data/debezium_mongo_json_customers.1
diff --git a/...um_mongo_json_customers_no_schema_field.1 → ...um_mongo_json_customers_no_schema_field.1 b/...um_mongo_json_customers_no_schema_field.1 → ...um_mongo_json_customers_no_schema_field.1
diff --git a/...est_data/debezium_non_compact_avro_json.1 → ...est_data/debezium_non_compact_avro_json.1 b/...est_data/debezium_non_compact_avro_json.1 → ...est_data/debezium_non_compact_avro_json.1
diff --git a/...afka_legacy/script/test_data/json_bytea.1 → ...egacy/kafka/script/test_data/json_bytea.1 b/...afka_legacy/script/test_data/json_bytea.1 → ...egacy/kafka/script/test_data/json_bytea.1
diff --git a/...ce/kafka_legacy/script/test_data/json_c.1 → ...ce_legacy/kafka/script/test_data/json_c.1 b/...ce/kafka_legacy/script/test_data/json_c.1 → ...ce_legacy/kafka/script/test_data/json_c.1
diff --git a/...pt/test_data/json_schema_without_schema.1 → ...pt/test_data/json_schema_without_schema.1 b/...pt/test_data/json_schema_without_schema.1 → ...pt/test_data/json_schema_without_schema.1
diff --git a/...gacy/script/test_data/kafka_1_csv_topic.1 → ...afka/script/test_data/kafka_1_csv_topic.1 b/...gacy/script/test_data/kafka_1_csv_topic.1 → ...afka/script/test_data/kafka_1_csv_topic.1
diff --git a/...pt/test_data/kafka_1_partition_mv_topic.1 → ...pt/test_data/kafka_1_partition_mv_topic.1 b/...pt/test_data/kafka_1_partition_mv_topic.1 → ...pt/test_data/kafka_1_partition_mv_topic.1
diff --git a/...cript/test_data/kafka_1_partition_topic.1 → ...cript/test_data/kafka_1_partition_topic.1 b/...cript/test_data/kafka_1_partition_topic.1 → ...cript/test_data/kafka_1_partition_topic.1
diff --git a/...cript/test_data/kafka_2_partition_topic.2 → ...cript/test_data/kafka_2_partition_topic.2 b/...cript/test_data/kafka_2_partition_topic.2 → ...cript/test_data/kafka_2_partition_topic.2
diff --git a/...cript/test_data/kafka_3_partition_topic.3 → ...cript/test_data/kafka_3_partition_topic.3 b/...cript/test_data/kafka_3_partition_topic.3 → ...cript/test_data/kafka_3_partition_topic.3
diff --git a/...cript/test_data/kafka_4_partition_topic.4 → ...cript/test_data/kafka_4_partition_topic.4 b/...cript/test_data/kafka_4_partition_topic.4 → ...cript/test_data/kafka_4_partition_topic.4
diff --git a/...fka_4_partition_topic_generated_columns.1 → ...fka_4_partition_topic_generated_columns.1 b/...fka_4_partition_topic_generated_columns.1 → ...fka_4_partition_topic_generated_columns.1
diff --git a/...afka_4_partition_topic_with_100_message.4 → ...afka_4_partition_topic_with_100_message.4 b/...afka_4_partition_topic_with_100_message.4 → ...afka_4_partition_topic_with_100_message.4
diff --git a/...gacy/script/test_data/kafka_json_schema.1 → ...afka/script/test_data/kafka_json_schema.1 b/...gacy/script/test_data/kafka_json_schema.1 → ...afka/script/test_data/kafka_json_schema.1
diff --git a/...ipt/test_data/kafka_source_format_bytes.1 → ...ipt/test_data/kafka_source_format_bytes.1 b/...ipt/test_data/kafka_source_format_bytes.1 → ...ipt/test_data/kafka_source_format_bytes.1
diff --git a/...ript/test_data/kafka_upsert_json_schema.1 → ...ript/test_data/kafka_upsert_json_schema.1 b/...ript/test_data/kafka_upsert_json_schema.1 → ...ript/test_data/kafka_upsert_json_schema.1
diff --git a/...ka_legacy/script/test_data/maxwell_json.1 → ...acy/kafka/script/test_data/maxwell_json.1 b/...ka_legacy/script/test_data/maxwell_json.1 → ...acy/kafka/script/test_data/maxwell_json.1
diff --git a/...fka_legacy/script/test_data/proto_c_bin.1 → ...gacy/kafka/script/test_data/proto_c_bin.1 b/...fka_legacy/script/test_data/proto_c_bin.1 → ...gacy/kafka/script/test_data/proto_c_bin.1
diff --git a/...a_legacy/script/test_data/sink_debezium.1 → ...cy/kafka/script/test_data/sink_debezium.1 b/...a_legacy/script/test_data/sink_debezium.1 → ...cy/kafka/script/test_data/sink_debezium.1
diff --git a/...fka_legacy/script/test_data/sink_target.1 → ...gacy/kafka/script/test_data/sink_target.1 b/...fka_legacy/script/test_data/sink_target.1 → ...gacy/kafka/script/test_data/sink_target.1
diff --git a/...fka_legacy/script/test_data/upsert_json.1 → ...gacy/kafka/script/test_data/upsert_json.1 b/...fka_legacy/script/test_data/upsert_json.1 → ...gacy/kafka/script/test_data/upsert_json.1
diff --git a/...ript/test_data/upsert_student_avro_json.1 → ...ript/test_data/upsert_student_avro_json.1 b/...ript/test_data/upsert_student_avro_json.1 → ...ript/test_data/upsert_student_avro_json.1
diff --git a/...udent_key_not_subset_of_value_avro_json.1 → ...udent_key_not_subset_of_value_avro_json.1 b/...udent_key_not_subset_of_value_avro_json.1 → ...udent_key_not_subset_of_value_avro_json.1
diff --git a/...e/kafka_legacy/script/test_data/weiling.1 → ...e_legacy/kafka/script/test_data/weiling.1 b/...e/kafka_legacy/script/test_data/weiling.1 → ...e_legacy/kafka/script/test_data/weiling.1
diff --git a/e2e_test/source/pulsar/astra-streaming.py → ...t/source_legacy/pulsar/astra-streaming.py b/e2e_test/source/pulsar/astra-streaming.py → ...t/source_legacy/pulsar/astra-streaming.py
diff --git a/e2e_test/source/pulsar/pulsar.slt → e2e_test/source_legacy/pulsar/pulsar.slt b/e2e_test/source/pulsar/pulsar.slt → e2e_test/source_legacy/pulsar/pulsar.slt
diff --git a/e2e_test/source/pulsar/streamnative-cloud.py → ...ource_legacy/pulsar/streamnative-cloud.py b/e2e_test/source/pulsar/streamnative-cloud.py → ...ource_legacy/pulsar/streamnative-cloud.py