Top | ![]() |
![]() |
![]() |
![]() |
GAFlightRecordBatchStream * | gaflight_record_batch_stream_new () |
GAFlightServerOptions * | gaflight_server_options_new () |
gboolean | gaflight_server_listen () |
gint | gaflight_server_get_port () |
gboolean | gaflight_server_shutdown () |
gboolean | gaflight_server_wait () |
GList * | gaflight_server_list_flights () |
GAFlightInfo * | gaflight_server_get_flight_info () |
GAFlightDataStream * | gaflight_server_do_get () |
gpointer | stream | Write / Construct Only |
GArrowRecordBatchReader * | reader | Read / Write / Construct Only |
gpointer | call-context | Write / Construct Only |
GAFlightLocation * | location | Read / Write / Construct Only |
GInterface ╰── GAFlightServable GObject ├── GAFlightDataStream │ ╰── GAFlightRecordBatchStream ├── GAFlightServer ├── GAFlightServerCallContext ╰── GAFlightServerOptions
GAFlightDataStream is a class for producing a sequence of IPC
payloads to be sent in FlightData
protobuf messages. Generally,
this is not used directly. Generally, GAFlightRecordBatchStream is
used instead.
GAFlightRecordBatchStream is a class for producing a sequence of
IPC payloads to be sent in FlightData
protobuf messages by
GArrowRecordBatchReader`.
GAFlightServerOptions is a class for options of each server.
GAFlightServerCallContext is a class for context of each server call.
GAFlightServer is a class to develop an Apache Arrow Flight server.
GAFlightRecordBatchStream * gaflight_record_batch_stream_new (GArrowRecordBatchReader *reader
,GArrowWriteOptions *options
);
reader |
A GArrowRecordBatchReader to be read. |
|
options |
A GArrowWriteOptions for writing record batches to a client. |
[nullable] |
Since: 6.0.0
GAFlightServerOptions *
gaflight_server_options_new (GAFlightLocation *location
);
Since: 5.0.0
gboolean gaflight_server_listen (GAFlightServer *server
,GAFlightServerOptions *options
,GError **error
);
Since: 5.0.0
gboolean gaflight_server_shutdown (GAFlightServer *server
,GError **error
);
Shuts down the serve. This function can be called from signal handler or another thread.
Since: 5.0.0
GList * gaflight_server_list_flights (GAFlightServer *server
,GAFlightServerCallContext *context
,GAFlightCriteria *criteria
,GError **error
);
server |
||
context |
||
criteria |
[nullable] | |
error |
Return location for a GError or |
[nullable] |
Since: 5.0.0
GAFlightInfo * gaflight_server_get_flight_info (GAFlightServer *server
,GAFlightServerCallContext *context
,GAFlightDescriptor *request
,GError **error
);
Since: 9.0.0
GAFlightDataStream * gaflight_server_do_get (GAFlightServer *server
,GAFlightServerCallContext *context
,GAFlightTicket *ticket
,GError **error
);
Since: 6.0.0
struct GAFlightRecordBatchStreamClass { GAFlightDataStreamClass parent_class; };
#define GAFLIGHT_TYPE_SERVER_OPTIONS (gaflight_server_options_get_type())
struct GAFlightServerCallContextClass { GObjectClass parent_class; };
struct GAFlightServerClass { GObjectClass parent_class; GList *(*list_flights)(GAFlightServer *server, GAFlightServerCallContext *context, GAFlightCriteria *criteria, GError **error); GAFlightInfo *(*get_flight_info)(GAFlightServer *server, GAFlightServerCallContext *context, GAFlightDescriptor *request, GError **error); GAFlightDataStream *(*do_get)(GAFlightServer *server, GAFlightServerCallContext *context, GAFlightTicket *ticket, GError **error); };
Since: 5.0.0
“stream”
property “stream” gpointer
The raw arrow::flight::FlightDataStream *.
Owner: GAFlightDataStream
Flags: Write / Construct Only
“reader”
property “reader” GArrowRecordBatchReader *
The reader that produces record batches.
Owner: GAFlightRecordBatchStream
Flags: Read / Write / Construct Only
Since: 6.0.0
“call-context”
property “call-context” gpointer
The raw arrow::flight::ServerCallContext.
Owner: GAFlightServerCallContext
Flags: Write / Construct Only
“location”
property“location” GAFlightLocation *
The location to be listened.
Owner: GAFlightServerOptions
Flags: Read / Write / Construct Only