Module org.apache.arrow.flight.core

Package org.apache.arrow.flight

Class FlightClient.ExchangeReaderWriter

java.lang.Object

org.apache.arrow.flight.FlightClient.ExchangeReaderWriter

All Implemented Interfaces:

AutoCloseable

Enclosing class:

FlightClient

public static class FlightClient.ExchangeReaderWriter
extends Object
implements AutoCloseable

A pair of a reader and a writer for a DoExchange call.

Method Summary

Modifier and Type	Method	Description
void	close()	Shut down the streams in this call.
FlightStream	getReader()	Get the reader for the call.
void	getResult()	Make sure stream is drained.
FlightClient.ClientStreamListener	getWriter()	Get the writer for the call.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getReader

public FlightStream getReader()

Get the reader for the call.

getWriter

public FlightClient.ClientStreamListener getWriter()

Get the writer for the call.

getResult

public void getResult()

Make sure stream is drained. You must call this to be notified of any errors that may have happened after the exchange is complete. This should be called after `getWriter().completed()` and instead of `getWriter().getResult()`.

close

public void close()
           throws Exception

Shut down the streams in this call.

Specified by:

close in interface AutoCloseable

Throws:

Exception