Class ArrowFileReader
Implements an ArrowStreamReader that can read Arrow files.
public class ArrowFileReader : ArrowStreamReader, IArrowArrayStream, IArrowReader, IDisposable- Inheritance
- 
      
      
      ArrowFileReader
- Implements
- Inherited Members
Constructors
ArrowFileReader(Stream)
public ArrowFileReader(Stream stream)Parameters
- streamStream
ArrowFileReader(Stream, ICompressionCodecFactory)
public ArrowFileReader(Stream stream, ICompressionCodecFactory compressionCodecFactory)Parameters
- streamStream
- compressionCodecFactoryICompressionCodecFactory
ArrowFileReader(Stream, MemoryAllocator)
public ArrowFileReader(Stream stream, MemoryAllocator allocator)Parameters
- streamStream
- allocatorMemoryAllocator
ArrowFileReader(Stream, MemoryAllocator, ICompressionCodecFactory)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory)Parameters
- streamStream
- allocatorMemoryAllocator
- compressionCodecFactoryICompressionCodecFactory
ArrowFileReader(Stream, MemoryAllocator, ICompressionCodecFactory, bool)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen)Parameters
- streamStream
- allocatorMemoryAllocator
- compressionCodecFactoryICompressionCodecFactory
- leaveOpenbool
ArrowFileReader(Stream, MemoryAllocator, bool)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, bool leaveOpen)Parameters
- streamStream
- allocatorMemoryAllocator
- leaveOpenbool
ArrowFileReader(Stream, bool)
public ArrowFileReader(Stream stream, bool leaveOpen)Parameters
Properties
IsFileValid
public bool IsFileValid { get; }Property Value
Methods
FromFile(string)
public static ArrowFileReader FromFile(string filename)Parameters
- filenamestring
Returns
ReadRecordBatchAsync(int, CancellationToken)
public ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellationToken = default)Parameters
- indexint
- cancellationTokenCancellationToken
Returns
RecordBatchCountAsync()
public ValueTask<int> RecordBatchCountAsync()