pub struct DecodedFlightData {
pub inner: FlightData,
pub payload: DecodedPayload,
}
Expand description
FlightData and the decoded payload (Schema, RecordBatch), if any
Fields§
§inner: FlightData
The original FlightData message
payload: DecodedPayload
The decoded payload
Implementations§
Source§impl DecodedFlightData
impl DecodedFlightData
Sourcepub fn new_none(inner: FlightData) -> Self
pub fn new_none(inner: FlightData) -> Self
Create a new DecodedFlightData with no payload
Sourcepub fn new_schema(inner: FlightData, schema: SchemaRef) -> Self
pub fn new_schema(inner: FlightData, schema: SchemaRef) -> Self
Create a new DecodedFlightData with a [Schema
] payload
Sourcepub fn new_record_batch(inner: FlightData, batch: RecordBatch) -> Self
pub fn new_record_batch(inner: FlightData, batch: RecordBatch) -> Self
Create a new DecodedFlightData
with a [RecordBatch
] payload
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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