diff --git a/src/connector/src/source/base.rs b/src/connector/src/source/base.rs index 4e126c528d7ed..406d678a65ee6 100644 --- a/src/connector/src/source/base.rs +++ b/src/connector/src/source/base.rs @@ -210,6 +210,7 @@ pub type SourceEnumeratorContextRef = Arc; pub trait AnySplitEnumerator: Send { async fn list_splits(&mut self) -> Result>; async fn on_drop_fragments(&mut self, _fragment_ids: Vec) -> Result<()>; + async fn on_finish_backfill(&mut self, _fragment_ids: Vec) -> Result<()>; } #[async_trait] @@ -223,6 +224,10 @@ impl>> AnySplitEnumerator for T { async fn on_drop_fragments(&mut self, _fragment_ids: Vec) -> Result<()> { SplitEnumerator::on_drop_fragments(self, _fragment_ids).await } + + async fn on_finish_backfill(&mut self, _fragment_ids: Vec) -> Result<()> { + SplitEnumerator::on_finish_backfill(self, _fragment_ids).await + } } /// The max size of a chunk yielded by source stream.