arrow.stream_listener

Module for [StreamListener] class

Types 3

Methods
GType _getGType() static nothrow
GType _gType() @property nothrow
StreamListener self() nothrowReturns `this`, for use in `with` statements.
StreamListenerGidBuilder builder() static nothrowGet builder for [arrow.stream_listener.StreamListener] Returns: New builder object
bool onEos()Processes an EOS event. Returns: true on success, false on error. Throws: [ErrorWrap]
bool onRecordBatchDecoded(arrow.record_batch.RecordBatch recordBatch, string[string] metadata = null)Processes a decoded record batch.
bool onSchemaDecoded(arrow.schema.Schema schema, arrow.schema.Schema filteredSchema)Processes a decoded schema.
Constructors
this(void * ptr, Flag!"Take" take)
Methods
StreamListener build() nothrowCreate object from builder. Returns: New object