Skip navigation links
A B C D E F G H I K L M N O P R S T U V W 

A

accept(CallHeaders) - Method in class org.apache.arrow.flight.auth2.BasicAuthCredentialWriter
 
accept(CallHeaders) - Method in class org.apache.arrow.flight.auth2.BearerCredentialWriter
 
acceptPut(FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener<PutResult>) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
acceptPut(FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener<PutResult>) - Method in interface org.apache.arrow.flight.FlightProducer
Accept uploaded data for a particular stream.
acceptPut(FlightProducer.CallContext, FlightStream, FlightProducer.StreamListener<PutResult>) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
Action - Class in org.apache.arrow.flight
An opaque action for the service to perform.
Action(String) - Constructor for class org.apache.arrow.flight.Action
 
Action(String, byte[]) - Constructor for class org.apache.arrow.flight.Action
 
ActionType - Class in org.apache.arrow.flight
POJO wrapper around protocol specifics for Flight actions.
ActionType(String, String) - Constructor for class org.apache.arrow.flight.ActionType
Construct a new instance.
add(ArrowRecordBatch) - Method in class org.apache.arrow.flight.example.Stream.StreamCreator
 
add(ByteBuf, OutputStream, boolean) - Static method in class org.apache.arrow.flight.grpc.AddWritableBuffer
Add the provided ByteBuf to the gRPC BufferChainOutputStream if possible, else copy the buffer to the stream.
addAllEndpoint(Iterable<? extends Flight.FlightEndpoint>) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addAllLocation(Iterable<? extends Flight.Location>) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addAllPath(Iterable<String>) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
addEndpoint(Flight.FlightEndpoint) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addEndpoint(int, Flight.FlightEndpoint) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addEndpoint(Flight.FlightEndpoint.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addEndpoint(int, Flight.FlightEndpoint.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addEndpointBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addEndpointBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
addLocation(Flight.Location) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addLocation(int, Flight.Location) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addLocation(Flight.Location.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addLocation(int, Flight.Location.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addLocationBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addLocationBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
addPath(String) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
addPathBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
addStream(Schema) - Method in class org.apache.arrow.flight.example.FlightHolder
Adds a new streams which clients can populate via the returned object.
AddWritableBuffer - Class in org.apache.arrow.flight.grpc
Allow a user to add a ByteBuf based InputStream directly into GRPC WritableBuffer to avoid an extra copy.
AddWritableBuffer() - Constructor for class org.apache.arrow.flight.grpc.AddWritableBuffer
 
ALL - Static variable in class org.apache.arrow.flight.Criteria
 
allocator(BufferAllocator) - Method in class org.apache.arrow.flight.FlightClient.Builder
 
allocator(BufferAllocator) - Method in class org.apache.arrow.flight.FlightServer.Builder
 
ALREADY_EXISTS - Static variable in class org.apache.arrow.flight.CallStatus
 
APP_METADATA_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightData
 
APP_METADATA_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.PutResult
 
appendToOutgoingHeaders(CallHeaders) - Method in interface org.apache.arrow.flight.auth2.CallHeaderAuthenticator.AuthResult
Appends a header to the outgoing call headers.
applyRequestMetadata(CallCredentials.RequestInfo, Executor, CallCredentials.MetadataApplier) - Method in class org.apache.arrow.flight.grpc.CallCredentialAdapter
 
AsyncPutListener - Class in org.apache.arrow.flight
A handler for server-sent application metadata messages during a Flight DoPut operation.
AsyncPutListener() - Constructor for class org.apache.arrow.flight.AsyncPutListener
 
Auth2Constants - Class in org.apache.arrow.flight.auth2
Constants used in authorization of flight connections.
AuthConstants - Class in org.apache.arrow.flight.auth
Constants used in authorization of flight connections.
authenticate(ClientAuthHandler.ClientAuthSender, Iterator<byte[]>) - Method in class org.apache.arrow.flight.auth.BasicClientAuthHandler
 
authenticate(ServerAuthHandler.ServerAuthSender, Iterator<byte[]>) - Method in class org.apache.arrow.flight.auth.BasicServerAuthHandler
 
authenticate(ClientAuthHandler.ClientAuthSender, Iterator<byte[]>) - Method in interface org.apache.arrow.flight.auth.ClientAuthHandler
Handle the initial handshake with the server.
authenticate(ServerAuthHandler.ServerAuthSender, Iterator<byte[]>) - Method in interface org.apache.arrow.flight.auth.ServerAuthHandler
Handle the initial handshake with the client.
authenticate(CallHeaders) - Method in class org.apache.arrow.flight.auth2.BasicCallHeaderAuthenticator
 
authenticate(CallHeaders) - Method in class org.apache.arrow.flight.auth2.BearerTokenAuthenticator
 
authenticate(CallHeaders) - Method in interface org.apache.arrow.flight.auth2.CallHeaderAuthenticator
Validate the auth headers sent by the client.
authenticate(ClientAuthHandler, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Authenticates against the Flight service.
authenticateBasic(String, String) - Method in class org.apache.arrow.flight.FlightClient
Authenticates with a username and password.
authenticateBasicToken(String, String) - Method in class org.apache.arrow.flight.FlightClient
Authenticates with a username and password.
authHandler(ServerAuthHandler) - Method in class org.apache.arrow.flight.FlightServer.Builder
Set the authentication handler.
AUTHORIZATION_HEADER - Static variable in class org.apache.arrow.flight.auth2.Auth2Constants
 
AuthUtilities - Class in org.apache.arrow.flight.auth2
Utility class for completing the auth process.
awaitTermination() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
awaitTermination() - Method in class org.apache.arrow.flight.FlightServer
Block until the server shuts down.
awaitTermination(long, TimeUnit) - Method in class org.apache.arrow.flight.FlightServer
Wait for the server to shut down with a timeout.
awaitTermination(long, TimeUnit) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 

B

BackpressureStrategy - Interface in org.apache.arrow.flight
Helper interface to dynamically handle backpressure when implementing FlightProducers.
BackpressureStrategy.CallbackBackpressureStrategy - Class in org.apache.arrow.flight
A back pressure strategy that uses callbacks to notify when the client is ready or cancelled.
BackpressureStrategy.WaitResult - Enum in org.apache.arrow.flight
The state of the client after a call to waitForListener.
BASIC_PREFIX - Static variable in class org.apache.arrow.flight.auth2.Auth2Constants
 
BasicAuthCredentialWriter - Class in org.apache.arrow.flight.auth2
Client credentials that use a username and password.
BasicAuthCredentialWriter(String, String) - Constructor for class org.apache.arrow.flight.auth2.BasicAuthCredentialWriter
 
BasicCallHeaderAuthenticator - Class in org.apache.arrow.flight.auth2
A ServerAuthHandler for username/password authentication.
BasicCallHeaderAuthenticator(BasicCallHeaderAuthenticator.CredentialValidator) - Constructor for class org.apache.arrow.flight.auth2.BasicCallHeaderAuthenticator
 
BasicCallHeaderAuthenticator.CredentialValidator - Interface in org.apache.arrow.flight.auth2
Interface that this handler delegates to for validating the incoming headers.
BasicClientAuthHandler - Class in org.apache.arrow.flight.auth
A client auth handler that supports username and password.
BasicClientAuthHandler(String, String) - Constructor for class org.apache.arrow.flight.auth.BasicClientAuthHandler
 
BasicServerAuthHandler - Class in org.apache.arrow.flight.auth
A ServerAuthHandler for username/password authentication.
BasicServerAuthHandler(BasicServerAuthHandler.BasicAuthValidator) - Constructor for class org.apache.arrow.flight.auth.BasicServerAuthHandler
 
BasicServerAuthHandler.BasicAuthValidator - Interface in org.apache.arrow.flight.auth
Interface that this handler delegates for determining if credentials are valid.
BEARER_PREFIX - Static variable in class org.apache.arrow.flight.auth2.Auth2Constants
 
BearerCredentialWriter - Class in org.apache.arrow.flight.auth2
Client credentials that use a bearer token.
BearerCredentialWriter(String) - Constructor for class org.apache.arrow.flight.auth2.BearerCredentialWriter
 
BearerTokenAuthenticator - Class in org.apache.arrow.flight.auth2
Partial implementation of CallHeaderAuthenticator for bearer-token based authentication.
BearerTokenAuthenticator(CallHeaderAuthenticator) - Constructor for class org.apache.arrow.flight.auth2.BearerTokenAuthenticator
 
bindService() - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
 
BODY_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Action
 
BODY_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Result
 
build() - Method in class org.apache.arrow.flight.FlightClient.Builder
Create the client from this builder.
build() - Method in class org.apache.arrow.flight.FlightServer.Builder
Create the server for this builder.
build() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
build() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
build(Channel, CallOptions) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
 
build(Channel, CallOptions) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceFutureStub
 
build(Channel, CallOptions) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
 
build() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
build() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
builder() - Static method in class org.apache.arrow.flight.FlightClient
Create a builder for a Flight client.
builder(BufferAllocator, Location) - Static method in class org.apache.arrow.flight.FlightClient
Create a builder for a Flight client.
builder() - Static method in class org.apache.arrow.flight.FlightServer
Create a builder for a Flight server.
builder(BufferAllocator, Location, FlightProducer) - Static method in class org.apache.arrow.flight.FlightServer
Create a builder for a Flight server.
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
buildPartial() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 

C

CallbackBackpressureStrategy() - Constructor for class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
 
CallCredentialAdapter - Class in org.apache.arrow.flight.grpc
Adapter class to utilize a CredentialWriter to implement Grpc CallCredentials.
CallCredentialAdapter(Consumer<CallHeaders>) - Constructor for class org.apache.arrow.flight.grpc.CallCredentialAdapter
 
CallHeaderAuthenticator - Interface in org.apache.arrow.flight.auth2
Interface for Server side authentication handlers.
CallHeaderAuthenticator.AuthResult - Interface in org.apache.arrow.flight.auth2
Encapsulates the result of the CallHeaderAuthenticator analysis of headers.
CallHeaders - Interface in org.apache.arrow.flight
A set of metadata key value pairs for a call (request or response).
CallInfo - Class in org.apache.arrow.flight
A description of a Flight call for middleware to inspect.
CallInfo(FlightMethod) - Constructor for class org.apache.arrow.flight.CallInfo
 
CallOption - Interface in org.apache.arrow.flight
Per-call RPC options.
CallOptions - Class in org.apache.arrow.flight
Common call options.
CallOptions() - Constructor for class org.apache.arrow.flight.CallOptions
 
CallOptions.GrpcCallOption - Interface in org.apache.arrow.flight
CallOptions specific to GRPC stubs.
CallStatus - Class in org.apache.arrow.flight
The result of a Flight RPC, consisting of a status code with an optional description and/or exception that led to the status.
CallStatus(FlightStatusCode, Throwable, String, ErrorFlightMetadata) - Constructor for class org.apache.arrow.flight.CallStatus
Create a new status.
CallStatus(FlightStatusCode) - Constructor for class org.apache.arrow.flight.CallStatus
Create a new status with no cause or description.
cancel(String, Throwable) - Method in class org.apache.arrow.flight.FlightStream
Cancels sending the stream to a client.
cancel(String, Throwable) - Method in interface org.apache.arrow.flight.FlightStream.Cancellable
 
cancelCallback() - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
Callback to execute when the listener is cancelled.
CANCELLED - Static variable in class org.apache.arrow.flight.CallStatus
 
cause() - Method in class org.apache.arrow.flight.CallStatus
The exception that led to this result.
clear() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
clear() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
clear() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
clear() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
clearAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Application-defined metadata.
clearAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
bytes app_metadata = 1;
clearBody() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
bytes body = 2;
clearBody() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
bytes body = 1;
clearCmd() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
Opaque value used to express a command.
clearDataBody() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The actual batch of Arrow data.
clearDataHeader() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Header for message data as described in Message.fbs::Message.
clearDefinition() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
clearDescription() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string description = 2;
clearEnd() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
exclusive end
clearEndpoint() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
clearExpression() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
bytes expression = 1;
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
clearFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
clearFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
clearLocation() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
clearPassword() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string password = 3;
clearPath() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
clearPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
Arbitrary auth/handshake info.
clearPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
Arbitrary auth/handshake info.
clearProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
A defined protocol version
clearProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
A defined protocol version
clearRecordsPerBatch() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 records_per_batch = 4;
clearRecordsPerStream() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int64 records_per_stream = 3;
clearSchema() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
schema of the dataset as described in Schema.fbs::Schema.
clearSchema() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
schema of the dataset as described in Schema.fbs::Schema.
clearSchema() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
bytes schema = 1;
clearStart() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
inclusive start
clearStreamCount() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 stream_count = 2;
clearTicket() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
clearTicket() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
bytes ticket = 1;
clearTotalBytes() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
int64 total_bytes = 5;
clearTotalRecords() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
Set these to -1 if unknown.
clearType() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
string type = 1;
clearType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string type = 1;
clearType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
clearUri() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
string uri = 1;
clearUsername() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string username = 2;
ClientAuthHandler - Interface in org.apache.arrow.flight.auth
Implement authentication for Flight on the client side.
ClientAuthHandler.ClientAuthSender - Interface in org.apache.arrow.flight.auth
A communication channel to the server during initial connection.
ClientAuthInterceptor - Class in org.apache.arrow.flight.auth
GRPC client intercepter that handles authentication with the server.
ClientAuthInterceptor() - Constructor for class org.apache.arrow.flight.auth.ClientAuthInterceptor
 
ClientAuthWrapper - Class in org.apache.arrow.flight.auth
Utility class for performing authorization over using a GRPC stub.
ClientAuthWrapper() - Constructor for class org.apache.arrow.flight.auth.ClientAuthWrapper
 
ClientBearerHeaderHandler - Class in org.apache.arrow.flight.auth2
A client header handler that parses the incoming headers for a bearer token.
ClientBearerHeaderHandler() - Constructor for class org.apache.arrow.flight.auth2.ClientBearerHeaderHandler
 
clientCertificate(InputStream, InputStream) - Method in class org.apache.arrow.flight.FlightClient.Builder
Set the trusted TLS certificates.
ClientCookieMiddleware - Class in org.apache.arrow.flight.client
A client middleware for receiving and sending cookie information.
ClientCookieMiddleware.Factory - Class in org.apache.arrow.flight.client
Factory used within FlightClient.
ClientHandshakeWrapper - Class in org.apache.arrow.flight.auth2
Utility class for executing a handshake with a FlightServer.
ClientHandshakeWrapper() - Constructor for class org.apache.arrow.flight.auth2.ClientHandshakeWrapper
 
ClientHeaderHandler - Interface in org.apache.arrow.flight.auth2
Interface for client side header parsing and conversion to CredentialCallOption.
ClientIncomingAuthHeaderMiddleware - Class in org.apache.arrow.flight.auth2
Middleware for capturing bearer tokens sent back from the Flight server.
ClientIncomingAuthHeaderMiddleware.Factory - Class in org.apache.arrow.flight.auth2
Factory used within FlightClient.
ClientInterceptorAdapter - Class in org.apache.arrow.flight.grpc
An adapter between Flight client middleware and gRPC interceptors.
ClientInterceptorAdapter(List<FlightClientMiddleware.Factory>) - Constructor for class org.apache.arrow.flight.grpc.ClientInterceptorAdapter
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
clone() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
clone() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
clone() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
close() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
close() - Method in class org.apache.arrow.flight.example.FlightHolder
 
close() - Method in class org.apache.arrow.flight.example.InMemoryStore
 
close() - Method in class org.apache.arrow.flight.example.Stream
 
close() - Method in class org.apache.arrow.flight.FlightClient
Shut down this client.
close() - Method in class org.apache.arrow.flight.FlightClient.ExchangeReaderWriter
Shut down the streams in this call.
close() - Method in class org.apache.arrow.flight.FlightServer
Shutdown the server, waits for up to 6 seconds for successful shutdown before returning.
close() - Method in class org.apache.arrow.flight.FlightStream
Closes the stream (freeing any existing resources).
close() - Method in class org.apache.arrow.flight.PutResult
 
close() - Method in class org.apache.arrow.flight.SyncPutListener
 
CMD_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
CMD_VALUE - Static variable in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
An opaque command to generate a dataset.
code() - Method in class org.apache.arrow.flight.CallStatus
The status code describing the result of the RPC.
command(byte[]) - Static method in class org.apache.arrow.flight.FlightDescriptor
 
complete() - Method in class org.apache.arrow.flight.example.Stream.StreamCreator
Complete building the stream (no more batches can be added).
completed() - Method in interface org.apache.arrow.flight.OutboundStreamListener
Indicate that transmission is finished.
containsKey(String) - Method in interface org.apache.arrow.flight.CallHeaders
Check whether the given metadata key is present.
containsKey(String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
containsKey(String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
containsKey(String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
ContextPropagatingExecutorService - Class in org.apache.arrow.flight.grpc
An ExecutorService that propagates the Context.
ContextPropagatingExecutorService(ExecutorService) - Constructor for class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
CredentialCallOption - Class in org.apache.arrow.flight.grpc
Method option for supplying credentials to method calls.
CredentialCallOption(Consumer<CallHeaders>) - Constructor for class org.apache.arrow.flight.grpc.CredentialCallOption
 
Criteria - Class in org.apache.arrow.flight
An opaque object that can be used to filter a list of streams available from a server.
Criteria(byte[]) - Constructor for class org.apache.arrow.flight.Criteria
 

D

DATA_BODY_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightData
 
DATA_HEADER_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightData
 
DEFINITION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
description() - Method in class org.apache.arrow.flight.CallStatus
A description of the result.
DESCRIPTION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.ActionType
 
deserialize(ByteBuffer) - Static method in class org.apache.arrow.flight.FlightDescriptor
Parse the serialized form of this protocol message.
deserialize(ByteBuffer) - Static method in class org.apache.arrow.flight.FlightInfo
Parse the serialized form of this protocol message.
deserialize(ByteBuffer) - Static method in class org.apache.arrow.flight.Ticket
Parse the serialized form of this protocol message.
doAction(FlightProducer.CallContext, Action, FlightProducer.StreamListener<Result>) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
doAction(Action, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Performs an action on the Flight service.
doAction(FlightProducer.CallContext, Action, FlightProducer.StreamListener<Result>) - Method in interface org.apache.arrow.flight.FlightProducer
Generic handler for application-defined RPCs.
doAction(Flight.Action) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
Flight services can support an arbitrary number of simple actions in addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut operations that are potentially available.
doAction(Flight.Action, StreamObserver<Flight.Result>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Flight services can support an arbitrary number of simple actions in addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut operations that are potentially available.
doAction(Flight.Action, StreamObserver<Flight.Result>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Flight services can support an arbitrary number of simple actions in addition to the possible ListFlights, GetFlightInfo, DoGet, DoPut operations that are potentially available.
doAction(FlightProducer.CallContext, Action, FlightProducer.StreamListener<Result>) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
doClientAuth(ClientAuthHandler, FlightServiceGrpc.FlightServiceStub) - Static method in class org.apache.arrow.flight.auth.ClientAuthWrapper
Do client auth for a client.
doClientHandshake(FlightServiceGrpc.FlightServiceStub) - Static method in class org.apache.arrow.flight.auth2.ClientHandshakeWrapper
Do handshake for a client.
doExchange(FlightDescriptor, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Initiate a bidirectional data exchange with the server.
doExchange(FlightProducer.CallContext, FlightStream, FlightProducer.ServerStreamListener) - Method in interface org.apache.arrow.flight.FlightProducer
 
doExchange(StreamObserver<Flight.FlightData>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Open a bidirectional data channel for a given descriptor.
doExchange(StreamObserver<Flight.FlightData>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Open a bidirectional data channel for a given descriptor.
doGet(Flight.Ticket) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
Retrieve a single stream associated with a particular descriptor associated with the referenced ticket.
doGet(Flight.Ticket, StreamObserver<Flight.FlightData>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Retrieve a single stream associated with a particular descriptor associated with the referenced ticket.
doGet(Flight.Ticket, StreamObserver<Flight.FlightData>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Retrieve a single stream associated with a particular descriptor associated with the referenced ticket.
doPut(StreamObserver<Flight.PutResult>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Push a stream to the flight service associated with a particular flight stream.
doPut(StreamObserver<Flight.PutResult>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Push a stream to the flight service associated with a particular flight stream.
drop() - Method in class org.apache.arrow.flight.example.Stream.StreamCreator
Abandon creation of the stream.

E

empty() - Static method in class org.apache.arrow.flight.PutResult
Create an empty PutResult.
END_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
ENDPOINT_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
equals(Object) - Method in class org.apache.arrow.flight.example.ExampleTicket
 
equals(Object) - Method in class org.apache.arrow.flight.FlightDescriptor
 
equals(Object) - Method in class org.apache.arrow.flight.FlightEndpoint
 
equals(Object) - Method in class org.apache.arrow.flight.FlightInfo
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Action
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Location
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Result
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
equals(Object) - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
equals(Object) - Method in class org.apache.arrow.flight.Location
 
equals(Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
equals(Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
equals(Object) - Method in class org.apache.arrow.flight.Ticket
 
error(Throwable) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Indicate an error to the client.
ErrorFlightMetadata - Class in org.apache.arrow.flight
metadata container specific to the binary metadata held in the grpc trailer.
ErrorFlightMetadata() - Constructor for class org.apache.arrow.flight.ErrorFlightMetadata
 
ExampleFlightServer - Class in org.apache.arrow.flight.example
An Example Flight Server that provides access to the InMemoryStore.
ExampleFlightServer(BufferAllocator, Location) - Constructor for class org.apache.arrow.flight.example.ExampleFlightServer
Constructs a new instance using Allocator for allocating buffer storage that binds to the given location.
ExampleTicket - Class in org.apache.arrow.flight.example
POJO object used to demonstrate how an opaque ticket can be generated.
ExampleTicket(List<String>, int, String) - Constructor for class org.apache.arrow.flight.example.ExampleTicket
Constructs a new instance.
execute(Runnable) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
executor(ExecutorService) - Method in class org.apache.arrow.flight.FlightServer.Builder
Set the executor used by the server.
EXPRESSION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Criteria
 

F

Factory(ClientHeaderHandler) - Constructor for class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware.Factory
Construct a factory with the given header handler.
Factory(CallHeaderAuthenticator) - Constructor for class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware.Factory
Construct a factory with the given auth handler.
Factory() - Constructor for class org.apache.arrow.flight.client.ClientCookieMiddleware.Factory
 
Factory() - Constructor for class org.apache.arrow.flight.ServerHeaderMiddleware.Factory
Construct a factory for receiving call headers.
Flight - Class in org.apache.arrow.flight.impl
 
Flight.Action - Class in org.apache.arrow.flight.impl
An opaque action specific for the service.
Flight.Action.Builder - Class in org.apache.arrow.flight.impl
An opaque action specific for the service.
Flight.ActionOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.ActionType - Class in org.apache.arrow.flight.impl
Describes an available action, including both the name used for execution along with a short description of the purpose of the action.
Flight.ActionType.Builder - Class in org.apache.arrow.flight.impl
Describes an available action, including both the name used for execution along with a short description of the purpose of the action.
Flight.ActionTypeOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.BasicAuth - Class in org.apache.arrow.flight.impl
A message for doing simple auth.
Flight.BasicAuth.Builder - Class in org.apache.arrow.flight.impl
A message for doing simple auth.
Flight.BasicAuthOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.Criteria - Class in org.apache.arrow.flight.impl
A service specific expression that can be used to return a limited set of available Arrow Flight streams.
Flight.Criteria.Builder - Class in org.apache.arrow.flight.impl
A service specific expression that can be used to return a limited set of available Arrow Flight streams.
Flight.CriteriaOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.Empty - Class in org.apache.arrow.flight.impl
Protobuf type arrow.flight.protocol.Empty
Flight.Empty.Builder - Class in org.apache.arrow.flight.impl
Protobuf type arrow.flight.protocol.Empty
Flight.EmptyOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.FlightData - Class in org.apache.arrow.flight.impl
A batch of Arrow data as part of a stream of batches.
Flight.FlightData.Builder - Class in org.apache.arrow.flight.impl
A batch of Arrow data as part of a stream of batches.
Flight.FlightDataOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.FlightDescriptor - Class in org.apache.arrow.flight.impl
The name or tag for a Flight.
Flight.FlightDescriptor.Builder - Class in org.apache.arrow.flight.impl
The name or tag for a Flight.
Flight.FlightDescriptor.DescriptorType - Enum in org.apache.arrow.flight.impl
Describes what type of descriptor is defined.
Flight.FlightDescriptorOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.FlightEndpoint - Class in org.apache.arrow.flight.impl
A particular stream or split associated with a flight.
Flight.FlightEndpoint.Builder - Class in org.apache.arrow.flight.impl
A particular stream or split associated with a flight.
Flight.FlightEndpointOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.FlightInfo - Class in org.apache.arrow.flight.impl
The access coordinates for retrieval of a dataset.
Flight.FlightInfo.Builder - Class in org.apache.arrow.flight.impl
The access coordinates for retrieval of a dataset.
Flight.FlightInfoOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.HandshakeRequest - Class in org.apache.arrow.flight.impl
The request that a client provides to a server on handshake.
Flight.HandshakeRequest.Builder - Class in org.apache.arrow.flight.impl
The request that a client provides to a server on handshake.
Flight.HandshakeRequestOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.HandshakeResponse - Class in org.apache.arrow.flight.impl
Protobuf type arrow.flight.protocol.HandshakeResponse
Flight.HandshakeResponse.Builder - Class in org.apache.arrow.flight.impl
Protobuf type arrow.flight.protocol.HandshakeResponse
Flight.HandshakeResponseOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.Location - Class in org.apache.arrow.flight.impl
A location where a Flight service will accept retrieval of a particular stream given a ticket.
Flight.Location.Builder - Class in org.apache.arrow.flight.impl
A location where a Flight service will accept retrieval of a particular stream given a ticket.
Flight.LocationOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.PutResult - Class in org.apache.arrow.flight.impl
The response message associated with the submission of a DoPut.
Flight.PutResult.Builder - Class in org.apache.arrow.flight.impl
The response message associated with the submission of a DoPut.
Flight.PutResultOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.Result - Class in org.apache.arrow.flight.impl
An opaque result returned after executing an action.
Flight.Result.Builder - Class in org.apache.arrow.flight.impl
An opaque result returned after executing an action.
Flight.ResultOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.SchemaResult - Class in org.apache.arrow.flight.impl
Wrap the result of a getSchema call
Flight.SchemaResult.Builder - Class in org.apache.arrow.flight.impl
Wrap the result of a getSchema call
Flight.SchemaResultOrBuilder - Interface in org.apache.arrow.flight.impl
 
Flight.Ticket - Class in org.apache.arrow.flight.impl
An opaque identifier that the service can use to retrieve a particular portion of a stream.
Flight.Ticket.Builder - Class in org.apache.arrow.flight.impl
An opaque identifier that the service can use to retrieve a particular portion of a stream.
Flight.TicketOrBuilder - Interface in org.apache.arrow.flight.impl
 
FLIGHT_DESCRIPTOR_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightData
 
FLIGHT_DESCRIPTOR_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
FlightCallHeaders - Class in org.apache.arrow.flight
An implementation of the Flight headers interface for headers.
FlightCallHeaders() - Constructor for class org.apache.arrow.flight.FlightCallHeaders
 
FlightClient - Class in org.apache.arrow.flight
Client for Flight services.
FlightClient.Builder - Class in org.apache.arrow.flight
A builder for Flight clients.
FlightClient.ClientStreamListener - Interface in org.apache.arrow.flight
Interface for writers to an Arrow data stream.
FlightClient.ExchangeReaderWriter - Class in org.apache.arrow.flight
A pair of a reader and a writer for a DoExchange call.
FlightClient.PutListener - Interface in org.apache.arrow.flight
A handler for server-sent application metadata messages during a Flight DoPut operation.
FlightClientMiddleware - Interface in org.apache.arrow.flight
Client-side middleware for Flight.
FlightClientMiddleware.Factory - Interface in org.apache.arrow.flight
A factory for client middleware instances.
FlightConstants - Interface in org.apache.arrow.flight
String constants relevant to flight implementations.
FlightDescriptor - Class in org.apache.arrow.flight
An identifier for a particular set of data.
FlightEndpoint - Class in org.apache.arrow.flight
POJO to convert to/from the underlying protobuf FlightEndpoint.
FlightEndpoint(Ticket, Location...) - Constructor for class org.apache.arrow.flight.FlightEndpoint
Constructs a new instance.
FlightHolder - Class in org.apache.arrow.flight.example
A logical collection of streams sharing the same schema.
FlightHolder(BufferAllocator, FlightDescriptor, Schema, DictionaryProvider) - Constructor for class org.apache.arrow.flight.example.FlightHolder
Creates a new instance.
FlightInfo - Class in org.apache.arrow.flight
A POJO representation of a FlightInfo, metadata associated with a set of data records.
FlightInfo(Schema, FlightDescriptor, List<FlightEndpoint>, long, long) - Constructor for class org.apache.arrow.flight.FlightInfo
Constructs a new instance.
FlightInfo(Schema, FlightDescriptor, List<FlightEndpoint>, long, long, IpcOption) - Constructor for class org.apache.arrow.flight.FlightInfo
Constructs a new instance.
FlightMethod - Enum in org.apache.arrow.flight
All the RPC methods available in Flight.
FlightProducer - Interface in org.apache.arrow.flight
API to Implement an Arrow Flight producer.
FlightProducer.CallContext - Interface in org.apache.arrow.flight
Call-specific context.
FlightProducer.ServerStreamListener - Interface in org.apache.arrow.flight
An interface for sending Arrow data back to a client.
FlightProducer.StreamListener<T> - Interface in org.apache.arrow.flight
Callbacks for pushing objects to a receiver.
FlightRuntimeException - Exception in org.apache.arrow.flight
An exception raised from a Flight RPC.
FlightServer - Class in org.apache.arrow.flight
Generic server of flight data that is customized via construction with delegate classes for the actual logic.
FlightServer.Builder - Class in org.apache.arrow.flight
A builder for Flight servers.
FlightServerMiddleware - Interface in org.apache.arrow.flight
Server-side middleware for Flight calls.
FlightServerMiddleware.Factory<T extends FlightServerMiddleware> - Interface in org.apache.arrow.flight
A factory for Flight server middleware.
FlightServerMiddleware.Key<T extends FlightServerMiddleware> - Class in org.apache.arrow.flight
A key for Flight server middleware.
FlightServiceGrpc - Class in org.apache.arrow.flight.impl
A flight service is an endpoint for retrieving or storing Arrow data.
FlightServiceGrpc.FlightServiceBlockingStub - Class in org.apache.arrow.flight.impl
A flight service is an endpoint for retrieving or storing Arrow data.
FlightServiceGrpc.FlightServiceFutureStub - Class in org.apache.arrow.flight.impl
A flight service is an endpoint for retrieving or storing Arrow data.
FlightServiceGrpc.FlightServiceImplBase - Class in org.apache.arrow.flight.impl
A flight service is an endpoint for retrieving or storing Arrow data.
FlightServiceGrpc.FlightServiceStub - Class in org.apache.arrow.flight.impl
A flight service is an endpoint for retrieving or storing Arrow data.
FlightServiceImplBase() - Constructor for class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
 
FlightStatusCode - Enum in org.apache.arrow.flight
A status code describing the result of a Flight call.
FlightStream - Class in org.apache.arrow.flight
An adaptor between protobuf streams and flight data streams.
FlightStream(BufferAllocator, int, FlightStream.Cancellable, FlightStream.Requestor) - Constructor for class org.apache.arrow.flight.FlightStream
Constructs a new instance.
FlightStream.Cancellable - Interface in org.apache.arrow.flight
Provides a callback to cancel a process that is in progress.
FlightStream.Requestor - Interface in org.apache.arrow.flight
Provides a interface to request more items from a stream producer.
forGrpcDomainSocket(String) - Static method in class org.apache.arrow.flight.Location
Construct a URI for a Flight+gRPC server over a Unix domain socket.
forGrpcInsecure(String, int) - Static method in class org.apache.arrow.flight.Location
Construct a URI for a Flight+gRPC server without transport security.
forGrpcTls(String, int) - Static method in class org.apache.arrow.flight.Location
Construct a URI for a Flight+gRPC server with transport security.
forNumber(int) - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
from(Ticket) - Static method in class org.apache.arrow.flight.example.ExampleTicket
Deserializes a new instance from the protocol buffer ticket.
fromGrpcRuntimeException(StatusRuntimeException) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a gRPC exception to a Flight exception.
fromGrpcStatus(Status) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a gRPC status to a Flight status.
fromGrpcStatusAndTrailers(Status, Metadata) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a gRPC Status & trailers to a Flight status.
fromGrpcStatusCode(Status.Code) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a gRPC status code to a Flight status code.
fromProtocol(String) - Static method in enum org.apache.arrow.flight.FlightMethod
Convert a method name string into a FlightMethod.
fromThrowable(Throwable) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert arbitrary exceptions to a FlightRuntimeException.

G

GeneratedBearerTokenAuthenticator - Class in org.apache.arrow.flight.auth2
Generates and caches bearer tokens from user credentials.
GeneratedBearerTokenAuthenticator(CallHeaderAuthenticator) - Constructor for class org.apache.arrow.flight.auth2.GeneratedBearerTokenAuthenticator
Generate bearer tokens for the given basic call authenticator.
GeneratedBearerTokenAuthenticator(CallHeaderAuthenticator, int) - Constructor for class org.apache.arrow.flight.auth2.GeneratedBearerTokenAuthenticator
Generate bearer tokens for the given basic call authenticator.
GeneratedBearerTokenAuthenticator(CallHeaderAuthenticator, CacheBuilder<Object, Object>) - Constructor for class org.apache.arrow.flight.auth2.GeneratedBearerTokenAuthenticator
Generate bearer tokens for the given basic call authenticator.
get(String) - Method in interface org.apache.arrow.flight.CallHeaders
Get the value of a metadata key.
get(String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
get(String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
get(String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
get(String) - Method in class org.apache.arrow.flight.grpc.RequestContextAdapter
 
get(String) - Method in interface org.apache.arrow.flight.RequestContext
Retrieve a registered variable.
getAll(String) - Method in interface org.apache.arrow.flight.CallHeaders
Get all values present for the given metadata key.
getAll(String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
getAll(String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
getAll(String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
getAllByte(String) - Method in interface org.apache.arrow.flight.CallHeaders
Get all values present for the given metadata key.
getAllByte(String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
getAllByte(String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
getAllByte(String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
getApplicationMetadata() - Method in class org.apache.arrow.flight.PutResult
Get the metadata in this message.
getAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Application-defined metadata.
getAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
Application-defined metadata.
getAppMetadata() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
Application-defined metadata.
getAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
bytes app_metadata = 1;
getAppMetadata() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
bytes app_metadata = 1;
getAppMetadata() - Method in interface org.apache.arrow.flight.impl.Flight.PutResultOrBuilder
bytes app_metadata = 1;
getAuthResultWithBearerToken(CallHeaderAuthenticator.AuthResult) - Method in class org.apache.arrow.flight.auth2.BearerTokenAuthenticator
Callback to run when the initial authenticator succeeds.
getAuthResultWithBearerToken(CallHeaderAuthenticator.AuthResult) - Method in class org.apache.arrow.flight.auth2.GeneratedBearerTokenAuthenticator
 
getBody() - Method in class org.apache.arrow.flight.Action
 
getBody() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
bytes body = 2;
getBody() - Method in class org.apache.arrow.flight.impl.Flight.Action
bytes body = 2;
getBody() - Method in interface org.apache.arrow.flight.impl.Flight.ActionOrBuilder
bytes body = 2;
getBody() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
bytes body = 1;
getBody() - Method in class org.apache.arrow.flight.impl.Flight.Result
bytes body = 1;
getBody() - Method in interface org.apache.arrow.flight.impl.Flight.ResultOrBuilder
bytes body = 1;
getBody() - Method in class org.apache.arrow.flight.Result
 
getByte(String) - Method in interface org.apache.arrow.flight.CallHeaders
Get the value of a metadata key.
getByte(String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
getByte(String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
getByte(String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
getBytes() - Method in class org.apache.arrow.flight.FlightInfo
 
getBytes() - Method in class org.apache.arrow.flight.Ticket
 
getCallToken() - Method in class org.apache.arrow.flight.auth.BasicClientAuthHandler
 
getCallToken() - Method in interface org.apache.arrow.flight.auth.ClientAuthHandler
Get the per-call authentication token.
getCmd() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
Opaque value used to express a command.
getCmd() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
Opaque value used to express a command.
getCmd() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
Opaque value used to express a command.
getCommand() - Method in class org.apache.arrow.flight.FlightDescriptor
 
getCredentialCallOption() - Method in class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware.Factory
 
getCredentialCallOptionFromIncomingHeaders(CallHeaders) - Method in class org.apache.arrow.flight.auth2.ClientBearerHeaderHandler
 
getCredentialCallOptionFromIncomingHeaders(CallHeaders) - Method in interface org.apache.arrow.flight.auth2.ClientHeaderHandler
Parses the incoming headers and converts them into a CredentialCallOption.
getDataBody() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The actual batch of Arrow data.
getDataBody() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
The actual batch of Arrow data.
getDataBody() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
The actual batch of Arrow data.
getDataHeader() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Header for message data as described in Message.fbs::Message.
getDataHeader() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
Header for message data as described in Message.fbs::Message.
getDataHeader() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
Header for message data as described in Message.fbs::Message.
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getDefaultInstance() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
getDefaultInstanceForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getDefinition() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
getDefinition() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
definition of entire flight.
getDefinition() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.TokenOrBuilder
definition of entire flight.
getDefinitionBuilder() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
getDefinitionOrBuilder() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
getDefinitionOrBuilder() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
definition of entire flight.
getDefinitionOrBuilder() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.TokenOrBuilder
definition of entire flight.
getDescription() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string description = 2;
getDescription() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
string description = 2;
getDescription() - Method in interface org.apache.arrow.flight.impl.Flight.ActionTypeOrBuilder
string description = 2;
getDescriptionBytes() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string description = 2;
getDescriptionBytes() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
string description = 2;
getDescriptionBytes() - Method in interface org.apache.arrow.flight.impl.Flight.ActionTypeOrBuilder
string description = 2;
getDescriptor() - Method in class org.apache.arrow.flight.FlightInfo
 
getDescriptor() - Method in class org.apache.arrow.flight.FlightStream
Get the descriptor for this stream.
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
getDescriptor() - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getDescriptor() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass
 
getDescriptor() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getDescriptor() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
getDescriptor() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
getDescriptorForType() - Method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
getDescriptorForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
getDictionaryProvider() - Method in class org.apache.arrow.flight.FlightStream
Get the provider for dictionaries in this stream.
getDoActionMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getDoExchangeMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getDoGetMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getDoPutMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getEnd() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
exclusive end
getEnd() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
exclusive end
getEnd() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.TokenOrBuilder
exclusive end
getEndpoint(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpoint(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
A list of endpoints associated with the flight.
getEndpoint(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
A list of endpoints associated with the flight.
getEndpointBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
A list of endpoints associated with the flight.
getEndpointCount() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
A list of endpoints associated with the flight.
getEndpointList() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointList() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
A list of endpoints associated with the flight.
getEndpointList() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
A list of endpoints associated with the flight.
getEndpointOrBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointOrBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
A list of endpoints associated with the flight.
getEndpointOrBuilder(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
A list of endpoints associated with the flight.
getEndpointOrBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
getEndpointOrBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
A list of endpoints associated with the flight.
getEndpointOrBuilderList() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
A list of endpoints associated with the flight.
getEndpoints() - Method in class org.apache.arrow.flight.FlightInfo
 
getExpression() - Method in class org.apache.arrow.flight.Criteria
Get the contained filter criteria.
getExpression() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
bytes expression = 1;
getExpression() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
bytes expression = 1;
getExpression() - Method in interface org.apache.arrow.flight.impl.Flight.CriteriaOrBuilder
bytes expression = 1;
getFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
getFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
The descriptor of the data.
getFlightDescriptor() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
The descriptor of the data.
getFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
getFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
The descriptor associated with this info.
getFlightDescriptor() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
The descriptor associated with this info.
getFlightDescriptorBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
getFlightDescriptorBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
getFlightDescriptorOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
getFlightDescriptorOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
The descriptor of the data.
getFlightDescriptorOrBuilder() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
The descriptor of the data.
getFlightDescriptorOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
getFlightDescriptorOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
The descriptor associated with this info.
getFlightDescriptorOrBuilder() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
The descriptor associated with this info.
getFlightInfo(Location) - Method in class org.apache.arrow.flight.example.FlightHolder
List all available streams as being available at l.
getFlightInfo(FlightProducer.CallContext, FlightDescriptor) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
getFlightInfo(FlightProducer.CallContext, FlightDescriptor) - Method in interface org.apache.arrow.flight.FlightProducer
Get information about a particular data stream.
getFlightInfo(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
For a given FlightDescriptor, get information about how the flight can be consumed.
getFlightInfo(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceFutureStub
For a given FlightDescriptor, get information about how the flight can be consumed.
getFlightInfo(Flight.FlightDescriptor, StreamObserver<Flight.FlightInfo>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
For a given FlightDescriptor, get information about how the flight can be consumed.
getFlightInfo(Flight.FlightDescriptor, StreamObserver<Flight.FlightInfo>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
For a given FlightDescriptor, get information about how the flight can be consumed.
getFlightInfo(FlightProducer.CallContext, FlightDescriptor) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
getGetFlightInfoMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getGetSchemaMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getHandshakeMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getInfo(FlightDescriptor, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Get info on a stream.
getInstance() - Static method in class org.apache.arrow.flight.NoOpStreamListener
 
getLatestMetadata() - Method in class org.apache.arrow.flight.FlightStream
Get the most recent metadata sent from the server.
getListActionsMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getListFlightsMethod() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getLocation() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
getLocation() - Method in class org.apache.arrow.flight.FlightServer
Get the location for this server.
getLocation(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocation(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
A list of URIs where this ticket can be redeemed.
getLocation(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
A list of URIs where this ticket can be redeemed.
getLocationBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
A list of URIs where this ticket can be redeemed.
getLocationCount() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
A list of URIs where this ticket can be redeemed.
getLocationList() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationList() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
A list of URIs where this ticket can be redeemed.
getLocationList() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
A list of URIs where this ticket can be redeemed.
getLocationOrBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationOrBuilder(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
A list of URIs where this ticket can be redeemed.
getLocationOrBuilder(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
A list of URIs where this ticket can be redeemed.
getLocationOrBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
getLocationOrBuilderList() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
A list of URIs where this ticket can be redeemed.
getLocationOrBuilderList() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
A list of URIs where this ticket can be redeemed.
getLocations() - Method in class org.apache.arrow.flight.FlightEndpoint
 
getMiddleware(FlightServerMiddleware.Key<T>) - Method in interface org.apache.arrow.flight.FlightProducer.CallContext
Get the middleware instance of the given type for this call.
getMiddleware() - Method in interface org.apache.arrow.flight.FlightProducer.CallContext
Get an immutable map of middleware for this call.
getNumber() - Method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
getOrdinal() - Method in class org.apache.arrow.flight.example.ExampleTicket
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getParserForType() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getParserForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getParserForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getPassword() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string password = 3;
getPassword() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
string password = 3;
getPassword() - Method in interface org.apache.arrow.flight.impl.Flight.BasicAuthOrBuilder
string password = 3;
getPasswordBytes() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string password = 3;
getPasswordBytes() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
string password = 3;
getPasswordBytes() - Method in interface org.apache.arrow.flight.impl.Flight.BasicAuthOrBuilder
string password = 3;
getPath() - Method in class org.apache.arrow.flight.example.ExampleTicket
 
getPath() - Method in class org.apache.arrow.flight.FlightDescriptor
 
getPath(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
getPath(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
List of strings identifying a particular dataset.
getPath(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
List of strings identifying a particular dataset.
getPathBytes(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
getPathBytes(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
List of strings identifying a particular dataset.
getPathBytes(int) - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
List of strings identifying a particular dataset.
getPathCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
getPathCount() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
List of strings identifying a particular dataset.
getPathCount() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
List of strings identifying a particular dataset.
getPathList() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
getPathList() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
List of strings identifying a particular dataset.
getPathList() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
List of strings identifying a particular dataset.
getPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
Arbitrary auth/handshake info.
getPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
Arbitrary auth/handshake info.
getPayload() - Method in interface org.apache.arrow.flight.impl.Flight.HandshakeRequestOrBuilder
Arbitrary auth/handshake info.
getPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
Arbitrary auth/handshake info.
getPayload() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
Arbitrary auth/handshake info.
getPayload() - Method in interface org.apache.arrow.flight.impl.Flight.HandshakeResponseOrBuilder
Arbitrary auth/handshake info.
getPeerIdentity() - Method in interface org.apache.arrow.flight.auth2.CallHeaderAuthenticator.AuthResult
The peer identity that was determined by the handshake process based on the authentication credentials supplied by the client.
getPort() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
getPort() - Method in class org.apache.arrow.flight.FlightServer
Get the port the server is running on (if applicable).
getProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
A defined protocol version
getProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
A defined protocol version
getProtocolVersion() - Method in interface org.apache.arrow.flight.impl.Flight.HandshakeRequestOrBuilder
A defined protocol version
getProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
A defined protocol version
getProtocolVersion() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
A defined protocol version
getProtocolVersion() - Method in interface org.apache.arrow.flight.impl.Flight.HandshakeResponseOrBuilder
A defined protocol version
GetReadableBuffer - Class in org.apache.arrow.flight.grpc
Enable access to ReadableBuffer directly to copy data from a BufferInputStream into a target ByteBuffer/ByteBuf.
GetReadableBuffer() - Constructor for class org.apache.arrow.flight.grpc.GetReadableBuffer
 
getReadableBuffer(InputStream) - Static method in class org.apache.arrow.flight.grpc.GetReadableBuffer
Extracts the ReadableBuffer for the given input stream.
getReader() - Method in class org.apache.arrow.flight.FlightClient.ExchangeReaderWriter
Get the reader for the call.
getRecordCount() - Method in class org.apache.arrow.flight.example.Stream
 
getRecords() - Method in class org.apache.arrow.flight.FlightInfo
 
getRecordsPerBatch() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 records_per_batch = 4;
getRecordsPerBatch() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
int32 records_per_batch = 4;
getRecordsPerBatch() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.PerfOrBuilder
int32 records_per_batch = 4;
getRecordsPerStream() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int64 records_per_stream = 3;
getRecordsPerStream() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
int64 records_per_stream = 3;
getRecordsPerStream() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.PerfOrBuilder
int64 records_per_stream = 3;
getResult() - Method in class org.apache.arrow.flight.AsyncPutListener
Wait for the stream to finish on the server side.
getResult() - Method in interface org.apache.arrow.flight.FlightClient.ClientStreamListener
Wait for the stream to finish on the server side.
getResult() - Method in interface org.apache.arrow.flight.FlightClient.PutListener
Wait for the stream to finish on the server side.
getResult() - Method in class org.apache.arrow.flight.SyncPutListener
 
getRoot() - Method in class org.apache.arrow.flight.FlightStream
Get the current vector data from the stream.
getSchema() - Method in class org.apache.arrow.flight.example.Stream
 
getSchema(FlightDescriptor, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Get schema for a stream.
getSchema() - Method in class org.apache.arrow.flight.FlightInfo
 
getSchema(FlightProducer.CallContext, FlightDescriptor) - Method in interface org.apache.arrow.flight.FlightProducer
Get schema for a particular data stream.
getSchema() - Method in class org.apache.arrow.flight.FlightStream
Get the schema for this stream.
getSchema() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
schema of the dataset as described in Schema.fbs::Schema.
getSchema() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
schema of the dataset as described in Schema.fbs::Schema.
getSchema() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
schema of the dataset as described in Schema.fbs::Schema.
getSchema() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
schema of the dataset as described in Schema.fbs::Schema.
getSchema() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
schema of the dataset as described in Schema.fbs::Schema.
getSchema() - Method in interface org.apache.arrow.flight.impl.Flight.SchemaResultOrBuilder
schema of the dataset as described in Schema.fbs::Schema.
getSchema(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema This is used when a consumer needs the Schema of flight stream.
getSchema(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceFutureStub
For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema This is used when a consumer needs the Schema of flight stream.
getSchema(Flight.FlightDescriptor, StreamObserver<Flight.SchemaResult>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema This is used when a consumer needs the Schema of flight stream.
getSchema(Flight.FlightDescriptor, StreamObserver<Flight.SchemaResult>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
For a given FlightDescriptor, get the Schema as described in Schema.fbs::Schema This is used when a consumer needs the Schema of flight stream.
getSchema() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
bytes schema = 1;
getSchema() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
bytes schema = 1;
getSchema() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.PerfOrBuilder
bytes schema = 1;
getSchema() - Method in class org.apache.arrow.flight.SchemaResult
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getSerializedSize() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getSerializedSize() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getSerializedSize() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getServiceDescriptor() - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
getStart() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
inclusive start
getStart() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
inclusive start
getStart() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.TokenOrBuilder
inclusive start
getStore() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
getStream(ExampleTicket) - Method in class org.apache.arrow.flight.example.FlightHolder
Returns the stream based on the ordinal of ExampleTicket.
getStream(FlightProducer.CallContext, Ticket, FlightProducer.ServerStreamListener) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
getStream(Ticket) - Method in class org.apache.arrow.flight.example.InMemoryStore
Returns the appropriate stream given the ticket (streams are indexed by path and an ordinal).
getStream(Ticket, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Retrieve a stream from the server.
getStream(FlightProducer.CallContext, Ticket, FlightProducer.ServerStreamListener) - Method in interface org.apache.arrow.flight.FlightProducer
Return data for a stream.
getStream(FlightProducer.CallContext, Ticket, FlightProducer.ServerStreamListener) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
getStreamCount() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 stream_count = 2;
getStreamCount() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
int32 stream_count = 2;
getStreamCount() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.PerfOrBuilder
int32 stream_count = 2;
getTicket() - Method in class org.apache.arrow.flight.FlightEndpoint
 
getTicket() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
getTicket() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
Token used to retrieve this stream.
getTicket() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
Token used to retrieve this stream.
getTicket() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
bytes ticket = 1;
getTicket() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
bytes ticket = 1;
getTicket() - Method in interface org.apache.arrow.flight.impl.Flight.TicketOrBuilder
bytes ticket = 1;
getTicketBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
getTicketOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
getTicketOrBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
Token used to retrieve this stream.
getTicketOrBuilder() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
Token used to retrieve this stream.
getToken(String, String) - Method in interface org.apache.arrow.flight.auth.BasicServerAuthHandler.BasicAuthValidator
 
getTotalBytes() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
int64 total_bytes = 5;
getTotalBytes() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
int64 total_bytes = 5;
getTotalBytes() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
int64 total_bytes = 5;
getTotalRecords() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
Set these to -1 if unknown.
getTotalRecords() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
Set these to -1 if unknown.
getTotalRecords() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
Set these to -1 if unknown.
getType() - Method in class org.apache.arrow.flight.Action
 
getType() - Method in class org.apache.arrow.flight.ActionType
 
getType() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
string type = 1;
getType() - Method in class org.apache.arrow.flight.impl.Flight.Action
string type = 1;
getType() - Method in interface org.apache.arrow.flight.impl.Flight.ActionOrBuilder
string type = 1;
getType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string type = 1;
getType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
string type = 1;
getType() - Method in interface org.apache.arrow.flight.impl.Flight.ActionTypeOrBuilder
string type = 1;
getType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getType() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getTypeBytes() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
string type = 1;
getTypeBytes() - Method in class org.apache.arrow.flight.impl.Flight.Action
string type = 1;
getTypeBytes() - Method in interface org.apache.arrow.flight.impl.Flight.ActionOrBuilder
string type = 1;
getTypeBytes() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string type = 1;
getTypeBytes() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
string type = 1;
getTypeBytes() - Method in interface org.apache.arrow.flight.impl.Flight.ActionTypeOrBuilder
string type = 1;
getTypeValue() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getTypeValue() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getTypeValue() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDescriptorOrBuilder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
getUnknownFields() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
getUnknownFields() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
getUnknownFields() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
getUri() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
string uri = 1;
getUri() - Method in class org.apache.arrow.flight.impl.Flight.Location
string uri = 1;
getUri() - Method in interface org.apache.arrow.flight.impl.Flight.LocationOrBuilder
string uri = 1;
getUri() - Method in class org.apache.arrow.flight.Location
 
getUriBytes() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
string uri = 1;
getUriBytes() - Method in class org.apache.arrow.flight.impl.Flight.Location
string uri = 1;
getUriBytes() - Method in interface org.apache.arrow.flight.impl.Flight.LocationOrBuilder
string uri = 1;
getUsername() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string username = 2;
getUsername() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
string username = 2;
getUsername() - Method in interface org.apache.arrow.flight.impl.Flight.BasicAuthOrBuilder
string username = 2;
getUsernameBytes() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string username = 2;
getUsernameBytes() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
string username = 2;
getUsernameBytes() - Method in interface org.apache.arrow.flight.impl.Flight.BasicAuthOrBuilder
string username = 2;
getUuid() - Method in class org.apache.arrow.flight.example.ExampleTicket
 
getUuid() - Method in class org.apache.arrow.flight.example.Stream
 
getValueDescriptor() - Method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
getValueFromAuthHeader(CallHeaders, String) - Static method in class org.apache.arrow.flight.auth2.AuthUtilities
Helper method for retrieving a value from the Authorization header.
getWriter() - Method in class org.apache.arrow.flight.FlightClient.ExchangeReaderWriter
Get the writer for the call.
GRPC - Static variable in class org.apache.arrow.flight.LocationSchemes
 
GRPC_DOMAIN_SOCKET - Static variable in class org.apache.arrow.flight.LocationSchemes
 
GRPC_INSECURE - Static variable in class org.apache.arrow.flight.LocationSchemes
 
GRPC_TLS - Static variable in class org.apache.arrow.flight.LocationSchemes
 

H

handshake(CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Executes the handshake against the Flight service.
handshake(StreamObserver<Flight.HandshakeResponse>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Handshake between client and server.
handshake(StreamObserver<Flight.HandshakeResponse>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Handshake between client and server.
HANDSHAKE_DESCRIPTOR_NAME - Static variable in class org.apache.arrow.flight.auth.AuthConstants
 
hasAuthHandler() - Method in class org.apache.arrow.flight.auth.ClientAuthInterceptor
 
hasDefinition() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
hasDefinition() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
definition of entire flight.
hasDefinition() - Method in interface org.apache.arrow.flight.perf.impl.PerfOuterClass.TokenOrBuilder
definition of entire flight.
hasFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
hasFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
The descriptor of the data.
hasFlightDescriptor() - Method in interface org.apache.arrow.flight.impl.Flight.FlightDataOrBuilder
The descriptor of the data.
hasFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
hasFlightDescriptor() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
The descriptor associated with this info.
hasFlightDescriptor() - Method in interface org.apache.arrow.flight.impl.Flight.FlightInfoOrBuilder
The descriptor associated with this info.
hashCode() - Method in class org.apache.arrow.flight.example.ExampleTicket
 
hashCode() - Method in class org.apache.arrow.flight.FlightDescriptor
 
hashCode() - Method in class org.apache.arrow.flight.FlightEndpoint
 
hashCode() - Method in class org.apache.arrow.flight.FlightInfo
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
hashCode() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
hashCode() - Method in class org.apache.arrow.flight.Location
 
hashCode() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
hashCode() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
hashCode() - Method in class org.apache.arrow.flight.Ticket
 
hasRoot() - Method in class org.apache.arrow.flight.FlightStream
Check if there is a root (i.e.
hasTicket() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
hasTicket() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
Token used to retrieve this stream.
hasTicket() - Method in interface org.apache.arrow.flight.impl.Flight.FlightEndpointOrBuilder
Token used to retrieve this stream.
HEADER_KEY - Static variable in interface org.apache.arrow.flight.FlightConstants
 
headerAuthenticator(CallHeaderAuthenticator) - Method in class org.apache.arrow.flight.FlightServer.Builder
Set the header-based authentication mechanism.
HeaderCallOption - Class in org.apache.arrow.flight
Method option for supplying headers to method calls.
HeaderCallOption(CallHeaders) - Constructor for class org.apache.arrow.flight.HeaderCallOption
Header property constructor.
headers() - Method in class org.apache.arrow.flight.ServerHeaderMiddleware
Retrieve the headers for this call.

I

InMemoryStore - Class in org.apache.arrow.flight.example
A FlightProducer that hosts an in memory store of Arrow buffers.
InMemoryStore(BufferAllocator, Location) - Constructor for class org.apache.arrow.flight.example.InMemoryStore
Constructs a new instance.
insert(String, String) - Method in interface org.apache.arrow.flight.CallHeaders
Insert a metadata pair with the given value.
insert(String, byte[]) - Method in interface org.apache.arrow.flight.CallHeaders
Insert a metadata pair with the given value.
insert(String, String) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
insert(String, byte[]) - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
insert(String, String) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
insert(String, byte[]) - Method in class org.apache.arrow.flight.FlightCallHeaders
 
insert(String, String) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
insert(String, byte[]) - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
intercept(FlightClientMiddleware.Factory) - Method in class org.apache.arrow.flight.FlightClient.Builder
 
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class org.apache.arrow.flight.auth.ClientAuthInterceptor
 
interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class org.apache.arrow.flight.auth.ServerAuthInterceptor
 
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class org.apache.arrow.flight.grpc.ClientInterceptorAdapter
 
interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class org.apache.arrow.flight.grpc.ServerInterceptorAdapter
 
INTERNAL - Static variable in class org.apache.arrow.flight.CallStatus
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
internalGetValueMap() - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
interruptWait() - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
Interrupt waiting on the listener to change state.
INVALID_ARGUMENT - Static variable in class org.apache.arrow.flight.CallStatus
 
invokeAll(Collection<? extends Callable<T>>) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
invokeAny(Collection<? extends Callable<T>>) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
isCancelled() - Method in class org.apache.arrow.flight.AsyncPutListener
 
isCancelled() - Method in interface org.apache.arrow.flight.FlightClient.PutListener
Check if the call has been cancelled.
isCancelled() - Method in interface org.apache.arrow.flight.FlightProducer.CallContext
Whether the call has been cancelled by the client.
isCancelled() - Method in interface org.apache.arrow.flight.FlightProducer.ServerStreamListener
Check whether the call has been cancelled.
isCancelled() - Method in class org.apache.arrow.flight.SyncPutListener
 
isCommand() - Method in class org.apache.arrow.flight.FlightDescriptor
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
isInitialized() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
isInitialized() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
isInitialized() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
isReady() - Method in interface org.apache.arrow.flight.OutboundStreamListener
A hint indicating whether the client is ready to receive data without excessive buffering.
isShutdown() - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
isTerminated() - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
isValid(byte[]) - Method in interface org.apache.arrow.flight.auth.BasicServerAuthHandler.BasicAuthValidator
 
isValid(byte[]) - Method in class org.apache.arrow.flight.auth.BasicServerAuthHandler
 
isValid(byte[]) - Method in interface org.apache.arrow.flight.auth.ServerAuthHandler
Validate the client token provided on each call.
iterator() - Method in class org.apache.arrow.flight.example.Stream
 

K

KeyFactory(FlightServerMiddleware.Key<T>, FlightServerMiddleware.Factory<T>) - Constructor for class org.apache.arrow.flight.grpc.ServerInterceptorAdapter.KeyFactory
 
keys() - Method in interface org.apache.arrow.flight.CallHeaders
Get a set of all the metadata keys.
keys() - Method in class org.apache.arrow.flight.ErrorFlightMetadata
 
keys() - Method in class org.apache.arrow.flight.FlightCallHeaders
 
keys() - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
keySet() - Method in class org.apache.arrow.flight.grpc.RequestContextAdapter
 
keySet() - Method in interface org.apache.arrow.flight.RequestContext
Retrieves the keys that have been registered to this context.

L

listActions(FlightProducer.CallContext, FlightProducer.StreamListener<ActionType>) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
listActions(CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Lists actions available on the Flight service.
listActions(FlightProducer.CallContext, FlightProducer.StreamListener<ActionType>) - Method in interface org.apache.arrow.flight.FlightProducer
List available application-defined RPCs.
listActions(Flight.Empty) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
A flight service exposes all of the available action types that it has along with descriptions.
listActions(Flight.Empty, StreamObserver<Flight.ActionType>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
A flight service exposes all of the available action types that it has along with descriptions.
listActions(Flight.Empty, StreamObserver<Flight.ActionType>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
A flight service exposes all of the available action types that it has along with descriptions.
listActions(FlightProducer.CallContext, FlightProducer.StreamListener<ActionType>) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
listFlights(FlightProducer.CallContext, Criteria, FlightProducer.StreamListener<FlightInfo>) - Method in class org.apache.arrow.flight.example.InMemoryStore
 
listFlights(Criteria, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Get a list of available flights.
listFlights(FlightProducer.CallContext, Criteria, FlightProducer.StreamListener<FlightInfo>) - Method in interface org.apache.arrow.flight.FlightProducer
List available data streams on this service.
listFlights(Flight.Criteria) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceBlockingStub
Get a list of available streams given a particular criteria.
listFlights(Flight.Criteria, StreamObserver<Flight.FlightInfo>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceImplBase
Get a list of available streams given a particular criteria.
listFlights(Flight.Criteria, StreamObserver<Flight.FlightInfo>) - Method in class org.apache.arrow.flight.impl.FlightServiceGrpc.FlightServiceStub
Get a list of available streams given a particular criteria.
listFlights(FlightProducer.CallContext, Criteria, FlightProducer.StreamListener<FlightInfo>) - Method in class org.apache.arrow.flight.NoOpFlightProducer
 
location(Location) - Method in class org.apache.arrow.flight.FlightClient.Builder
 
location(Location) - Method in class org.apache.arrow.flight.FlightServer.Builder
 
Location - Class in org.apache.arrow.flight
A URI where a Flight stream is available.
Location(String) - Constructor for class org.apache.arrow.flight.Location
Constructs a new instance.
Location(URI) - Constructor for class org.apache.arrow.flight.Location
Construct a new instance from an existing URI.
LOCATION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
LocationSchemes - Class in org.apache.arrow.flight
Constants representing well-known URI schemes for Flight services.

M

main(String[]) - Static method in class org.apache.arrow.flight.example.ExampleFlightServer
Main method starts the server listening to localhost:12233.
maxInboundMessageSize(int) - Method in class org.apache.arrow.flight.FlightClient.Builder
Set the maximum inbound message size.
maxInboundMessageSize(int) - Method in class org.apache.arrow.flight.FlightServer.Builder
Set the maximum size of a message.
mergeDefinition(PerfOuterClass.Perf) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
mergeFlightDescriptor(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
mergeFlightDescriptor(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
mergeFrom(Flight.Action) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
mergeFrom(Flight.ActionType) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
mergeFrom(Flight.BasicAuth) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
mergeFrom(Flight.Criteria) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
mergeFrom(Flight.Empty) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
mergeFrom(Flight.FlightData) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
mergeFrom(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
mergeFrom(Flight.FlightEndpoint) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
mergeFrom(Flight.FlightInfo) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
mergeFrom(Flight.HandshakeRequest) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
mergeFrom(Flight.HandshakeResponse) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
mergeFrom(Flight.Location) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
mergeFrom(Flight.PutResult) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
mergeFrom(Flight.Result) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
mergeFrom(Flight.SchemaResult) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
mergeFrom(Flight.Ticket) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
mergeFrom(PerfOuterClass.Perf) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
mergeFrom(Message) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
mergeFrom(PerfOuterClass.Token) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
mergeTicket(Flight.Ticket) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
metadata() - Method in class org.apache.arrow.flight.CallStatus
Metadata associated with the exception.
metadata(ArrowBuf) - Static method in class org.apache.arrow.flight.PutResult
Create a PutResult with application-specific metadata.
MetadataAdapter - Class in org.apache.arrow.flight.grpc
A mutable adapter between the gRPC Metadata object and the Flight headers interface.
MetadataAdapter(Metadata) - Constructor for class org.apache.arrow.flight.grpc.MetadataAdapter
 
method() - Method in class org.apache.arrow.flight.CallInfo
 
middleware(FlightServerMiddleware.Key<T>, FlightServerMiddleware.Factory<T>) - Method in class org.apache.arrow.flight.FlightServer.Builder
Add a Flight middleware component to inspect and modify requests to this service.

N

newBlockingStub(Channel) - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
newBuilder(Flight.Action) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
newBuilder(Flight.ActionType) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
newBuilder(Flight.BasicAuth) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
newBuilder(Flight.Criteria) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
newBuilder(Flight.Empty) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
newBuilder(Flight.FlightData) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
newBuilder(Flight.FlightDescriptor) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
newBuilder(Flight.FlightEndpoint) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
newBuilder(Flight.FlightInfo) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
newBuilder(Flight.HandshakeRequest) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
newBuilder(Flight.HandshakeResponse) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
newBuilder(Flight.Location) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
newBuilder(Flight.PutResult) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
newBuilder(Flight.Result) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
newBuilder(Flight.SchemaResult) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
newBuilder() - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
newBuilder(Flight.Ticket) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
newBuilder() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
newBuilder(PerfOuterClass.Perf) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
newBuilder() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
newBuilder(PerfOuterClass.Token) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Action
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Location
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Result
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
newBuilderForType() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
newBuilderForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
newBuilderForType() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
newFutureStub(Channel) - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
Creates a new ListenableFuture-style stub that supports unary calls on the service
newStub(Channel) - Static method in class org.apache.arrow.flight.impl.FlightServiceGrpc
Creates a new async stub that supports all call types for the service
next() - Method in class org.apache.arrow.flight.FlightStream
Blocking request to load next item into list.
NO_OP - Static variable in interface org.apache.arrow.flight.auth.ServerAuthHandler
An auth handler that does nothing.
NO_OP - Static variable in interface org.apache.arrow.flight.auth2.CallHeaderAuthenticator
An auth handler that does nothing.
NO_OP - Static variable in interface org.apache.arrow.flight.auth2.ClientHeaderHandler
An client header handler that does nothing.
NoOpFlightProducer - Class in org.apache.arrow.flight
A FlightProducer that throws on all operations.
NoOpFlightProducer() - Constructor for class org.apache.arrow.flight.NoOpFlightProducer
 
NoOpStreamListener<T> - Class in org.apache.arrow.flight
A FlightProducer.StreamListener that does nothing for all callbacks.
NoOpStreamListener() - Constructor for class org.apache.arrow.flight.NoOpStreamListener
 
NOT_FOUND - Static variable in class org.apache.arrow.flight.CallStatus
 

O

of(String) - Static method in class org.apache.arrow.flight.FlightServerMiddleware.Key
Create a new key for the given type.
onBeforeSendingHeaders(CallHeaders) - Method in class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware
 
onBeforeSendingHeaders(CallHeaders) - Method in class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware
 
onBeforeSendingHeaders(CallHeaders) - Method in class org.apache.arrow.flight.client.ClientCookieMiddleware
 
onBeforeSendingHeaders(CallHeaders) - Method in interface org.apache.arrow.flight.FlightClientMiddleware
A callback used before request headers are sent.
onBeforeSendingHeaders(CallHeaders) - Method in interface org.apache.arrow.flight.FlightServerMiddleware
Callback for when the underlying transport is about to send response headers.
onBeforeSendingHeaders(CallHeaders) - Method in class org.apache.arrow.flight.ServerHeaderMiddleware
 
onCallCompleted(CallStatus) - Method in class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware
 
onCallCompleted(CallStatus) - Method in class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware
 
onCallCompleted(CallStatus) - Method in class org.apache.arrow.flight.client.ClientCookieMiddleware
 
onCallCompleted(CallStatus) - Method in interface org.apache.arrow.flight.FlightClientMiddleware
A callback called after the call completes.
onCallCompleted(CallStatus) - Method in interface org.apache.arrow.flight.FlightServerMiddleware
Callback for when the underlying transport has completed a call.
onCallCompleted(CallStatus) - Method in class org.apache.arrow.flight.ServerHeaderMiddleware
 
onCallErrored(Throwable) - Method in class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware
 
onCallErrored(Throwable) - Method in interface org.apache.arrow.flight.FlightServerMiddleware
Callback for when an RPC method implementation throws an uncaught exception.
onCallErrored(Throwable) - Method in class org.apache.arrow.flight.ServerHeaderMiddleware
 
onCallStarted(CallInfo) - Method in class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware.Factory
 
onCallStarted(CallInfo, CallHeaders, RequestContext) - Method in class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware.Factory
 
onCallStarted(CallInfo) - Method in class org.apache.arrow.flight.client.ClientCookieMiddleware.Factory
 
onCallStarted(CallInfo) - Method in interface org.apache.arrow.flight.FlightClientMiddleware.Factory
Create a new middleware instance for the given call.
onCallStarted(CallInfo, CallHeaders, RequestContext) - Method in interface org.apache.arrow.flight.FlightServerMiddleware.Factory
A callback for when the call starts.
onCallStarted(CallInfo, CallHeaders, RequestContext) - Method in class org.apache.arrow.flight.ServerHeaderMiddleware.Factory
 
onCompleted() - Method in class org.apache.arrow.flight.AsyncPutListener
 
onCompleted() - Method in interface org.apache.arrow.flight.FlightProducer.StreamListener
Indicate that the transmission is finished.
onCompleted() - Method in class org.apache.arrow.flight.NoOpStreamListener
Ignores the stream completion event.
onCompleted() - Method in class org.apache.arrow.flight.SyncPutListener
 
onError(Throwable) - Method in class org.apache.arrow.flight.AsyncPutListener
 
onError(Throwable) - Method in interface org.apache.arrow.flight.auth.ClientAuthHandler.ClientAuthSender
Signal an error to the server and abort the authentication attempt.
onError(Throwable) - Method in interface org.apache.arrow.flight.auth.ServerAuthHandler.ServerAuthSender
 
onError(Throwable) - Method in interface org.apache.arrow.flight.FlightProducer.StreamListener
Indicate an error to the client.
onError(Throwable) - Method in class org.apache.arrow.flight.NoOpStreamListener
Ignores the error received.
onError(Throwable) - Method in class org.apache.arrow.flight.SyncPutListener
 
onHeadersReceived(CallHeaders) - Method in class org.apache.arrow.flight.auth2.ClientIncomingAuthHeaderMiddleware
 
onHeadersReceived(CallHeaders) - Method in class org.apache.arrow.flight.client.ClientCookieMiddleware
 
onHeadersReceived(CallHeaders) - Method in interface org.apache.arrow.flight.FlightClientMiddleware
A callback called after response headers are received.
onNext(PutResult) - Method in class org.apache.arrow.flight.AsyncPutListener
 
onNext(PutResult) - Method in interface org.apache.arrow.flight.FlightClient.PutListener
Called when a message from the server is received.
onNext(T) - Method in interface org.apache.arrow.flight.FlightProducer.StreamListener
Send the next value to the client.
onNext(T) - Method in class org.apache.arrow.flight.NoOpStreamListener
Ignores the value received.
onNext(PutResult) - Method in class org.apache.arrow.flight.SyncPutListener
 
org.apache.arrow.flight - package org.apache.arrow.flight
 
org.apache.arrow.flight.auth - package org.apache.arrow.flight.auth
 
org.apache.arrow.flight.auth2 - package org.apache.arrow.flight.auth2
 
org.apache.arrow.flight.client - package org.apache.arrow.flight.client
 
org.apache.arrow.flight.example - package org.apache.arrow.flight.example
 
org.apache.arrow.flight.example.integration - package org.apache.arrow.flight.example.integration
 
org.apache.arrow.flight.grpc - package org.apache.arrow.flight.grpc
 
org.apache.arrow.flight.impl - package org.apache.arrow.flight.impl
 
org.apache.arrow.flight.perf.impl - package org.apache.arrow.flight.perf.impl
 
OutboundStreamListener - Interface in org.apache.arrow.flight
An interface for writing data to a peer, client or server.
overrideHostname(String) - Method in class org.apache.arrow.flight.FlightClient.Builder
Override the hostname checked for TLS.

P

parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parseFrom(ByteBuffer) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(ByteString) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(byte[]) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(InputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(CodedInputStream) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Action
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.ActionType
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Criteria
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Empty
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.FlightData
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Location
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.PutResult
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Result
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
parser() - Static method in class org.apache.arrow.flight.impl.Flight.Ticket
 
parser() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
parser() - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
PASSWORD_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
path(Iterable<String>) - Static method in class org.apache.arrow.flight.FlightDescriptor
 
path(String...) - Static method in class org.apache.arrow.flight.FlightDescriptor
 
PATH_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
PATH_VALUE - Static variable in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
A named path that identifies a dataset.
PAYLOAD_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
PAYLOAD_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
PEER_IDENTITY_KEY - Static variable in class org.apache.arrow.flight.auth.AuthConstants
 
PEER_IDENTITY_KEY - Static variable in class org.apache.arrow.flight.auth2.Auth2Constants
 
peerIdentity() - Method in interface org.apache.arrow.flight.FlightProducer.CallContext
The identity of the authenticated peer.
PerfOuterClass - Class in org.apache.arrow.flight.perf.impl
 
PerfOuterClass.Perf - Class in org.apache.arrow.flight.perf.impl
Protobuf type Perf
PerfOuterClass.Perf.Builder - Class in org.apache.arrow.flight.perf.impl
Protobuf type Perf
PerfOuterClass.PerfOrBuilder - Interface in org.apache.arrow.flight.perf.impl
 
PerfOuterClass.Token - Class in org.apache.arrow.flight.perf.impl
Payload of ticket
PerfOuterClass.Token.Builder - Class in org.apache.arrow.flight.perf.impl
Payload of ticket
PerfOuterClass.TokenOrBuilder - Interface in org.apache.arrow.flight.perf.impl
 
poll(long, TimeUnit) - Method in class org.apache.arrow.flight.SyncPutListener
Get the next message from the server, blocking for the specified amount of time until it is available.
producer(FlightProducer) - Method in class org.apache.arrow.flight.FlightServer.Builder
 
PROTOCOL_VERSION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
PROTOCOL_VERSION_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
put(String, String) - Method in class org.apache.arrow.flight.grpc.RequestContextAdapter
 
put(String, String) - Method in interface org.apache.arrow.flight.RequestContext
Register a variable and a value.
putMetadata(ArrowBuf) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Send a pure metadata message without any associated data.
putNext() - Method in interface org.apache.arrow.flight.OutboundStreamListener
Send the current contents of the associated VectorSchemaRoot.
putNext(ArrowBuf) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Send the current contents of the associated VectorSchemaRoot alongside application-defined metadata.
PutResult - Class in org.apache.arrow.flight
A message from the server during a DoPut operation.

R

read() - Method in class org.apache.arrow.flight.SyncPutListener
Get the next message from the server, blocking until it is available.
readIntoBuffer(InputStream, ArrowBuf, int, boolean) - Static method in class org.apache.arrow.flight.grpc.GetReadableBuffer
Helper method to read a gRPC-provided InputStream into an ArrowBuf.
readyCallback() - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
Callback to execute when the listener becomes ready.
RECORDS_PER_BATCH_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
RECORDS_PER_STREAM_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
register(FlightProducer.ServerStreamListener) - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
 
register(FlightProducer.ServerStreamListener) - Method in interface org.apache.arrow.flight.BackpressureStrategy
Set up operations to work against the given listener.
registerAllExtensions(ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.impl.Flight
 
registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.arrow.flight.impl.Flight
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass
 
registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.arrow.flight.perf.impl.PerfOuterClass
 
remove(String) - Method in class org.apache.arrow.flight.grpc.RequestContextAdapter
 
remove(String) - Method in interface org.apache.arrow.flight.RequestContext
Deletes a registered variable.
removeEndpoint(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
removeLocation(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
request(int) - Method in interface org.apache.arrow.flight.FlightStream.Requestor
Requests count more messages from the instance of this object.
REQUEST_CONTEXT_KEY - Static variable in class org.apache.arrow.flight.grpc.RequestContextAdapter
 
RequestContext - Interface in org.apache.arrow.flight
Tracks variables about the current request.
RequestContextAdapter - Class in org.apache.arrow.flight.grpc
Adapter for holding key value pairs.
RequestContextAdapter() - Constructor for class org.apache.arrow.flight.grpc.RequestContextAdapter
 
Result - Class in org.apache.arrow.flight
Opaque result returned after executing an action.
Result(byte[]) - Constructor for class org.apache.arrow.flight.Result
 

S

SCHEMA_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
SCHEMA_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
SCHEMA_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
SchemaResult - Class in org.apache.arrow.flight
Opaque result returned after executing a getSchema request.
SchemaResult(Schema) - Constructor for class org.apache.arrow.flight.SchemaResult
 
SchemaResult(Schema, IpcOption) - Constructor for class org.apache.arrow.flight.SchemaResult
Create a schema result with specific IPC options for serialization.
send(byte[]) - Method in interface org.apache.arrow.flight.auth.ClientAuthHandler.ClientAuthSender
Send the server a message.
send(byte[]) - Method in interface org.apache.arrow.flight.auth.ServerAuthHandler.ServerAuthSender
 
sendTo(BufferAllocator, FlightProducer.ServerStreamListener) - Method in class org.apache.arrow.flight.example.Stream
Sends that data from this object to the given listener.
serialize() - Method in class org.apache.arrow.flight.FlightDescriptor
Get the serialized form of this protocol message.
serialize() - Method in class org.apache.arrow.flight.FlightInfo
Get the serialized form of this protocol message.
serialize() - Method in class org.apache.arrow.flight.Ticket
Get the serialized form of this protocol message.
SERVER_MIDDLEWARE_KEY - Static variable in class org.apache.arrow.flight.grpc.ServerInterceptorAdapter
The Context.Key that stores the Flight middleware active for a particular call.
ServerAuthHandler - Interface in org.apache.arrow.flight.auth
Interface for Server side authentication handlers.
ServerAuthHandler.ServerAuthSender - Interface in org.apache.arrow.flight.auth
Interface for a server implementations to send back authentication messages back to the client.
ServerAuthInterceptor - Class in org.apache.arrow.flight.auth
GRPC Interceptor for performing authentication.
ServerAuthInterceptor(ServerAuthHandler) - Constructor for class org.apache.arrow.flight.auth.ServerAuthInterceptor
 
ServerAuthWrapper - Class in org.apache.arrow.flight.auth
Contains utility methods for integrating authorization into a GRPC stream.
ServerAuthWrapper() - Constructor for class org.apache.arrow.flight.auth.ServerAuthWrapper
 
ServerCallHeaderAuthMiddleware - Class in org.apache.arrow.flight.auth2
Middleware that's used to validate credentials during the handshake and verify the bearer token in subsequent requests.
ServerCallHeaderAuthMiddleware(CallHeaderAuthenticator.AuthResult) - Constructor for class org.apache.arrow.flight.auth2.ServerCallHeaderAuthMiddleware
 
ServerCallHeaderAuthMiddleware.Factory - Class in org.apache.arrow.flight.auth2
Factory for accessing ServerAuthMiddleware.
ServerHeaderMiddleware - Class in org.apache.arrow.flight
Middleware that's used to extract and pass headers to the server during requests.
ServerHeaderMiddleware.Factory - Class in org.apache.arrow.flight
Factory for accessing ServerHeaderMiddleware.
ServerInterceptorAdapter - Class in org.apache.arrow.flight.grpc
An adapter between Flight middleware and a gRPC interceptor.
ServerInterceptorAdapter(List<ServerInterceptorAdapter.KeyFactory<?>>) - Constructor for class org.apache.arrow.flight.grpc.ServerInterceptorAdapter
 
ServerInterceptorAdapter.KeyFactory<T extends FlightServerMiddleware> - Class in org.apache.arrow.flight.grpc
A combination of a middleware Key and factory.
SERVICE - Static variable in interface org.apache.arrow.flight.FlightConstants
 
SERVICE_NAME - Static variable in class org.apache.arrow.flight.impl.FlightServiceGrpc
 
setAppMetadata(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Application-defined metadata.
setAppMetadata(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
bytes app_metadata = 1;
setAuthHandler(ClientAuthHandler) - Method in class org.apache.arrow.flight.auth.ClientAuthInterceptor
 
setBody(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
bytes body = 2;
setBody(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
bytes body = 1;
setCmd(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
Opaque value used to express a command.
setDataBody(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The actual batch of Arrow data.
setDataHeader(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
Header for message data as described in Message.fbs::Message.
setDefinition(PerfOuterClass.Perf) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
setDefinition(PerfOuterClass.Perf.Builder) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
definition of entire flight.
setDescription(String) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string description = 2;
setDescriptionBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string description = 2;
setEnd(long) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
exclusive end
setEndpoint(int, Flight.FlightEndpoint) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
setEndpoint(int, Flight.FlightEndpoint.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
A list of endpoints associated with the flight.
setExpression(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
bytes expression = 1;
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
setFlightDescriptor(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
setFlightDescriptor(Flight.FlightDescriptor.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
The descriptor of the data.
setFlightDescriptor(Flight.FlightDescriptor) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
setFlightDescriptor(Flight.FlightDescriptor.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
The descriptor associated with this info.
setLocation(Location) - Method in class org.apache.arrow.flight.example.InMemoryStore
Update the location after server start.
setLocation(int, Flight.Location) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
setLocation(int, Flight.Location.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
A list of URIs where this ticket can be redeemed.
setOnCancelHandler(Runnable) - Method in interface org.apache.arrow.flight.FlightProducer.ServerStreamListener
Set a callback for when the client cancels a call, i.e.
setOnReadyHandler(Runnable) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Set a callback for when the listener is ready for new calls to putNext(), i.e.
setPassword(String) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string password = 3;
setPasswordBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string password = 3;
setPath(int, String) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
List of strings identifying a particular dataset.
setPayload(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
Arbitrary auth/handshake info.
setPayload(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
Arbitrary auth/handshake info.
setProtocolVersion(long) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
A defined protocol version
setProtocolVersion(long) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
A defined protocol version
setRecordsPerBatch(int) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 records_per_batch = 4;
setRecordsPerStream(long) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int64 records_per_stream = 3;
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
setSchema(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
schema of the dataset as described in Schema.fbs::Schema.
setSchema(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
schema of the dataset as described in Schema.fbs::Schema.
setSchema(ByteString) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
bytes schema = 1;
setStart(long) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
inclusive start
setStreamCount(int) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
int32 stream_count = 2;
setTicket(Flight.Ticket) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
setTicket(Flight.Ticket.Builder) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
Token used to retrieve this stream.
setTicket(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
bytes ticket = 1;
setTotalBytes(long) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
int64 total_bytes = 5;
setTotalRecords(long) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
Set these to -1 if unknown.
setType(String) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
string type = 1;
setType(String) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string type = 1;
setType(Flight.FlightDescriptor.DescriptorType) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
setTypeBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
string type = 1;
setTypeBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
string type = 1;
setTypeValue(int) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
.arrow.flight.protocol.FlightDescriptor.DescriptorType type = 1;
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Action.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.ActionType.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Criteria.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Empty.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightData.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.PutResult.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Result.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.impl.Flight.Ticket.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token.Builder
 
setUri(String) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
string uri = 1;
setUriBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.Location.Builder
string uri = 1;
setUsername(String) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string username = 2;
setUsernameBytes(ByteString) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth.Builder
string username = 2;
setUseZeroCopy(boolean) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Toggle whether to ues the zero-copy write optimization.
shouldContinueWaiting(FlightProducer.ServerStreamListener, long) - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
Callback function to run to check if the listener should continue to be waited on if it leaves the waiting state without being cancelled, ready, or timed out.
shutdown() - Method in class org.apache.arrow.flight.FlightServer
Request that the server shut down.
shutdown() - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
shutdownNow() - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
start() - Method in class org.apache.arrow.flight.example.ExampleFlightServer
 
start() - Method in class org.apache.arrow.flight.FlightServer
Start the server.
start(VectorSchemaRoot) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Start sending data, using the schema of the given VectorSchemaRoot.
start(VectorSchemaRoot, DictionaryProvider) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Start sending data, using the schema of the given VectorSchemaRoot.
start(VectorSchemaRoot, DictionaryProvider, IpcOption) - Method in interface org.apache.arrow.flight.OutboundStreamListener
Start sending data, using the schema of the given VectorSchemaRoot.
START_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
startPut(FlightDescriptor, VectorSchemaRoot, FlightClient.PutListener, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Create or append a descriptor with another stream.
startPut(FlightDescriptor, VectorSchemaRoot, DictionaryProvider, FlightClient.PutListener, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Create or append a descriptor with another stream.
startPut(FlightDescriptor, FlightClient.PutListener, CallOption...) - Method in class org.apache.arrow.flight.FlightClient
Create or append a descriptor with another stream.
status() - Method in exception org.apache.arrow.flight.FlightRuntimeException
 
StatusUtils - Class in org.apache.arrow.flight.grpc
Utilities to adapt gRPC and Flight status objects.
Stream - Class in org.apache.arrow.flight.example
A collection of Arrow record batches.
Stream(Schema, DictionaryProvider, List<ArrowRecordBatch>, long) - Constructor for class org.apache.arrow.flight.example.Stream
Create a new instance.
Stream.StreamCreator - Class in org.apache.arrow.flight.example
Provides the functionality to create a new stream by adding batches serially.
STREAM_COUNT_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
StreamCreator(Schema, DictionaryProvider, BufferAllocator, Consumer<Stream>) - Constructor for class org.apache.arrow.flight.example.Stream.StreamCreator
Creates a new instance.
submit(Callable<T>) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
submit(Runnable, T) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
submit(Runnable) - Method in class org.apache.arrow.flight.grpc.ContextPropagatingExecutorService
 
SyncPutListener - Class in org.apache.arrow.flight
A listener for server-sent application metadata messages during a Flight DoPut.
SyncPutListener() - Constructor for class org.apache.arrow.flight.SyncPutListener
 

T

takeDictionaryOwnership() - Method in class org.apache.arrow.flight.FlightStream
Get an owned reference to the dictionaries in this stream.
thisUsesUnstableApi() - Method in class org.apache.arrow.flight.grpc.CallCredentialAdapter
 
Ticket - Class in org.apache.arrow.flight
Endpoint for a particular stream.
Ticket(byte[]) - Constructor for class org.apache.arrow.flight.Ticket
 
TICKET_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
TICKET_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Ticket
 
TIMED_OUT - Static variable in class org.apache.arrow.flight.CallStatus
 
timeout(long, TimeUnit) - Static method in class org.apache.arrow.flight.CallOptions
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Action
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Location
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Result
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
toBuilder() - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
toBuilder() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
toBuilder() - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
toGrpcException(Throwable) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert arbitrary exceptions to a StatusRuntimeException or StatusException.
toGrpcStatus(CallStatus) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a Flight status to a gRPC status.
toGrpcStatusCode(FlightStatusCode) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Convert from a Flight status code to a gRPC status code.
TOKEN_KEY - Static variable in class org.apache.arrow.flight.auth.AuthConstants
 
TOKEN_NAME - Static variable in class org.apache.arrow.flight.auth.AuthConstants
 
toRuntimeException() - Method in class org.apache.arrow.flight.CallStatus
Convert the status to an equivalent exception.
toStatus() - Method in enum org.apache.arrow.flight.FlightStatusCode
Create a blank CallStatus with this code.
toString() - Method in class org.apache.arrow.flight.ActionType
 
toString() - Method in class org.apache.arrow.flight.CallStatus
 
toString() - Method in class org.apache.arrow.flight.FlightCallHeaders
 
toString() - Method in class org.apache.arrow.flight.FlightDescriptor
 
toString() - Method in class org.apache.arrow.flight.FlightEndpoint
 
toString() - Method in class org.apache.arrow.flight.FlightInfo
 
toString() - Method in exception org.apache.arrow.flight.FlightRuntimeException
 
toString() - Method in class org.apache.arrow.flight.grpc.MetadataAdapter
 
toString() - Method in class org.apache.arrow.flight.Location
 
TOTAL_BYTES_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
TOTAL_RECORDS_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
toTicket() - Method in class org.apache.arrow.flight.example.ExampleTicket
Creates a new protocol buffer Ticket by serializing to JSON.
transportHint(String, Object) - Method in class org.apache.arrow.flight.FlightServer.Builder
Provide a transport-specific option.
trustedCertificates(InputStream) - Method in class org.apache.arrow.flight.FlightClient.Builder
Set the trusted TLS certificates.
TYPE_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Action
 
TYPE_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.ActionType
 
TYPE_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 

U

UNAUTHENTICATED - Static variable in class org.apache.arrow.flight.CallStatus
 
UNAUTHORIZED - Static variable in class org.apache.arrow.flight.CallStatus
 
UNAVAILABLE - Static variable in class org.apache.arrow.flight.CallStatus
 
UNIMPLEMENTED - Static variable in class org.apache.arrow.flight.CallStatus
 
UNKNOWN - Static variable in class org.apache.arrow.flight.CallStatus
 
UNKNOWN_VALUE - Static variable in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
Protobuf pattern, not used.
URI_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.Location
 
USERNAME_FIELD_NUMBER - Static variable in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
useTls() - Method in class org.apache.arrow.flight.FlightClient.Builder
Force the client to connect over TLS.
useTls(File, File) - Method in class org.apache.arrow.flight.FlightServer.Builder
Enable TLS on the server.
useTls(InputStream, InputStream) - Method in class org.apache.arrow.flight.FlightServer.Builder
Enable TLS on the server.

V

validate(String, String) - Method in interface org.apache.arrow.flight.auth2.BasicCallHeaderAuthenticator.CredentialValidator
Validate the supplied credentials (username/password) and return the peer identity.
validateBearer(String) - Method in class org.apache.arrow.flight.auth2.BearerTokenAuthenticator
Validate the bearer token.
validateBearer(String) - Method in class org.apache.arrow.flight.auth2.GeneratedBearerTokenAuthenticator
 
valueOf(String) - Static method in enum org.apache.arrow.flight.BackpressureStrategy.WaitResult
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.arrow.flight.FlightMethod
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.arrow.flight.FlightStatusCode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
Returns the enum constant of this type with the specified name.
valueOf(int) - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
 
values() - Static method in enum org.apache.arrow.flight.BackpressureStrategy.WaitResult
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.arrow.flight.FlightMethod
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.arrow.flight.FlightStatusCode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.arrow.flight.impl.Flight.FlightDescriptor.DescriptorType
Returns an array containing the constants of this enum type, in the order they are declared.
verify(ExampleTicket) - Method in class org.apache.arrow.flight.example.Stream
Throws an IllegalStateException if the given ticket doesn't correspond to this stream.
verifyServer(boolean) - Method in class org.apache.arrow.flight.FlightClient.Builder
 

W

waitForListener(long) - Method in class org.apache.arrow.flight.BackpressureStrategy.CallbackBackpressureStrategy
 
waitForListener(long) - Method in interface org.apache.arrow.flight.BackpressureStrategy
Waits for the listener to be ready or cancelled up to the given timeout.
withCause(Throwable) - Method in class org.apache.arrow.flight.CallStatus
Return a copy of this status with the given exception as the cause.
withDescription(String) - Method in class org.apache.arrow.flight.CallStatus
Return a copy of this status with an error message.
withMetadata(ErrorFlightMetadata) - Method in class org.apache.arrow.flight.CallStatus
Return a copy of this status with associated exception metadata.
wrapHandshake(ServerAuthHandler, StreamObserver<Flight.HandshakeResponse>, ExecutorService) - Static method in class org.apache.arrow.flight.auth.ServerAuthWrapper
Wrap the auth handler for handshake purposes.
wrapIterator(Iterator<FROM>, Function<? super FROM, ? extends TO>) - Static method in class org.apache.arrow.flight.grpc.StatusUtils
Maps a transformation function to the elements of an iterator, while wrapping exceptions in FlightRuntimeException.
wrapStub(T) - Method in interface org.apache.arrow.flight.CallOptions.GrpcCallOption
 
wrapStub(T) - Method in class org.apache.arrow.flight.grpc.CredentialCallOption
 
wrapStub(T) - Method in class org.apache.arrow.flight.HeaderCallOption
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Action
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.ActionType
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.BasicAuth
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Criteria
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Empty
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.FlightData
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.FlightDescriptor
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.FlightEndpoint
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.FlightInfo
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeRequest
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.HandshakeResponse
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Location
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.PutResult
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Result
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.SchemaResult
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.impl.Flight.Ticket
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Perf
 
writeTo(CodedOutputStream) - Method in class org.apache.arrow.flight.perf.impl.PerfOuterClass.Token
 
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links

Copyright © 2021 The Apache Software Foundation. All rights reserved.