risingwave_
meta
2.4.0-alpha
In risingwave_
meta::
rpc::
ddl_
controller
risingwave_meta
::
rpc
::
ddl_controller
Function
clean_all_rows_by_sink_id
Copy item path
Source
async fn clean_all_rows_by_sink_id( db: &DatabaseConnection, sink_id:
i32
, ) ->
MetaResult
<
()
>