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 and Description
void	close() Shut down the streams in this call.
FlightStream	getReader() Get the reader for the call.
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 Detail

getReader

public FlightStream getReader()

Get the reader for the call.

getWriter

public FlightClient.ClientStreamListener getWriter()

Get the writer for the call.

close

public void close()
           throws Exception

Shut down the streams in this call.

Specified by:

close in interface AutoCloseable

Throws:

Exception