Table of Contents

Class FlightServer

Namespace
Apache.Arrow.Flight.Server
Assembly
Apache.Arrow.Flight.dll
public abstract class FlightServer
Inheritance
FlightServer
Derived
Inherited Members

Methods

DoAction(FlightAction, IAsyncStreamWriter<FlightResult>, ServerCallContext)

public virtual Task DoAction(FlightAction request, IAsyncStreamWriter<FlightResult> responseStream, ServerCallContext context)

Parameters

request FlightAction
responseStream IAsyncStreamWriter<FlightResult>
context ServerCallContext

Returns

Task

DoExchange(FlightServerRecordBatchStreamReader, FlightServerRecordBatchStreamWriter, ServerCallContext)

public virtual Task DoExchange(FlightServerRecordBatchStreamReader requestStream, FlightServerRecordBatchStreamWriter responseStream, ServerCallContext context)

Parameters

requestStream FlightServerRecordBatchStreamReader
responseStream FlightServerRecordBatchStreamWriter
context ServerCallContext

Returns

Task

DoGet(FlightTicket, FlightServerRecordBatchStreamWriter, ServerCallContext)

public virtual Task DoGet(FlightTicket ticket, FlightServerRecordBatchStreamWriter responseStream, ServerCallContext context)

Parameters

ticket FlightTicket
responseStream FlightServerRecordBatchStreamWriter
context ServerCallContext

Returns

Task

DoPut(FlightServerRecordBatchStreamReader, IAsyncStreamWriter<FlightPutResult>, ServerCallContext)

public virtual Task DoPut(FlightServerRecordBatchStreamReader requestStream, IAsyncStreamWriter<FlightPutResult> responseStream, ServerCallContext context)

Parameters

requestStream FlightServerRecordBatchStreamReader
responseStream IAsyncStreamWriter<FlightPutResult>
context ServerCallContext

Returns

Task

GetFlightInfo(FlightDescriptor, ServerCallContext)

public virtual Task<FlightInfo> GetFlightInfo(FlightDescriptor request, ServerCallContext context)

Parameters

request FlightDescriptor
context ServerCallContext

Returns

Task<FlightInfo>

GetSchema(FlightDescriptor, ServerCallContext)

public virtual Task<Schema> GetSchema(FlightDescriptor request, ServerCallContext context)

Parameters

request FlightDescriptor
context ServerCallContext

Returns

Task<Schema>

Handshake(IAsyncStreamReader<FlightHandshakeRequest>, IAsyncStreamWriter<FlightHandshakeResponse>, ServerCallContext)

public virtual Task Handshake(IAsyncStreamReader<FlightHandshakeRequest> requestStream, IAsyncStreamWriter<FlightHandshakeResponse> responseStream, ServerCallContext context)

Parameters

requestStream IAsyncStreamReader<FlightHandshakeRequest>
responseStream IAsyncStreamWriter<FlightHandshakeResponse>
context ServerCallContext

Returns

Task

ListActions(IAsyncStreamWriter<FlightActionType>, ServerCallContext)

public virtual Task ListActions(IAsyncStreamWriter<FlightActionType> responseStream, ServerCallContext context)

Parameters

responseStream IAsyncStreamWriter<FlightActionType>
context ServerCallContext

Returns

Task

ListFlights(FlightCriteria, IAsyncStreamWriter<FlightInfo>, ServerCallContext)

public virtual Task ListFlights(FlightCriteria request, IAsyncStreamWriter<FlightInfo> responseStream, ServerCallContext context)

Parameters

request FlightCriteria
responseStream IAsyncStreamWriter<FlightInfo>
context ServerCallContext

Returns

Task