Class FlightClientRecordBatchStreamWriter

Namespace

Apache.Arrow.Flight.Client

Assembly

Apache.Arrow.Flight.dll

public class FlightClientRecordBatchStreamWriter : FlightRecordBatchStreamWriter, IDisposable, IClientStreamWriter<RecordBatch>, IAsyncStreamWriter<RecordBatch>

Inheritance

object

FlightRecordBatchStreamWriter

FlightClientRecordBatchStreamWriter

Implements

IDisposable

IClientStreamWriter<RecordBatch>

IAsyncStreamWriter<RecordBatch>

Inherited Members

FlightRecordBatchStreamWriter.SetupStream(Schema)

FlightRecordBatchStreamWriter.WriteOptions

FlightRecordBatchStreamWriter.WriteAsync(RecordBatch)

FlightRecordBatchStreamWriter.WriteAsync(RecordBatch, ByteString)

FlightRecordBatchStreamWriter.Dispose()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

CompleteAsync()

Completes/closes the stream. Can only be called once there is no pending write. No writes should follow calling this.

public Task CompleteAsync()

Returns

Task

Dispose(bool)

protected override void Dispose(bool disposing)

Parameters

disposing bool