namespace Apache.Arrow.Ipc { public class ArrowStreamWriter : IDisposable { protected Stream BaseStream { get; } protected bool HasWrittenSchema { get; set; } protected Schema Schema { get; } public ArrowStreamWriter(Stream baseStream, Schema schema); public ArrowStreamWriter(Stream baseStream, Schema schema, bool leaveOpen); public ArrowStreamWriter(Stream baseStream, Schema schema, bool leaveOpen, IpcOptions options); public ArrowStreamWriter(Stream baseStream, Schema schema, bool leaveOpen, IpcOptions options, MemoryAllocator allocator); public virtual void WriteRecordBatch(RecordBatch recordBatch); public virtual Task WriteRecordBatchAsync(RecordBatch recordBatch, CancellationToken cancellationToken = default(CancellationToken)); public void WriteStart(); public Task WriteStartAsync(CancellationToken cancellationToken = default(CancellationToken)); public void WriteEnd(); public Task WriteEndAsync(CancellationToken cancellationToken = default(CancellationToken)); protected int CalculatePadding(long offset, int alignment = 8); public virtual void Dispose(); } }