Package | Description |
---|---|
org.apache.arrow.flight.impl |
Modifier and Type | Method and Description |
---|---|
Flight.FlightData |
Flight.FlightData.Builder.build() |
Flight.FlightData |
Flight.FlightData.Builder.buildPartial() |
static Flight.FlightData |
Flight.FlightData.getDefaultInstance() |
Flight.FlightData |
Flight.FlightData.getDefaultInstanceForType() |
Flight.FlightData |
Flight.FlightData.Builder.getDefaultInstanceForType() |
static Flight.FlightData |
Flight.FlightData.parseDelimitedFrom(InputStream input) |
static Flight.FlightData |
Flight.FlightData.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Flight.FlightData |
Flight.FlightData.parseFrom(byte[] data) |
static Flight.FlightData |
Flight.FlightData.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Flight.FlightData |
Flight.FlightData.parseFrom(ByteBuffer data) |
static Flight.FlightData |
Flight.FlightData.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Flight.FlightData |
Flight.FlightData.parseFrom(com.google.protobuf.ByteString data) |
static Flight.FlightData |
Flight.FlightData.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Flight.FlightData |
Flight.FlightData.parseFrom(com.google.protobuf.CodedInputStream input) |
static Flight.FlightData |
Flight.FlightData.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Flight.FlightData |
Flight.FlightData.parseFrom(InputStream input) |
static Flight.FlightData |
Flight.FlightData.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
default io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.AsyncService.doExchange(io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Open a bidirectional data channel for a given descriptor.
|
io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.FlightServiceStub.doExchange(io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Open a bidirectional data channel for a given descriptor.
|
Iterator<Flight.FlightData> |
FlightServiceGrpc.FlightServiceBlockingStub.doGet(Flight.Ticket request)
Retrieve a single stream associated with a particular descriptor
associated with the referenced ticket.
|
default io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.AsyncService.doPut(io.grpc.stub.StreamObserver<Flight.PutResult> responseObserver)
Push a stream to the flight service associated with a particular
flight stream.
|
io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.FlightServiceStub.doPut(io.grpc.stub.StreamObserver<Flight.PutResult> responseObserver)
Push a stream to the flight service associated with a particular
flight stream.
|
static io.grpc.MethodDescriptor<Flight.FlightData,Flight.FlightData> |
FlightServiceGrpc.getDoExchangeMethod() |
static io.grpc.MethodDescriptor<Flight.FlightData,Flight.FlightData> |
FlightServiceGrpc.getDoExchangeMethod() |
static io.grpc.MethodDescriptor<Flight.Ticket,Flight.FlightData> |
FlightServiceGrpc.getDoGetMethod() |
static io.grpc.MethodDescriptor<Flight.FlightData,Flight.PutResult> |
FlightServiceGrpc.getDoPutMethod() |
com.google.protobuf.Parser<Flight.FlightData> |
Flight.FlightData.getParserForType() |
static com.google.protobuf.Parser<Flight.FlightData> |
Flight.FlightData.parser() |
Modifier and Type | Method and Description |
---|---|
Flight.FlightData.Builder |
Flight.FlightData.Builder.mergeFrom(Flight.FlightData other) |
static Flight.FlightData.Builder |
Flight.FlightData.newBuilder(Flight.FlightData prototype) |
Modifier and Type | Method and Description |
---|---|
default io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.AsyncService.doExchange(io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Open a bidirectional data channel for a given descriptor.
|
io.grpc.stub.StreamObserver<Flight.FlightData> |
FlightServiceGrpc.FlightServiceStub.doExchange(io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Open a bidirectional data channel for a given descriptor.
|
default void |
FlightServiceGrpc.AsyncService.doGet(Flight.Ticket request,
io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Retrieve a single stream associated with a particular descriptor
associated with the referenced ticket.
|
void |
FlightServiceGrpc.FlightServiceStub.doGet(Flight.Ticket request,
io.grpc.stub.StreamObserver<Flight.FlightData> responseObserver)
Retrieve a single stream associated with a particular descriptor
associated with the referenced ticket.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.