-
Notifications
You must be signed in to change notification settings - Fork 524
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Browse files
Browse the repository at this point in the history
* refactor: wrap source creation into SourceDescBuilder to create stream source. Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * remove StreamSource related part of create_source rpc in CN Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * fix typo Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * fix unit test Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * remove SourceType field in SourceNode Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * remap row_id_index in SourceExecutor Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * build table source in SourceDescBuilder, remove create_source/sync_source rpc - move create_table_source logic into SourceDescBuilder - remove create_source rpc in CN - remove sync_source rpc in CN - fix all unittests' complaination Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * fix misc check error Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * move create_table_info into source::table::test_utils Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * remove row_id_index field from source_executor Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * remove SourceCatalogType in frontend Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> * Update src/stream/src/executor/source/source_executor.rs Co-authored-by: Bugen Zhao <i@bugenzhao.com> Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> Signed-off-by: Qinglin Pan <qinglin@risingwave-labs.com> Co-authored-by: Bugen Zhao <i@bugenzhao.com>
- Loading branch information
Showing
25 changed files
with
425 additions
and
592 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.