feat: Experimentally introducing sink into table#13185

Merged

shanicky merged 42 commits intomainfrom peng/sink-into-table-new

Dec 9, 2023

+2,036-435

Commits on Dec 9, 2023

Update fill_cdc_mysql_server_id to conditionally add server ID if not present in properties.
shanicky
committed
Added modules and commented code blocks in create_table.rs. Imported modules and modified functions in mod.rs.
shanicky
committed
Code cleanup: Removal of unnecessary println! statements
shanicky
committed
Added modules and commented code blocks in create_table.rs. Imported modules and modified functions in mod.rs.
shanicky
committed
Added new Table variant, commented out println, and modified ddl_service.rs file
shanicky
committed
Merge message types, modify imports, add new functions, and modify structs.
shanicky
committed
Add ReplaceTableChange to ddl_service.proto and update CreateSinkRequest to include target_table_change.
shanicky
committed
Code changes: Module relocation, print statement removal, comment addition, license header addition, print statement removal, print statement removal
shanicky
committed
Added "incoming_sinks" field to TableCatalogBuilder struct
shanicky
committed
Add empty vector to incoming_sinks in table_catalog.rs, remove return statement in ddl_controller.rs, add empty vector to incoming_sinks in filter_key_extractor.rs.
shanicky
committed
Refactor imports and functions, remove unused code, add new functionality
shanicky
committed
Update code with various changes: single sink, specific attributes, error handling, append-only and delete chunk support, bug fixes.
shanicky
committed
Remove println! statements in code.
shanicky
committed
Code changes: remove unused argument, modify function names and logic, add insert merger function
shanicky
committed
Import Arc, SessionImpl, add fetch_table_catalog_for_alter, refactor handle_alter_table_column. Add schema_has_schema_registry function and tests.
shanicky
committed
Update sink_into_name to target_table, rename generate_table to generate_stream_graph_for_table.
shanicky
committed
Modified SinkCatalog's target_table field, changed external.rs, modified import statements, removed assertion, modified CatalogManager
shanicky
committed
Add new tables, sinks, drops and cycle check.
shanicky
committed
correct handle incoming sink
shanicky
committed
Fix import, create Arc instances in handle functions
shanicky
committed
Error handling implemented, mutable reference acquired, function removed.
shanicky
committed
Code changes: import PbReplaceTablePlan, ReplaceTablePlan, remove duplicate DdlProgress import.
shanicky
committed
Updated catalog.proto and other files, added target_table field and incoming_sinks field, removed visit_stream_node_cont function.
shanicky
committed
Refactoring: Remove Barrier from stream_plan.proto, refactor import in barrier/command.rs, reformat code in rpc/ddl_controller.rs.
shanicky
committed
Add comment explaining affected_table_change field in CreateSinkRequest.
shanicky
committed
Modified error message and removed functions in alter_table_column.rs and catalog/mod.rs
shanicky
committed
Modifies impl PlanRoot and adds with_upstreams method.
shanicky
committed
Refactor imports and remove unused ones
shanicky
committed
fix default column
shanicky
committed
Modify sink_into_table.slt and CatalogManager in catalog.
shanicky
committed
add default value column for sink into table
shanicky
committed
move check cycle to meta
shanicky
committed
fix conflict
shanicky
committed
Updated error messages, added imports, modified functions, and fixed bugs.
shanicky
committed
Code changes: remove ColIndexMapping usage, replace with None, update function signatures and variable usage.
shanicky
committed
move cycle check back to fe
shanicky
committed
huge: use AddAndUpdate mutation
shanicky
committed
Refactored return types and statements.
shanicky
committed
big change
shanicky
committed
fix conflict
shanicky
committed
Added comments and new struct for sink plan in handler files
shanicky
committed
Add comment about dropping sink into table not compatible with cascade drop.
shanicky
committed