Struct arrow_flight::decode::DecodedFlightData
source · pub struct DecodedFlightData {
pub inner: FlightData,
pub payload: DecodedPayload,
}
Expand description
FlightData and the decoded payload (Schema, RecordBatch), if any
Fields§
§inner: FlightData
§payload: DecodedPayload
Implementations§
source§impl DecodedFlightData
impl DecodedFlightData
pub fn new_none(inner: FlightData) -> Self
pub fn new_schema(inner: FlightData, schema: SchemaRef) -> Self
pub fn new_record_batch(inner: FlightData, batch: RecordBatch) -> Self
sourcepub fn app_metadata(&self) -> Bytes
pub fn app_metadata(&self) -> Bytes
return the metadata field of the inner flight data
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for DecodedFlightData
impl !RefUnwindSafe for DecodedFlightData
impl Send for DecodedFlightData
impl Sync for DecodedFlightData
impl Unpin for DecodedFlightData
impl !UnwindSafe for DecodedFlightData
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request