arrow.stream_listener
Module for StreamListener class
Types 3
Methods
StreamListener self()Returns `this`, for use in `with` statements.StreamListenerGidBuilder builder()Get builder for [arrow.stream_listener.StreamListener] Returns: New builder objectbool 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.Fluent builder implementation template for arrow.stream_listener.StreamListener
Fluent builder for arrow.stream_listener.StreamListener
Methods
StreamListener build()Create object from builder. Returns: New object