Uses of Class
org.apache.arrow.flight.impl.Flight.FlightData
Packages that use Flight.FlightData
-
Uses of Flight.FlightData in org.apache.arrow.flight.impl
Methods in org.apache.arrow.flight.impl that return Flight.FlightDataModifier and TypeMethodDescriptionFlight.FlightData.Builder.build()Flight.FlightData.Builder.buildPartial()static Flight.FlightDataFlight.FlightData.getDefaultInstance()Flight.FlightData.Builder.getDefaultInstanceForType()Flight.FlightData.getDefaultInstanceForType()static Flight.FlightDataFlight.FlightData.parseDelimitedFrom(InputStream input) static Flight.FlightDataFlight.FlightData.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static Flight.FlightDataFlight.FlightData.parseFrom(byte[] data) static Flight.FlightDataFlight.FlightData.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static Flight.FlightDataFlight.FlightData.parseFrom(com.google.protobuf.ByteString data) static Flight.FlightDataFlight.FlightData.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static Flight.FlightDataFlight.FlightData.parseFrom(com.google.protobuf.CodedInputStream input) static Flight.FlightDataFlight.FlightData.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static Flight.FlightDataFlight.FlightData.parseFrom(InputStream input) static Flight.FlightDataFlight.FlightData.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static Flight.FlightDataFlight.FlightData.parseFrom(ByteBuffer data) static Flight.FlightDataFlight.FlightData.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) Methods in org.apache.arrow.flight.impl that return types with arguments of type Flight.FlightDataModifier and TypeMethodDescriptiondefault 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.BlockingClientCall<Flight.FlightData,Flight.FlightData> FlightServiceGrpc.FlightServiceBlockingV2Stub.doExchange()Open a bidirectional data channel for a given descriptor.io.grpc.stub.BlockingClientCall<Flight.FlightData,Flight.FlightData> FlightServiceGrpc.FlightServiceBlockingV2Stub.doExchange()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.FlightServiceGrpc.FlightServiceBlockingStub.doGet(Flight.Ticket request) Retrieve a single stream associated with a particular descriptor associated with the referenced ticket.io.grpc.stub.BlockingClientCall<?,Flight.FlightData> FlightServiceGrpc.FlightServiceBlockingV2Stub.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.BlockingClientCall<Flight.FlightData,Flight.PutResult> FlightServiceGrpc.FlightServiceBlockingV2Stub.doPut()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()Methods in org.apache.arrow.flight.impl with parameters of type Flight.FlightDataModifier and TypeMethodDescriptionFlight.FlightData.Builder.mergeFrom(Flight.FlightData other) static Flight.FlightData.BuilderFlight.FlightData.newBuilder(Flight.FlightData prototype) Method parameters in org.apache.arrow.flight.impl with type arguments of type Flight.FlightDataModifier and TypeMethodDescriptiondefault 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 voidFlightServiceGrpc.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.voidFlightServiceGrpc.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.