Home
last modified time | relevance | path

Searched refs:ReadRecordBatchAsync (Results 1 – 15 of 15) sorted by relevance

/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/test/Apache.Arrow.Tests/
H A DArrowFileReaderTests.cs106 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
110 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
149 RecordBatch readBatch1 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
152 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(1); in TestReadMultipleRecordBatchAsync()
156 RecordBatch readBatch3 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
H A DArrowFileWriterTests.cs114 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in ValidateRecordBatchFile()
/dports/databases/arrow/apache-arrow-6.0.1/csharp/test/Apache.Arrow.Tests/
H A DArrowFileReaderTests.cs106 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
110 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
147 RecordBatch readBatch1 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
150 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(1); in TestReadMultipleRecordBatchAsync()
154 RecordBatch readBatch3 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
H A DArrowFileWriterTests.cs114 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in ValidateRecordBatchFile()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/test/Apache.Arrow.Tests/
H A DArrowFileReaderTests.cs106 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
110 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(0); in TestReadRecordBatchAsync()
149 RecordBatch readBatch1 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
152 RecordBatch readBatch2 = await reader.ReadRecordBatchAsync(1); in TestReadMultipleRecordBatchAsync()
156 RecordBatch readBatch3 = await reader.ReadRecordBatchAsync(0); in TestReadMultipleRecordBatchAsync()
H A DArrowFileWriterTests.cs81 RecordBatch readBatch = await reader.ReadRecordBatchAsync(0); in WritesFooterAlignedMulitpleOf8()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Ipc/
H A DArrowFileReader.cs64 …public ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellationToken … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReader
66 return Implementation.ReadRecordBatchAsync(index, cancellationToken); in ReadRecordBatchAsync()
H A DArrowFileReaderImplementation.cs143 …public async ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellation… in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReaderImplementation
156 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadRecordBatchAsync()
184 …RecordBatch result = await ReadRecordBatchAsync(_recordBatchIndex, cancellationToken).ConfigureAwa… in ReadNextRecordBatchAsync()
H A DArrowStreamReaderImplementation.cs50 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadNextRecordBatchAsync()
58 …protected async ValueTask<RecordBatch> ReadRecordBatchAsync(CancellationToken cancellationToken = … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowStreamReaderImplementation
/dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow/Ipc/
H A DArrowFileReader.cs64 …public ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellationToken … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReader
66 return Implementation.ReadRecordBatchAsync(index, cancellationToken); in ReadRecordBatchAsync()
H A DArrowFileReaderImplementation.cs143 …public async ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellation… in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReaderImplementation
156 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadRecordBatchAsync()
184 …RecordBatch result = await ReadRecordBatchAsync(_recordBatchIndex, cancellationToken).ConfigureAwa… in ReadNextRecordBatchAsync()
H A DArrowStreamReaderImplementation.cs48 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadNextRecordBatchAsync()
56 …protected async ValueTask<RecordBatch> ReadRecordBatchAsync(CancellationToken cancellationToken = … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowStreamReaderImplementation
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow/Ipc/
H A DArrowFileReader.cs64 …public ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellationToken … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReader
66 return Implementation.ReadRecordBatchAsync(index, cancellationToken); in ReadRecordBatchAsync()
H A DArrowFileReaderImplementation.cs143 …public async ValueTask<RecordBatch> ReadRecordBatchAsync(int index, CancellationToken cancellation… in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowFileReaderImplementation
156 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadRecordBatchAsync()
184 …RecordBatch result = await ReadRecordBatchAsync(_recordBatchIndex, cancellationToken).ConfigureAwa… in ReadNextRecordBatchAsync()
H A DArrowStreamReaderImplementation.cs50 return await ReadRecordBatchAsync(cancellationToken).ConfigureAwait(false); in ReadNextRecordBatchAsync()
58 …protected async ValueTask<RecordBatch> ReadRecordBatchAsync(CancellationToken cancellationToken = … in ReadRecordBatchAsync() method in Apache.Arrow.Ipc.ArrowStreamReaderImplementation