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 |
FlightClient.PutListener.onNext(PutResult val)
Called when a message from the server is received.
|
void |
SyncPutListener.onNext(PutResult val) |
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.
|
Modifier and Type | Method and Description |
---|---|
default Runnable |
FlightSqlProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Depending on the provided command, method either:
1.
|
Runnable |
FlightSqlProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded parameter values for a particular prepared statement query.
|
Runnable |
FlightSqlProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded data for a particular prepared statement data stream.
|
Runnable |
FlightSqlProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accepts uploaded data for a particular SQL query based data stream.
|
default Runnable |
FlightSqlProducer.acceptPutSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command,
FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Handle a Substrait plan with uploaded data.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.