From 72f746f7ebe03fcf6da903e771e7553c7dac6505 Mon Sep 17 00:00:00 2001
From: Neville Dipale <nevilledips@gmail.com>
Date: Mon, 27 Jan 2020 08:16:36 +0200
Subject: [PATCH 1/2] [Rust] Update arrow and parquet README

---
 rust/arrow/README.md   | 8 ++++----
 rust/parquet/README.md | 3 +--
 2 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/rust/arrow/README.md b/rust/arrow/README.md
index eb5013a9e77..40a7db4f3c1 100644
--- a/rust/arrow/README.md
+++ b/rust/arrow/README.md
@@ -19,22 +19,22 @@
 
 # Native Rust implementation of Apache Arrow
 
-[![Build Status](https://travis-ci.org/apache/arrow.svg?branch=master)](https://travis-ci.org/apache/arrow)
 [![Coverage Status](https://coveralls.io/repos/github/apache/arrow/badge.svg)](https://coveralls.io/github/apache/arrow)
 
 ## Status
 
 This is a native Rust implementation of Apache Arrow. Currently the project
-is developed and tested against nightly Rust.  The current status is:
+is developed and tested against nightly Rust. The current status is:
 
 - [x] Primitive Arrays
 - [x] List Arrays
 - [x] Struct Arrays
 - [x] CSV Reader
-- [ ] CSV Writer
+- [X] CSV Writer
+- [X] JSON Reader
 - [ ] Parquet Reader
 - [ ] Parquet Writer
-- [ ] Arrow IPC
+- [X] Arrow IPC
 - [ ] Interop tests with other implementations
 
 ## Examples
diff --git a/rust/parquet/README.md b/rust/parquet/README.md
index 40aad6c462e..5e8185e30ae 100644
--- a/rust/parquet/README.md
+++ b/rust/parquet/README.md
@@ -58,7 +58,7 @@ version is available. Then simply update version of `parquet-format` crate in Ca
 - [X] Read support
   - [X] Primitive column value readers
   - [X] Row record reader
-  - [ ] Arrow record reader
+  - [X] Arrow record reader
 - [X] Statistics support
 - [X] Write support
   - [X] Primitive column value writers
@@ -66,7 +66,6 @@ version is available. Then simply update version of `parquet-format` crate in Ca
   - [ ] Arrow record writer
 - [ ] Predicate pushdown
 - [ ] Parquet format 2.5 support
-- [ ] HDFS support
 
 ## Requirements
 - Rust nightly

From 56f3db91322c01bccd9cfdff3339e04b7154c04e Mon Sep 17 00:00:00 2001
From: Neville Dipale <nevilledips@gmail.com>
Date: Wed, 1 Apr 2020 19:47:47 +0200
Subject: [PATCH 2/2] ARROW-8308: [Rust] Impl DoExchange on examples

---
 rust/arrow-flight/examples/server.rs      | 9 +++++++++
 rust/datafusion/examples/flight_server.rs | 9 +++++++++
 2 files changed, 18 insertions(+)

diff --git a/rust/arrow-flight/examples/server.rs b/rust/arrow-flight/examples/server.rs
index b71ad78b3bb..6651e3919dd 100644
--- a/rust/arrow-flight/examples/server.rs
+++ b/rust/arrow-flight/examples/server.rs
@@ -46,6 +46,8 @@ impl FlightService for FlightServiceImpl {
     >;
     type ListActionsStream =
         Pin<Box<dyn Stream<Item = Result<ActionType, Status>> + Send + Sync + 'static>>;
+    type DoExchangeStream =
+        Pin<Box<dyn Stream<Item = Result<FlightData, Status>> + Send + Sync + 'static>>;
 
     async fn handshake(
         &self,
@@ -102,6 +104,13 @@ impl FlightService for FlightServiceImpl {
     ) -> Result<Response<Self::ListActionsStream>, Status> {
         Err(Status::unimplemented("Not yet implemented"))
     }
+
+    async fn do_exchange(
+        &self,
+        _request: Request<Streaming<FlightData>>,
+    ) -> Result<Response<Self::DoExchangeStream>, Status> {
+        Err(Status::unimplemented("Not yet implemented"))
+    }
 }
 
 #[tokio::main]
diff --git a/rust/datafusion/examples/flight_server.rs b/rust/datafusion/examples/flight_server.rs
index 30afa5d5377..b4592ba1c0d 100644
--- a/rust/datafusion/examples/flight_server.rs
+++ b/rust/datafusion/examples/flight_server.rs
@@ -54,6 +54,8 @@ impl FlightService for FlightServiceImpl {
     >;
     type ListActionsStream =
         Pin<Box<dyn Stream<Item = Result<ActionType, Status>> + Send + Sync + 'static>>;
+    type DoExchangeStream =
+        Pin<Box<dyn Stream<Item = Result<FlightData, Status>> + Send + Sync + 'static>>;
 
     async fn get_schema(
         &self,
@@ -163,6 +165,13 @@ impl FlightService for FlightServiceImpl {
     ) -> Result<Response<Self::ListActionsStream>, Status> {
         Err(Status::unimplemented("Not yet implemented"))
     }
+
+    async fn do_exchange(
+        &self,
+        _request: Request<Streaming<FlightData>>,
+    ) -> Result<Response<Self::DoExchangeStream>, Status> {
+        Err(Status::unimplemented("Not yet implemented"))
+    }
 }
 
 fn to_tonic_err(e: &datafusion::error::ExecutionError) -> Status {