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
stream
Stream
ArrowFileReader(Stream, ICompressionCodecFactory)
public ArrowFileReader(Stream stream, ICompressionCodecFactory compressionCodecFactory)
Parameters
stream
StreamcompressionCodecFactory
ICompressionCodecFactory
ArrowFileReader(Stream, MemoryAllocator)
public ArrowFileReader(Stream stream, MemoryAllocator allocator)
Parameters
stream
Streamallocator
MemoryAllocator
ArrowFileReader(Stream, MemoryAllocator, ICompressionCodecFactory)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory)
Parameters
stream
Streamallocator
MemoryAllocatorcompressionCodecFactory
ICompressionCodecFactory
ArrowFileReader(Stream, MemoryAllocator, ICompressionCodecFactory, bool)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen)
Parameters
stream
Streamallocator
MemoryAllocatorcompressionCodecFactory
ICompressionCodecFactoryleaveOpen
bool
ArrowFileReader(Stream, MemoryAllocator, bool)
public ArrowFileReader(Stream stream, MemoryAllocator allocator, bool leaveOpen)
Parameters
stream
Streamallocator
MemoryAllocatorleaveOpen
bool
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
filename
string
Returns
ReadRecordBatchAsync(int, CancellationToken)
public ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellationToken = default)
Parameters
index
intcancellationToken
CancellationToken
Returns
RecordBatchCountAsync()
public ValueTask<int> RecordBatchCountAsync()