Skip to main content

wrap_remote_dyn_filter_guarded_stream

datanode::region_server::remote_dyn_filter

Function wrap_remote_dyn_filter_guarded_stream 

Source 
pub(super) fn wrap_remote_dyn_filter_guarded_stream(
    stream: SendableRecordBatchStream,
    cleanup: RemoteDynFilterRegistrationGuard,
) -> SendableRecordBatchStream