org.apache.arrow.flight.example

Class FlightHolder

java.lang.Object

org.apache.arrow.flight.example.FlightHolder

All Implemented Interfaces:

AutoCloseable

public class FlightHolder
extends Object
implements AutoCloseable

A logical collection of streams sharing the same schema.

Constructor Summary

Constructors

Constructor and Description
FlightHolder(BufferAllocator allocator, FlightDescriptor descriptor, Schema schema, DictionaryProvider dictionaryProvider) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
Stream.StreamCreator	addStream(Schema schema) Adds a new streams which clients can populate via the returned object.
void	close()
FlightInfo	getFlightInfo(Location l) List all available streams as being available at l.
Stream	getStream(ExampleTicket ticket) Returns the stream based on the ordinal of ExampleTicket.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlightHolder

public FlightHolder(BufferAllocator allocator,
                    FlightDescriptor descriptor,
                    Schema schema,
                    DictionaryProvider dictionaryProvider)

Creates a new instance.

Parameters:

allocator - The allocator to use for allocating buffers to store data.

descriptor - The descriptor for the streams.

schema - The schema for the stream.

dictionaryProvider - The dictionary provider for the stream.

Method Detail

getStream

public Stream getStream(ExampleTicket ticket)

Returns the stream based on the ordinal of ExampleTicket.

addStream

public Stream.StreamCreator addStream(Schema schema)

Adds a new streams which clients can populate via the returned object.

getFlightInfo

public FlightInfo getFlightInfo(Location l)

List all available streams as being available at l.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception