| 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 |
SyncPutListener.onNext(PutResult val) |
void |
FlightClient.PutListener.onNext(PutResult val)
Called when a message from the server is received.
|
void |
AsyncPutListener.onNext(PutResult val) |
| Modifier and Type | Method and Description |
|---|---|
Runnable |
NoOpFlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
Runnable |
FlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.