This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 699bf474e5 deploy: 2fe71ca52da53586282f6a24d9290ffca776025f
699bf474e5 is described below
commit 699bf474e52bf6134272a0367c3c91b50361c41b
Author: tustvold <[email protected]>
AuthorDate: Thu Sep 7 13:51:35 2023 +0000
deploy: 2fe71ca52da53586282f6a24d9290ffca776025f
---
.../auth_basic_proto/fn.authenticate.html | 2 +-
.../auth_basic_proto/type.Client.html | 2 +-
.../fn.consume_flight_location.html | 4 +-
.../fn.receive_batch_flight_data.html | 4 +-
.../fn.receive_schema_flight_data.html | 2 +-
.../integration_test/fn.send_batch.html | 2 +-
.../integration_test/fn.upload_data.html | 4 +-
.../integration_test/fn.verify_data.html | 4 +-
.../integration_test/type.Client.html | 2 +-
.../struct.AuthBasicProtoScenarioImpl.html | 54 +++++++++++-----------
.../flight_server_scenarios/fn.endpoint.html | 2 +-
.../integration_test/fn.save_uploaded_chunks.html | 4 +-
.../integration_test/fn.send_app_metadata.html | 2 +-
.../integration_test/struct.FlightServiceImpl.html | 54 +++++++++++-----------
.../middleware/struct.MiddlewareScenarioImpl.html | 54 +++++++++++-----------
.../flight_service_server/trait.FlightService.js | 2 +-
parquet/record/reader/index.html | 2 +-
parquet/record/reader/struct.ReaderIter.html | 4 +-
parquet/record/reader/struct.RowIter.html | 9 ++--
search-index.js | 2 +-
src/parquet/record/reader.rs.html | 12 +++++
21 files changed, 120 insertions(+), 107 deletions(-)
diff --git
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
index af1251346a..483a4f6b64 100644
---
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
+++
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/fn.authenticate.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `authenticate` fn in crate
`arrow_integration_testing`."><title>authenticate in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/Source [...]
- client: &mut <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ client: &mut FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
username: &<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.str.html";>str</a>,
password: &<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.str.html";>str</a>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.E [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
index 078af1f87d..9903e691d6 100644
---
a/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
+++
b/arrow_integration_testing/flight_client_scenarios/auth_basic_proto/type.Client.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
\ No newline at end of file
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::auth_basic_proto -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
index b99bfb75b6..9a9b6c3f2a 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.consume_flight_location.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `consume_flight_location` fn in crate
`arrow_integration_testing`."><title>consume_flight_location in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../ [...]
- location: <a class="struct"
href="../../../arrow_flight/gen/struct.Location.html" title="struct
arrow_flight::gen::Location">Location</a>,
- ticket: <a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>,
+ location: Location,
+ ticket: Ticket,
expected_data: &[<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
index 523c3a2056..8754279c70 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_batch_flight_data.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `receive_batch_flight_data` fn in crate
`arrow_integration_testing`."><title>receive_batch_flight_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href=".. [...]
- resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>,
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>,
schema: <a class="type"
href="../../../arrow_schema/schema/type.SchemaRef.html" title="type
arrow_schema::schema::SchemaRef">SchemaRef</a>,
dictionaries_by_id: &mut <a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.i64.html";>i64</a>, <a
class="type" href="../../../arrow_array/array/type.ArrayRef.html" title="type
arrow_array::array::ArrayRef">ArrayRef</a>>
-) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightData.html" title="struct
arrow_flight::gen::FlightData">FlightData</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
+) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum
core::option::Option">Option</a><FlightData></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
index c988e33ed6..b09b69b89e 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.receive_schema_flight_data.html
@@ -1,3 +1,3 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `receive_schema_flight_data` fn in crate
`arrow_integration_testing`."><title>receive_schema_flight_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin href="
[...]
- resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>
+ resp: &mut <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
index 3ea0c51942..f6277d4b87 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.send_batch.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `send_batch` fn in crate
`arrow_integration_testing`."><title>send_batch in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSeri [...]
- upload_tx: &mut Sender<<a class="struct"
href="../../../arrow_flight/gen/struct.FlightData.html" title="struct
arrow_flight::gen::FlightData">FlightData</a>>,
+ upload_tx: &mut Sender<FlightData>,
metadata: &[<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.u8.html";>u8</a>],
batch: &<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>,
options: &<a class="struct"
href="../../../arrow_ipc/writer/struct.IpcWriteOptions.html" title="struct
arrow_ipc::writer::IpcWriteOptions">IpcWriteOptions</a>
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
index a247c3cf20..66a26fae9a 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.upload_data.html
@@ -1,6 +1,6 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `upload_data` fn in crate
`arrow_integration_testing`."><title>upload_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSe [...]
- client: <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ client: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
schema: <a class="type"
href="../../../arrow_schema/schema/type.SchemaRef.html" title="type
arrow_schema::schema::SchemaRef">SchemaRef</a>,
- descriptor: <a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>,
+ descriptor: FlightDescriptor,
original_data: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/vec/struct.Vec.html";
title="struct alloc::vec::Vec">Vec</a><<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
index c6406f7b24..9f942607af 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/fn.verify_data.html
@@ -1,5 +1,5 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `verify_data` fn in crate
`arrow_integration_testing`."><title>verify_data in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSe [...]
- client: <a class="struct"
href="../../../arrow_flight/gen/flight_service_client/struct.FlightServiceClient.html"
title="struct
arrow_flight::gen::flight_service_client::FlightServiceClient">FlightServiceClient</a><<a
class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
- descriptor: <a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>,
+ client: FlightServiceClient<<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/transport/channel/struct.Channel.html";
title="struct tonic::transport::channel::Channel">Channel</a>>,
+ descriptor: FlightDescriptor,
expected_data: &[<a class="struct"
href="../../../arrow_array/record_batch/struct.RecordBatch.html" title="struct
arrow_array::record_batch::RecordBatch">RecordBatch</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/error/trait.Error.html";
title="trait core::error::Error">Er [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
b/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
index c79fa9452b..153e633cf6 100644
---
a/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
+++
b/arrow_integration_testing/flight_client_scenarios/integration_test/type.Client.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
\ No newline at end of file
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `Client` type in crate
`arrow_integration_testing`."><title>Client in
arrow_integration_testing::flight_client_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Reg [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
b/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
index e234a6d1dc..b148af1081 100644
---
a/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html
@@ -8,44 +8,44 @@
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section><secti [...]
&self,
token: <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>>
-) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section></div> [...]
+) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="struct.GrpcServerCallContext.html" title="struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::GrpcServerCallContext">GrpcServerCallContext</a>,
<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>></h4></section></div> [...]
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#118-124">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'as [...]
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#118-124">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#126-173">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#126-173">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#175-181">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
cla [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#175-181">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#183-189">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#183-189">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -56,37 +56,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#191-198">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#191-198">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#200-210">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#200-210">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#212-218">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#212-218">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#220-227">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchan
[...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/auth_basic_proto.rs.html#220-227">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git a/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
b/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
index e59d784212..2b094f6a43 100644
--- a/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
+++ b/arrow_integration_testing/flight_server_scenarios/fn.endpoint.html
@@ -1 +1 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `endpoint` fn in crate
`arrow_integration_testing`."><title>endpoint in
arrow_integration_testing::flight_server_scenarios - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac52 [...]
\ No newline at end of file
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `endpoint` fn in crate
`arrow_integration_testing`."><title>endpoint in
arrow_integration_testing::flight_server_scenarios - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin
href="../../static.files/SourceSerif4-Regular-46f98efaafac52 [...]
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
index 1444f09230..70224fd7e4 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.save_uploaded_chunks.html
@@ -1,8 +1,8 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `save_uploaded_chunks` fn in crate
`arrow_integration_testing`."><title>save_uploaded_chunks in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../sta [...]
uploaded_chunks: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><Mutex<<a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct" href [...]
schema_ref: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><<a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>>,
- input_stream: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>,
- response_tx: Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="../../../arrow_flight/gen/struct.PutResult.html" title="struct
arrow_flight::gen::PutResult">PutResult</a>, <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
+ input_stream: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><FlightData>,
+ response_tx: Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><PutResult, <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
schema: <a class="struct"
href="../../../arrow_schema/schema/struct.Schema.html" title="struct
arrow_schema::schema::Schema">Schema</a>,
key: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct
tonic::status::Status">Status</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
index e3586f8dc3..65063e4f01 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/fn.send_app_metadata.html
@@ -1,4 +1,4 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `send_app_metadata` fn in crate
`arrow_integration_testing`."><title>send_app_metadata in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.fi [...]
- tx: &mut Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="struct"
href="../../../arrow_flight/gen/struct.PutResult.html" title="struct
arrow_flight::gen::PutResult">PutResult</a>, <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
+ tx: &mut Sender<<a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><PutResult, <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct tonic::status::Status">Status</a>>>,
app_metadata: &[<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.u8.html";>u8</a>]
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><<a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.unit.html";>()</a>, <a
class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/status/struct.Status.html";
title="struct
tonic::status::Status">Status</a>></code></pre></section></div></main></body></html>
\ No newline at end of file
diff --git
a/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
b/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
index 21fd59959d..996a3a0ea0 100644
---
a/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/integration_test/struct.FlightServiceImpl.html
@@ -1,44 +1,44 @@
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `FlightServiceImpl` struct in crate
`arrow_integration_testing`."><title>FlightServiceImpl in
arrow_integration_testing::flight_server_scenarios::integration_test -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../stati [...]
server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>,
uploaded_chunks: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/sync/struct.Arc.html";
title="struct alloc::sync::Arc">Arc</a><Mutex<<a class="struct"
href="https://doc.rust-lang.org/nightly/std/collections/hash/map/struct.HashMap.html";
title="struct std::collections::hash::map::HashMap">HashMap</a><<a
class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a>, <a class="struct" href [...]
-}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.server_location"
class="structfield small-section-header"><a href="#structfield.server_location"
class="anchor field">§</a><code>server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a></code></span><span
id="structfield.uploaded_chunks" class="structfield [...]
+}</code></pre><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.server_location"
class="structfield small-section-header"><a href="#structfield.server_location"
class="anchor field">§</a><code>server_location: <a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/string/struct.String.html";
title="struct alloc::string::String">String</a></code></span><span
id="structfield.uploaded_chunks" class="structfield [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#99-149">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'asy [...]
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#99-149">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#151-156">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#151-156">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#158-163">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
cla [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#158-163">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#165-210">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#165-210">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -49,37 +49,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#212-259">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#212-259">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#261-266">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#261-266">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#268-273">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#268-273">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#275-280">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchan
[...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/integration_test.rs.html#275-280">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git
a/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
b/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
index 5f29b5bf2f..4ef9d7a8d6 100644
---
a/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
+++
b/arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html
@@ -1,41 +1,41 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `MiddlewareScenarioImpl` struct in crate
`arrow_integration_testing`."><title>MiddlewareScenarioImpl in
arrow_integration_testing::flight_server_scenarios::middleware -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../s [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="API
documentation for the Rust `MiddlewareScenarioImpl` struct in crate
`arrow_integration_testing`."><title>MiddlewareScenarioImpl in
arrow_integration_testing::flight_server_scenarios::middleware -
Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../s [...]
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get the Schema as described in
Schema.fbs::Schema
This is used when a consumer needs the Schema of flight stream. Similar to
GetFlightInfo this interface may generate a new flight that was not previously
-available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#67-72">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_get"
class="fn">do_get</a><'life0, 'async_trait>(
+available in ListFlights.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_get" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#67-72">source</a><a
href="#method.do_get" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_get</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Ticket.html" title="struct
arrow_flight::gen::Ticket">Ticket</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Ticket>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Retrieve a single stream associated with a particular
descriptor
associated with the referenced ticket. A Flight can be composed of one or
more streams where each stream can be retrieved using a separate opaque
-ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#74-79">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymetho
[...]
+ticket that the flight service uses for managing a collection of
streams.</div></details><details class="toggle method-toggle"
open><summary><section id="method.handshake" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#74-79">source</a><a
href="#method.handshake" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">handshake</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.HandshakeRequest.html"
title="struct arrow_flight::gen::HandshakeRequest">HandshakeRequest</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><HandshakeRequest>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Handshake between client and server. Depending on the server,
the
handshake may be required to determine the token that should be used for
future operations. Both request and response are streams to allow multiple
-round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#81-86">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_flights"
class="fn"> [...]
+round-trips depending on auth mechanism.</div></details><details class="toggle
method-toggle" open><summary><section id="method.list_flights" class="method
trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#81-86">source</a><a
href="#method.list_flights" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_flights</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Criteria.html" title="struct
arrow_flight::gen::Criteria">Criteria</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Criteria>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Get a list of available streams given a particular criteria.
Most flight
services will expose one or more streams that are readily available for
retrieval. This api allows listing the streams available for
consumption. A user can also provide a criteria. The criteria can limit
the subset of streams that can be listed via this interface. Each flight
-service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#88-122">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymeth
[...]
+service allows its own definition of how to consume
criteria.</div></details><details class="toggle method-toggle"
open><summary><section id="method.get_flight_info" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#88-122">source</a><a
href="#method.get_flight_info" class="anchor">§</a><h4 class="code-header">fn
<a class="fn">get_flight_info</a><'life0, 'async_trait>(
&'life0 self,
- request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.FlightDescriptor.html" title="struct
arrow_flight::gen::FlightDescriptor">FlightDescriptor</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><FlightDescriptor>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>For a given FlightDescriptor, get information about how the
flight can be
consumed. This is a useful interface if the consumer of the interface
@@ -46,37 +46,37 @@ includes a SQL statement or a Pickled Python operation that
will be
executed. In those cases, the descriptor will not be previously available
within the list of available streams provided by ListFlights but will be
available for consumption for the duration defined by the specific flight
-service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#124-129">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_put"
class="fn">do_put</a><'life0, 'async_trait>(
+service.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_put" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#124-129">source</a><a
href="#method.do_put" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_put</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Push a stream to the flight service associated with a
particular
flight stream. This allows a client of a flight service to upload a stream
of data. Depending on the particular flight service, a client consumer
could be allowed to upload a single stream per descriptor or an unlimited
number. In the latter, the service might implement a ‘seal’ action that
-can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#131-136">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_actio
[...]
+can be applied to a descriptor once all streams are
uploaded.</div></details><details class="toggle method-toggle"
open><summary><section id="method.do_action" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#131-136">source</a><a
href="#method.do_action" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_action</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Action.html" title="struct
arrow_flight::gen::Action">Action</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Action>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Flight services can support an arbitrary number of simple
actions in
addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut
operations that are potentially available. DoAction allows a flight client
to do a specific action against a flight service. An action includes
opaque request and response objects that are specific to the type action
-being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#138-143">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.list_actions"
class="fn">list_actions</a><' [...]
+being undertaken.</div></details><details class="toggle method-toggle"
open><summary><section id="method.list_actions" class="method trait-impl"><a
class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#138-143">source</a><a
href="#method.list_actions" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">list_actions</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="../../../arrow_flight/gen/struct.Empty.html" title="struct
arrow_flight::gen::Empty">Empty</a>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><Empty>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>A flight service exposes all of the available action types
that it has
along with descriptions. This allows different flight consumers to
-understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#145-150">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
href="../../../arrow_flight/gen/flight_service_server/trait.FlightService.html#tymethod.do_exchange"
cl [...]
+understand the capabilities of the flight service.</div></details><details
class="toggle method-toggle" open><summary><section id="method.do_exchange"
class="method trait-impl"><a class="src rightside"
href="../../../src/arrow_integration_testing/flight_server_scenarios/middleware.rs.html#145-150">source</a><a
href="#method.do_exchange" class="anchor">§</a><h4 class="code-header">fn <a
class="fn">do_exchange</a><'life0, 'async_trait>(
&'life0 self,
- _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct tonic::codec::decode::Streaming">Streaming</a><<a
class="struct" href="../../../arrow_flight/gen/struct.FlightData.html"
title="struct arrow_flight::gen::FlightData">FlightData</a>>>
-) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
+ _request: <a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/request/struct.Request.html";
title="struct tonic::request::Request">Request</a><<a class="struct"
href="https://docs.rs/tonic/0.9.2/tonic/codec/decode/struct.Streaming.html";
title="struct
tonic::codec::decode::Streaming">Streaming</a><FlightData>>
+) -> <a class="struct"
href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html"; title="struct
core::pin::Pin">Pin</a><<a class="struct"
href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html";
title="struct alloc::boxed::Box">Box</a><dyn <a class="trait"
href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html";
title="trait core::future::future::Future">Future</a><Output = <a
class="enum" href="https://doc.rust-lang.org/nightly/core/re [...]
Self: 'async_trait,
'life0: 'async_trait,</span></h4></section></summary><div
class='docblock'>Open a bidirectional data channel for a given descriptor. This
allows clients to send and receive arbitrary Arrow data and
diff --git
a/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
b/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
index f45f4ea4ca..073f2538d3 100644
--- a/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
+++ b/implementors/arrow_flight/gen/flight_service_server/trait.FlightService.js
@@ -1,4 +1,4 @@
(function() {var implementors = {
"arrow_flight":[],
-"arrow_integration_testing":[["impl <a class=\"trait\"
href=\"arrow_flight/gen/flight_service_server/trait.FlightService.html\"
title=\"trait
arrow_flight::gen::flight_service_server::FlightService\">FlightService</a> for
<a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::AuthBasicProtoScenarioImpl\">AuthBasicProtoScenari
[...]
+"arrow_integration_testing":[["impl FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/auth_basic_proto/struct.AuthBasicProtoScenarioImpl.html\"
title=\"struct
arrow_integration_testing::flight_server_scenarios::auth_basic_proto::AuthBasicProtoScenarioImpl\">AuthBasicProtoScenarioImpl</a>"],["impl
FlightService for <a class=\"struct\"
href=\"arrow_integration_testing/flight_server_scenarios/middleware/struct.MiddlewareScenarioImpl.html\"
title= [...]
};if (window.register_implementors)
{window.register_implementors(implementors);} else {window.pending_implementors
= implementors;}})()
\ No newline at end of file
diff --git a/parquet/record/reader/index.html b/parquet/record/reader/index.html
index efb2196ecd..75d9348453 100644
--- a/parquet/record/reader/index.html
+++ b/parquet/record/reader/index.html
@@ -1,4 +1,4 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Contains
implementation of record assembly and converting Parquet types into
`Row`s."><title>parquet::record::reader - Rust</title><link rel="preload"
as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Contains
implementation of record assembly and converting Parquet types into
`Row`s."><title>parquet::record::reader - Rust</title><link rel="preload"
as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" [...]
<a href="../api/struct.Row.html" title="struct
parquet::record::api::Row"><code>Row</code></a>s.</p>
</div></details><h2 id="structs" class="small-section-header"><a
href="#structs">Structs</a></h2><ul class="item-table"><li><div
class="item-name"><a class="struct" href="struct.ReaderIter.html" title="struct
parquet::record::reader::ReaderIter">ReaderIter</a></div><div class="desc
docblock-short">Internal iterator of <a href="../api/struct.Row.html"
title="struct parquet::record::api::Row"><code>Row</code></a>s for a
reader.</div></li><li><div class="item-name"><a class="struct" href="s [...]
It is used either for a single row group to iterate over data in that row
group, or
diff --git a/parquet/record/reader/struct.ReaderIter.html
b/parquet/record/reader/struct.ReaderIter.html
index 22fba1e71f..8572d09ddc 100644
--- a/parquet/record/reader/struct.ReaderIter.html
+++ b/parquet/record/reader/struct.ReaderIter.html
@@ -1,8 +1,8 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Internal
iterator of `Row`s for a reader."><title>ReaderIter in parquet::record::reader
- Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" c [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Internal
iterator of `Row`s for a reader."><title>ReaderIter in parquet::record::reader
- Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin
href="../../../static.files/SourceSerif4-Regular-46f98efaafac5295.ttf.woff2"><link
rel="preload" as="font" type="font/woff2" c [...]
root_reader: <a class="enum" href="enum.Reader.html" title="enum
parquet::record::reader::Reader">Reader</a>,
records_left: <a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.usize.html";>usize</a>,
}</code></pre><details class="toggle top-doc" open><summary
class="hideme"><span>Expand description</span></summary><div
class="docblock"><p>Internal iterator of <a href="../api/struct.Row.html"
title="struct parquet::record::api::Row"><code>Row</code></a>s for a reader.</p>
-</div></details><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.root_reader"
class="structfield small-section-header"><a href="#structfield.root_reader"
class="anchor field">§</a><code>root_reader: <a class="enum"
href="enum.Reader.html" title="enum
parquet::record::reader::Reader">Reader</a></code></span><span
id="structfield.records_left" class="structfield small-section-header"><a
href="#structfield.records_lef [...]
+</div></details><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.root_reader"
class="structfield small-section-header"><a href="#structfield.root_reader"
class="anchor field">§</a><code>root_reader: <a class="enum"
href="enum.Reader.html" title="enum
parquet::record::reader::Reader">Reader</a></code></span><span
id="structfield.records_left" class="structfield small-section-header"><a
href="#structfield.records_lef [...]
&mut self
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><[Self::<a
class="associatedtype"
href="https://doc.rust-lang.org/nightly/core/iter/traits/iterator/trait.Iterator.html#associatedtype.Item";
title="type core::iter::traits::iterator::Iterator::Item">Item</a>; <a
class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.array.html";>N</a>], <a
class="struct" href="https://doc.rust-lang.o [...]
Self: <a class="trait"
href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html";
title="trait
core::marker::Sized">Sized</a>,</span></h4></section></summary><span
class="item-info"><div class="stab unstable"><span
class="emoji">🔬</span><span>This is a nightly-only experimental API.
(<code>iter_next_chunk</code>)</span></div></span><div
class='docblock'>Advances the iterator and returns an array containing the next
<code>N</code> values. <a href="https://doc.rust-lang.org/ [...]
diff --git a/parquet/record/reader/struct.RowIter.html
b/parquet/record/reader/struct.RowIter.html
index 189a153ce7..1afae16dbf 100644
--- a/parquet/record/reader/struct.RowIter.html
+++ b/parquet/record/reader/struct.RowIter.html
@@ -1,4 +1,4 @@
-<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Iterator
of `Row`s. It is used either for a single row group to iterate over data in
that row group, or an entire file with auto buffering of all row
groups."><title>RowIter in parquet::record::reader - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin href="../../. [...]
+<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta
name="viewport" content="width=device-width, initial-scale=1.0"><meta
name="generator" content="rustdoc"><meta name="description" content="Iterator
of `Row`s. It is used either for a single row group to iterate over data in
that row group, or an entire file with auto buffering of all row
groups."><title>RowIter in parquet::record::reader - Rust</title><link
rel="preload" as="font" type="font/woff2" crossorigin href="../../. [...]
descr: <a class="type" href="../../schema/types/type.SchemaDescPtr.html"
title="type parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a>,
tree_builder: <a class="struct" href="struct.TreeBuilder.html"
title="struct parquet::record::reader::TreeBuilder">TreeBuilder</a>,
file_reader: <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="enum"
href="enum.Either.html" title="enum
parquet::record::reader::Either">Either</a><'a>>,
@@ -8,7 +8,7 @@
}</code></pre><details class="toggle top-doc" open><summary
class="hideme"><span>Expand description</span></summary><div
class="docblock"><p>Iterator of <a href="../api/struct.Row.html" title="struct
parquet::record::api::Row"><code>Row</code></a>s.
It is used either for a single row group to iterate over data in that row
group, or
an entire file with auto buffering of all row groups.</p>
-</div></details><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.descr"
class="structfield small-section-header"><a href="#structfield.descr"
class="anchor field">§</a><code>descr: <a class="type"
href="../../schema/types/type.SchemaDescPtr.html" title="type
parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a></code></span><span
id="structfield.tree_builder" class="structfield small-section-header"><a
href="#st [...]
+</div></details><h2 id="fields" class="fields small-section-header">Fields<a
href="#fields" class="anchor">§</a></h2><span id="structfield.descr"
class="structfield small-section-header"><a href="#structfield.descr"
class="anchor field">§</a><code>descr: <a class="type"
href="../../schema/types/type.SchemaDescPtr.html" title="type
parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a></code></span><span
id="structfield.tree_builder" class="structfield small-section-header"><a
href="#st [...]
file_reader: <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="enum"
href="enum.Either.html" title="enum
parquet::record::reader::Either">Either</a><'a>>,
row_iter: <a class="enum"
href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html";
title="enum core::option::Option">Option</a><<a class="struct"
href="struct.ReaderIter.html" title="struct
parquet::record::reader::ReaderIter">ReaderIter</a>>,
descr: <a class="type" href="../../schema/types/type.SchemaDescPtr.html"
title="type parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a>
@@ -29,9 +29,10 @@ when it is None, full file schema is assumed.</p>
root_descr: <a class="type"
href="../../schema/types/type.SchemaDescPtr.html" title="type
parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a>
) -> <a class="type" href="../../errors/type.Result.html" title="type
parquet::errors::Result">Result</a><<a class="type"
href="../../schema/types/type.SchemaDescPtr.html" title="type
parquet::schema::types::SchemaDescPtr">SchemaDescPtr</a>></h4></section></summary><div
class="docblock"><p>Helper method to get schema descriptor for projected
schema.
If projection is None, then full schema is returned.</p>
-</div></details><details class="toggle method-toggle" open><summary><section
id="method.tree_builder" class="method"><a class="src rightside"
href="../../../src/parquet/record/reader.rs.html#753-755">source</a><h4
class="code-header">fn <a href="#method.tree_builder"
class="fn">tree_builder</a>() -> <a class="struct"
href="struct.TreeBuilder.html" title="struct
parquet::record::reader::TreeBuilder">TreeBuilder</a></h4></section></summary><div
class="docblock"><p>Returns common tree bu [...]
+</div></details><details class="toggle method-toggle" open><summary><section
id="method.with_batch_size" class="method"><a class="src rightside"
href="../../../src/parquet/record/reader.rs.html#751-754">source</a><h4
class="code-header">pub fn <a href="#method.with_batch_size"
class="fn">with_batch_size</a>(self, batch_size: <a class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.usize.html";>usize</a>)
-> Self</h4></section></summary><div class="docblock"><p>Sets ba [...]
+</div></details><details class="toggle method-toggle" open><summary><section
id="method.tree_builder" class="method"><a class="src rightside"
href="../../../src/parquet/record/reader.rs.html#759-761">source</a><h4
class="code-header">fn <a href="#method.tree_builder"
class="fn">tree_builder</a>() -> <a class="struct"
href="struct.TreeBuilder.html" title="struct
parquet::record::reader::TreeBuilder">TreeBuilder</a></h4></section></summary><div
class="docblock"><p>Returns common tree bu [...]
from file reader and row group.</p>
-</div></details></div></details></div><h2 id="trait-implementations"
class="small-section-header">Trait Implementations<a
href="#trait-implementations" class="anchor">§</a></h2><div
id="trait-implementations-list"><details class="toggle implementors-toggle"
open><summary><section id="impl-Iterator-for-RowIter%3C'a%3E" class="impl"><a
class="src rightside"
href="../../../src/parquet/record/reader.rs.html#758-793">source</a><a
href="#impl-Iterator-for-RowIter%3C'a%3E" class="anchor">§</a>< [...]
+</div></details></div></details></div><h2 id="trait-implementations"
class="small-section-header">Trait Implementations<a
href="#trait-implementations" class="anchor">§</a></h2><div
id="trait-implementations-list"><details class="toggle implementors-toggle"
open><summary><section id="impl-Iterator-for-RowIter%3C'a%3E" class="impl"><a
class="src rightside"
href="../../../src/parquet/record/reader.rs.html#764-799">source</a><a
href="#impl-Iterator-for-RowIter%3C'a%3E" class="anchor">§</a>< [...]
&mut self
) -> <a class="enum"
href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html";
title="enum core::result::Result">Result</a><[Self::<a
class="associatedtype"
href="https://doc.rust-lang.org/nightly/core/iter/traits/iterator/trait.Iterator.html#associatedtype.Item";
title="type core::iter::traits::iterator::Iterator::Item">Item</a>; <a
class="primitive"
href="https://doc.rust-lang.org/nightly/std/primitive.array.html";>N</a>], <a
class="struct" href="https://doc.rust-lang.o [...]
Self: <a class="trait"
href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html";
title="trait
core::marker::Sized">Sized</a>,</span></h4></section></summary><span
class="item-info"><div class="stab unstable"><span
class="emoji">🔬</span><span>This is a nightly-only experimental API.
(<code>iter_next_chunk</code>)</span></div></span><div
class='docblock'>Advances the iterator and returns an array containing the next
<code>N</code> values. <a href="https://doc.rust-lang.org/ [...]
diff --git a/search-index.js b/search-index.js
index 665dfe1467..e64a1caa71 100644
--- a/search-index.js
+++ b/search-index.js
@@ -23,7 +23,7 @@ var searchIndex = JSON.parse('{\
"flight_test_integration_client":{"doc":"","t":"DNGNGELLLLLLLLLLLLLLLLLLLLLLMLLLLFMMMLLLLLLLLLLLLL","n":["Args","AuthBasicProto","Error","Middleware","Result","Scenario","augment_args","augment_args_for_update","borrow","borrow","borrow_mut","borrow_mut","cast","cast","clone","clone_into","command","command_for_update","fmt","fmt","from","from","from_arg_matches","from_arg_matches_mut","from_cast","from_cast","from_ref","group_id","host","into","into","into_request","into_request","main"
[...]
"flight_test_integration_server":{"doc":"","t":"DNGNGELLLLLLLLLLLLLLLLLLLLLLLLLLFMMLLLLLLLLLLLLL","n":["Args","AuthBasicProto","Error","Middleware","Result","Scenario","augment_args","augment_args_for_update","borrow","borrow","borrow_mut","borrow_mut","cast","cast","clone","clone_into","command","command_for_update","fmt","fmt","from","from","from_arg_matches","from_arg_matches_mut","from_cast","from_cast","from_ref","group_id","into","into","into_request","into_request","main","port","
[...]
"gen":{"doc":"","t":"FF","n":["main","prost_config"],"q":[[0,"gen"],[2,"core::error"],[3,"alloc::boxed"],[4,"core::result"],[5,"prost_build"]],"d":["",""],"i":[0,0],"f":[[[],[[3,[[2,[1]]]]]],[[],4]],"c":[],"p":[[8,"Error",2],[3,"Box",3],[4,"Result",4],[3,"Config",5]]},\
-"parquet":{"doc":"This crate contains the official Native Rust
…","t":"AAAAAAOAAAARCCDRCDLAFAAALLLLALLLLLLAMLLLLLLLLLLMMFFFALLLLLLLLLIDDDDDGDDDIDDFMMMLLLLLLLLLLLLLLLLLLLLLLLLLKLMLKFMMMAMLLLLLLLLLLLLLLMLLLLLLLLMLLLLMMMMLLLLLLLLLLKLMMLLMKMMMMMMMMLLLMMMAMMMFMMLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLIDDLLLLLLKLMLLLLLLLLMKLMLLLLLLDDFLLLLLLLLLLLLLLLLLLLLLLLLLLLLFLLLLLLLMLLMLLMLLLLLLLLLLDEDDDNDNGLMLLLLLLLLLLLLMMALLLLLLLLLLMLLLLLLLLLLLLLLLLLFFLFFLFFFLMLLLLLLLLLLMAMLLLLMLLLLLLLLLLLLLLLLLLLLLLFFLLFMMD
[...]
+"parquet":{"doc":"This crate contains the official Native Rust
…","t":"AAAAAAOAAAARCCDRCDLAFAAALLLLALLLLLLAMLLLLLLLLLLMMFFFALLLLLLLLLIDDDDDGDDDIDDFMMMLLLLLLLLLLLLLLLLLLLLLLLLLKLMLKFMMMAMLLLLLLLLLLLLLLMLLLLLLLLMLLLLMMMMLLLLLLLLLLKLMMLLMKMMMMMMMMLLLMMMAMMMFMMLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLLIDDLLLLLLKLMLLLLLLLLMKLMLLLLLLDDFLLLLLLLLLLLLLLLLLLLLLLLLLLLLFLLLLLLLMLLMLLMLLLLLLLLLLDEDDDNDNGLMLLLLLLLLLLLLMMALLLLLLLLLLMLLLLLLLLLLLLLLLLLFFLFFLFFFLMLLLLLLLLLLMAMLLLLMLLLLLLLLLLLLLLLLLLLLLLFFLLFMMD
[...]
"parquet_concat":{"doc":"Binary that concatenates the column data of one or
more
…","t":"DLLLLLLLLLLLLLMLFMLLLLLL","n":["Args","augment_args","augment_args_for_update","borrow","borrow_mut","cast","command","command_for_update","fmt","from","from_arg_matches","from_arg_matches_mut","from_cast","group_id","input","into","main","output","run","try_from","try_into","type_id","update_from_arg_matches","update_from_arg_matches_mut"],"q":[[0,"parquet_concat"],[24,"clap_builder::builder::comman
[...]
"parquet_derive":{"doc":"","t":"YANNNDNNNEENNNLLLLLLLLLLLLLLLLLLLLLLLLLMLLLLMLLLLLLLLLMLLLLLLMLLLL","n":["ParquetRecordWriter","parquet_field","Array","ChronoNaiveDate","ChronoNaiveDateTime","Field","Option","Reference","Slice","ThirdPartyType","Type","TypePath","Uuid","Vec","borrow","borrow","borrow","borrow_mut","borrow_mut","borrow_mut","column_writer","converted_type","copied_direct_vals","eq","eq","eq","fmt","fmt","fmt","from","from","from","from","from","from_type","from_type_array
[...]
"parquet_derive_test":{"doc":"","t":"DMMMMLLMMMMMMLMMLLMMLMMMMMMMMMMMLLLM","n":["ACompleteRecord","a_bool","a_borrowed_string","a_str","a_string","borrow","borrow_mut","borrowed_byte_vec","borrowed_maybe_a_str","borrowed_maybe_a_string","borrowed_maybe_borrowed_byte_vec","borrowed_maybe_byte_vec","byte_vec","cast","double","float","from","from_cast","i16","i32","into","isize","maybe_a_str","maybe_a_string","maybe_byte_vec","maybe_double","maybe_float","maybe_i16","maybe_u32","maybe_u8","
[...]
diff --git a/src/parquet/record/reader.rs.html
b/src/parquet/record/reader.rs.html
index a518ccf0fa..6675c3107a 100644
--- a/src/parquet/record/reader.rs.html
+++ b/src/parquet/record/reader.rs.html
@@ -1633,6 +1633,12 @@
<a href="#1633" id="1633">1633</a>
<a href="#1634" id="1634">1634</a>
<a href="#1635" id="1635">1635</a>
+<a href="#1636" id="1636">1636</a>
+<a href="#1637" id="1637">1637</a>
+<a href="#1638" id="1638">1638</a>
+<a href="#1639" id="1639">1639</a>
+<a href="#1640" id="1640">1640</a>
+<a href="#1641" id="1641">1641</a>
</pre></div><pre class="rust"><code><span class="comment">// Licensed to the
Apache Software Foundation (ASF) under one
// or more contributor license agreements. See the NOTICE file
// distributed with this work for additional information
@@ -2382,6 +2388,12 @@
}
}
+ <span class="doccomment">/// Sets batch size for this row iter.
+ </span><span class="kw">pub fn </span>with_batch_size(<span
class="kw-2">mut </span><span class="self">self</span>, batch_size: usize)
-> <span class="self">Self </span>{
+ <span class="self">self</span>.tree_builder = <span
class="self">self</span>.tree_builder.with_batch_size(batch_size);
+ <span class="self">self
+ </span>}
+
<span class="doccomment">/// Returns common tree builder, so the same
settings are applied to both iterators
/// from file reader and row group.
</span><span class="attr">#[inline]
