Module org.apache.arrow.flight.core

Package org.apache.arrow.flight.impl

Class FlightServiceGrpc

java.lang.Object

org.apache.arrow.flight.impl.FlightServiceGrpc

public final class FlightServiceGrpc
extends Object

 A flight service is an endpoint for retrieving or storing Arrow data. A
 flight service can expose one or more predefined endpoints that can be
 accessed using the Arrow Flight Protocol. Additionally, a flight service
 can expose a set of actions that are available.
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FlightServiceGrpc.AsyncService	A flight service is an endpoint for retrieving or storing Arrow data.
static final class	FlightServiceGrpc.FlightServiceBlockingStub	A stub to allow clients to do limited synchronous rpc calls to service FlightService.
static final class	FlightServiceGrpc.FlightServiceBlockingV2Stub	A stub to allow clients to do synchronous rpc calls to service FlightService.
static final class	FlightServiceGrpc.FlightServiceFutureStub	A stub to allow clients to do ListenableFuture-style rpc calls to service FlightService.
static class	FlightServiceGrpc.FlightServiceImplBase	Base class for the server implementation of the service FlightService.
static final class	FlightServiceGrpc.FlightServiceStub	A stub to allow clients to do asynchronous rpc calls to service FlightService.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static final io.grpc.ServerServiceDefinition	bindService(FlightServiceGrpc.AsyncService service)
static io.grpc.MethodDescriptor<Flight.Action,Flight.Result>	getDoActionMethod()
static io.grpc.MethodDescriptor<Flight.FlightData,Flight.FlightData>	getDoExchangeMethod()
static io.grpc.MethodDescriptor<Flight.Ticket,Flight.FlightData>	getDoGetMethod()
static io.grpc.MethodDescriptor<Flight.FlightData,Flight.PutResult>	getDoPutMethod()
static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.FlightInfo>	getGetFlightInfoMethod()
static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.SchemaResult>	getGetSchemaMethod()
static io.grpc.MethodDescriptor<Flight.HandshakeRequest,Flight.HandshakeResponse>	getHandshakeMethod()
static io.grpc.MethodDescriptor<Flight.Empty,Flight.ActionType>	getListActionsMethod()
static io.grpc.MethodDescriptor<Flight.Criteria,Flight.FlightInfo>	getListFlightsMethod()
static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.PollInfo>	getPollFlightInfoMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static FlightServiceGrpc.FlightServiceBlockingStub	newBlockingStub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports unary and streaming output calls on the service
static FlightServiceGrpc.FlightServiceBlockingV2Stub	newBlockingV2Stub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports all types of calls on the service
static FlightServiceGrpc.FlightServiceFutureStub	newFutureStub(io.grpc.Channel channel)	Creates a new ListenableFuture-style stub that supports unary calls on the service
static FlightServiceGrpc.FlightServiceStub	newStub(io.grpc.Channel channel)	Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Details

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

• Constant Field Values

Method Details

getHandshakeMethod

public static io.grpc.MethodDescriptor<Flight.HandshakeRequest,Flight.HandshakeResponse> getHandshakeMethod()

getListFlightsMethod

public static io.grpc.MethodDescriptor<Flight.Criteria,Flight.FlightInfo> getListFlightsMethod()

getGetFlightInfoMethod

public static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.FlightInfo> getGetFlightInfoMethod()

getPollFlightInfoMethod

public static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.PollInfo> getPollFlightInfoMethod()

getGetSchemaMethod

public static io.grpc.MethodDescriptor<Flight.FlightDescriptor,Flight.SchemaResult> getGetSchemaMethod()

getDoGetMethod

public static io.grpc.MethodDescriptor<Flight.Ticket,Flight.FlightData> getDoGetMethod()

getDoPutMethod

public static io.grpc.MethodDescriptor<Flight.FlightData,Flight.PutResult> getDoPutMethod()

getDoExchangeMethod

public static io.grpc.MethodDescriptor<Flight.FlightData,Flight.FlightData> getDoExchangeMethod()

getDoActionMethod

public static io.grpc.MethodDescriptor<Flight.Action,Flight.Result> getDoActionMethod()

getListActionsMethod

public static io.grpc.MethodDescriptor<Flight.Empty,Flight.ActionType> getListActionsMethod()

newStub

public static FlightServiceGrpc.FlightServiceStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingV2Stub

public static FlightServiceGrpc.FlightServiceBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports all types of calls on the service

newBlockingStub

public static FlightServiceGrpc.FlightServiceBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static FlightServiceGrpc.FlightServiceFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(FlightServiceGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()