org.apache.arrow.flight.example

Class ExampleFlightServer

java.lang.Object

org.apache.arrow.flight.example.ExampleFlightServer

All Implemented Interfaces:

AutoCloseable

public class ExampleFlightServer
extends Object
implements AutoCloseable

An Example Flight Server that provides access to the InMemoryStore. Used for integration testing.

Constructor Summary

Constructors

Constructor and Description
ExampleFlightServer(BufferAllocator allocator, Location location) Constructs a new instance using Allocator for allocating buffer storage that binds to the given location.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination()
void	close()
Location	getLocation()
int	getPort()
InMemoryStore	getStore()
static void	main(String[] args) Main method starts the server listening to localhost:12233.
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExampleFlightServer

public ExampleFlightServer(BufferAllocator allocator,
                           Location location)

Constructs a new instance using Allocator for allocating buffer storage that binds to the given location.

Method Detail

getLocation

public Location getLocation()

getPort

public int getPort()

start

public void start()
           throws IOException

Throws:

IOException

awaitTermination

public void awaitTermination()
                      throws InterruptedException

Throws:

InterruptedException

getStore

public InMemoryStore getStore()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Main method starts the server listening to localhost:12233.

Throws:

Exception