Package | Description |
---|---|
org.apache.arrow.flight | |
org.apache.arrow.flight.integration.tests | |
org.apache.arrow.flight.sql |
Modifier and Type | Method and Description |
---|---|
static PutResult |
PutResult.empty()
Create an empty PutResult.
|
static PutResult |
PutResult.metadata(ArrowBuf metadata)
Create a PutResult with application-specific metadata.
|
PutResult |
SyncPutListener.poll(long timeout,
TimeUnit unit)
Get the next message from the server, blocking for the specified amount of time until it is available.
|
PutResult |
SyncPutListener.read()
Get the next message from the server, blocking until it is available.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncPutListener.onNext(PutResult val) |
void |
SyncPutListener.onNext(PutResult val) |
void |
FlightClient.PutListener.onNext(PutResult val)
Called when a message from the server is received.
|
Modifier and Type | Method and Description |
---|---|
Runnable |
FlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
Runnable |
NoOpFlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
Copyright © 2024 The Apache Software Foundation. All rights reserved.