Context: In crates/connectors/src/sources/grpc.rs (around line 222), there is a TODO: Implement limit pushdown. While full limit pushdown requires translating the DataFusion logical plan into the specific gRPC request message, the first step is just to plumb the limit: Option<usize> through the source definition.
Task:
- Locate
crates/connectors/src/sources/grpc.rs.
- Find where the
limit might be passed into the connector (usually in the scan method of TableProvider).
- Add a
tracing::debug!("gRPC connector limit pushdown requested: {:?}", limit); to acknowledge the limit parameter is received, removing the TODO comment.
This prepares the scaffolding for the actual pushdown implementation later.
Context: In
crates/connectors/src/sources/grpc.rs(around line 222), there is aTODO: Implement limit pushdown. While full limit pushdown requires translating the DataFusion logical plan into the specific gRPC request message, the first step is just to plumb thelimit: Option<usize>through the source definition.Task:
crates/connectors/src/sources/grpc.rs.limitmight be passed into the connector (usually in thescanmethod ofTableProvider).tracing::debug!("gRPC connector limit pushdown requested: {:?}", limit);to acknowledge the limit parameter is received, removing theTODOcomment.This prepares the scaffolding for the actual pushdown implementation later.