Trait GrpcStreamToTable

pub trait GrpcStreamToTable:
    Debug
    + 'static
    + Send
    + Sync
    + Clone
    + Unpin {
    type GrpcStreamData;

    // Required methods
    fn fetch_schema<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = DataFusionResult<SchemaRef>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn process_response(
        &mut self,
        response: Self::GrpcStreamData,
    ) -> DataFusionResult<RecordBatch>;
    fn send_streaming_request<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = DataFusionResult<Response<Streaming<Self::GrpcStreamData>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Associated Types

type GrpcStreamData

Required Methods

fn fetch_schema<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = DataFusionResult<SchemaRef>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn process_response( &mut self, response: Self::GrpcStreamData, ) -> DataFusionResult<RecordBatch>

fn send_streaming_request<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = DataFusionResult<Response<Streaming<Self::GrpcStreamData>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl GrpcStreamToTable for PartitionTableProvider

type GrpcStreamData = ScanPartitionTableResponse

impl GrpcStreamToTable for SearchResultsTableProvider

type GrpcStreamData = SearchDatasetResponse

impl GrpcStreamToTable for TableEntryTableProvider

type GrpcStreamData = ScanTableResponse