MCPcopy Create free account
hub / github.com/apache/arrow-rs / do_put

Method do_put

arrow-flight/src/sql/client.rs:295–301  ·  view source on GitHub ↗

Push a stream to the flight service associated with a particular flight stream.

(
        &mut self,
        request: impl tonic::IntoStreamingRequest<Message = FlightData>,
    )

Source from the content-addressed store, hash-verified

293
294 /// Push a stream to the flight service associated with a particular flight stream.
295 pub async fn do_put(
296 &mut self,
297 request: impl tonic::IntoStreamingRequest<Message = FlightData>,
298 ) -> Result<Streaming<PutResult>> {
299 let req = self.set_request_headers(request.into_streaming_request())?;
300 Ok(self.flight_client.do_put(req).await?.into_inner())
301 }
302
303 /// DoAction allows a flight client to do a specific action against a flight service
304 pub async fn do_action(

Callers 3

execute_updateMethod · 0.45
execute_ingestMethod · 0.45
write_bind_paramsMethod · 0.45

Calls 2

set_request_headersMethod · 0.80
into_innerMethod · 0.45

Tested by

no test coverage detected