Search
Preparing search index...
The search index is not available
Apache Arrow - v9.0.0
Options
All
Public
Public/Protected
All
Inherited
Menu
Apache Arrow - v9.0.0
Arrow.dom
RecordBatchReader
Class RecordBatchReader<T>
Type Parameters
T
extends
TypeMap
=
any
Hierarchy
ReadableInterop
<
RecordBatch
<
T
>
>
RecordBatchReader
Index
Accessors
auto
Destroy
closed
dictionaries
footer
num
Dictionaries
num
Record
Batches
schema
Methods
[async
Iterator]
[iterator]
cancel
is
Async
is
File
is
Stream
is
Sync
next
open
pipe
pipe
Through
pipe
To
read
Record
Batch
reset
return
tee
throw
toDOMStream
to
Node
Stream
from
read
All
throughDOM
through
Node
Accessors
auto
Destroy
get
autoDestroy
(
)
:
boolean
Returns
boolean
closed
get
closed
(
)
:
boolean
Returns
boolean
dictionaries
get
dictionaries
(
)
:
Map
<
number
,
Vector
<
any
>
>
Returns
Map
<
number
,
Vector
<
any
>
>
footer
get
footer
(
)
:
null
|
Footer_
Returns
null
|
Footer_
num
Dictionaries
get
numDictionaries
(
)
:
number
Returns
number
num
Record
Batches
get
numRecordBatches
(
)
:
number
Returns
number
schema
get
schema
(
)
:
Schema
<
T
>
Returns
Schema
<
T
>
Methods
[async
Iterator]
[async
Iterator]
(
)
:
AsyncIterableIterator
<
RecordBatch
<
T
>
>
Returns
AsyncIterableIterator
<
RecordBatch
<
T
>
>
[iterator]
[iterator]
(
)
:
IterableIterator
<
RecordBatch
<
T
>
>
Returns
IterableIterator
<
RecordBatch
<
T
>
>
cancel
cancel
(
)
:
void
|
Promise
<
void
>
Returns
void
|
Promise
<
void
>
is
Async
is
Async
(
)
:
this
is
AsyncRecordBatchReaders
<
T
>
Returns
this
is
AsyncRecordBatchReaders
<
T
>
is
File
is
File
(
)
:
this
is
RecordBatchFileReaders
<
T
>
Returns
this
is
RecordBatchFileReaders
<
T
>
is
Stream
is
Stream
(
)
:
this
is
RecordBatchStreamReaders
<
T
>
Returns
this
is
RecordBatchStreamReaders
<
T
>
is
Sync
is
Sync
(
)
:
this
is
RecordBatchReaders
<
T
>
Returns
this
is
RecordBatchReaders
<
T
>
next
next
(
)
:
IteratorResult
<
RecordBatch
<
T
>
,
any
>
|
Promise
<
IteratorResult
<
RecordBatch
<
T
>
,
any
>
>
Returns
IteratorResult
<
RecordBatch
<
T
>
,
any
>
|
Promise
<
IteratorResult
<
RecordBatch
<
T
>
,
any
>
>
open
open
(
options
?:
OpenOptions
)
:
RecordBatchReader
<
T
>
|
Promise
<
RecordBatchReader
<
T
>
>
Parameters
Optional
options:
OpenOptions
Returns
RecordBatchReader
<
T
>
|
Promise
<
RecordBatchReader
<
T
>
>
pipe
pipe
<
R
>
(
writable
:
R
, options
?:
{
end
?:
boolean
}
)
:
R
Type Parameters
R
extends
WritableStream
<
R
>
Parameters
writable:
R
Optional
options:
{
end
?:
boolean
}
Optional
end
?:
boolean
Returns
R
pipe
Through
pipe
Through
<
R
>
(
duplex
:
{
readable
:
R
;
writable
:
WritableStream
<
RecordBatch
<
T
>
>
}
, options
?:
StreamPipeOptions
)
:
ReadableStream
<
any
>
Type Parameters
R
extends
ReadableStream
<
any
,
R
>
Parameters
duplex:
{
readable
:
R
;
writable
:
WritableStream
<
RecordBatch
<
T
>
>
}
readable
:
R
writable
:
WritableStream
<
RecordBatch
<
T
>
>
Optional
options:
StreamPipeOptions
Returns
ReadableStream
<
any
>
pipe
To
pipe
To
(
writable
:
WritableStream
<
RecordBatch
<
T
>
>
, options
?:
StreamPipeOptions
)
:
Promise
<
void
>
Parameters
writable:
WritableStream
<
RecordBatch
<
T
>
>
Optional
options:
StreamPipeOptions
Returns
Promise
<
void
>
read
Record
Batch
read
Record
Batch
(
index
:
number
)
:
null
|
RecordBatch
<
T
>
|
Promise
<
null
|
RecordBatch
<
T
>
>
Parameters
index:
number
Returns
null
|
RecordBatch
<
T
>
|
Promise
<
null
|
RecordBatch
<
T
>
>
reset
reset
(
schema
?:
null
|
Schema
<
T
>
)
:
RecordBatchReader
<
T
>
Parameters
Optional
schema:
null
|
Schema
<
T
>
Returns
RecordBatchReader
<
T
>
return
return
(
value
?:
any
)
:
IteratorResult
<
any
,
any
>
|
Promise
<
IteratorResult
<
any
,
any
>
>
Parameters
Optional
value:
any
Returns
IteratorResult
<
any
,
any
>
|
Promise
<
IteratorResult
<
any
,
any
>
>
tee
tee
(
)
:
[
ReadableStream
<
RecordBatch
<
T
>
>
,
ReadableStream
<
RecordBatch
<
T
>
>
]
Returns
[
ReadableStream
<
RecordBatch
<
T
>
>
,
ReadableStream
<
RecordBatch
<
T
>
>
]
throw
throw
(
value
?:
any
)
:
IteratorResult
<
any
,
any
>
|
Promise
<
IteratorResult
<
any
,
any
>
>
Parameters
Optional
value:
any
Returns
IteratorResult
<
any
,
any
>
|
Promise
<
IteratorResult
<
any
,
any
>
>
toDOMStream
toDOMStream
(
)
:
ReadableStream
<
RecordBatch
<
T
>
>
Returns
ReadableStream
<
RecordBatch
<
T
>
>
to
Node
Stream
to
Node
Stream
(
)
:
Readable
Returns
Readable
Static
from
from
<
T
>
(
source
:
T
)
:
T
from
<
T
>
(
source
:
ArrowJSONLike
)
:
RecordBatchStreamReader
<
T
>
from
<
T
>
(
source
:
FromArg1
)
:
Promise
<
RecordBatchStreamReader
<
T
>
>
from
<
T
>
(
source
:
FromArg2
)
:
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
from
<
T
>
(
source
:
FromArg3
)
:
Promise
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
from
<
T
>
(
source
:
FromArg4
)
:
Promise
<
AsyncRecordBatchFileReader
<
T
>
|
AsyncRecordBatchStreamReader
<
T
>
>
from
<
T
>
(
source
:
FromArg5
)
:
Promise
<
AsyncRecordBatchFileReader
<
T
>
|
AsyncRecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
RecordBatchReader
<
any
,
T
>
Parameters
source:
T
Returns
T
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
ArrowJSONLike
Returns
RecordBatchStreamReader
<
T
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg1
Returns
Promise
<
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg2
Returns
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg3
Returns
Promise
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg4
Returns
Promise
<
AsyncRecordBatchFileReader
<
T
>
|
AsyncRecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg5
Returns
Promise
<
AsyncRecordBatchFileReader
<
T
>
|
AsyncRecordBatchStreamReader
<
T
>
>
Static
read
All
read
All
<
T
>
(
source
:
T
)
:
T
extends
RecordBatchReaders
<
any
>
?
IterableIterator
<
T
>
:
AsyncIterableIterator
<
T
>
read
All
<
T
>
(
source
:
ArrowJSONLike
)
:
IterableIterator
<
RecordBatchStreamReader
<
T
>
>
read
All
<
T
>
(
source
:
FromArg1
)
:
AsyncIterableIterator
<
RecordBatchStreamReader
<
T
>
>
read
All
<
T
>
(
source
:
FromArg2
)
:
IterableIterator
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
read
All
<
T
>
(
source
:
FromArg3
)
:
AsyncIterableIterator
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
read
All
<
T
>
(
source
:
FromArg4
)
:
AsyncIterableIterator
<
AsyncRecordBatchReaders
<
T
>
>
read
All
<
T
>
(
source
:
FromArg5
)
:
AsyncIterableIterator
<
AsyncRecordBatchReaders
<
T
>
>
nocollapse
Type Parameters
T
extends
RecordBatchReader
<
any
,
T
>
Parameters
source:
T
Returns
T
extends
RecordBatchReaders
<
any
>
?
IterableIterator
<
T
>
:
AsyncIterableIterator
<
T
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
ArrowJSONLike
Returns
IterableIterator
<
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg1
Returns
AsyncIterableIterator
<
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg2
Returns
IterableIterator
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg3
Returns
AsyncIterableIterator
<
RecordBatchFileReader
<
T
>
|
RecordBatchStreamReader
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg4
Returns
AsyncIterableIterator
<
AsyncRecordBatchReaders
<
T
>
>
nocollapse
Type Parameters
T
extends
TypeMap
=
any
Parameters
source:
FromArg5
Returns
AsyncIterableIterator
<
AsyncRecordBatchReaders
<
T
>
>
Static
throughDOM
throughDOM
<
T
>
(
writableStrategy
?:
ByteLengthQueuingStrategy
, readableStrategy
?:
{
autoDestroy
:
boolean
}
)
:
{
readable
:
ReadableStream
<
RecordBatch
<
T
>
>
;
writable
:
WritableStream
<
Uint8Array
>
}
nocollapse
Type Parameters
T
extends
TypeMap
Parameters
Optional
writableStrategy:
ByteLengthQueuingStrategy
Optional
readableStrategy:
{
autoDestroy
:
boolean
}
auto
Destroy
:
boolean
Returns
{
readable
:
ReadableStream
<
RecordBatch
<
T
>
>
;
writable
:
WritableStream
<
Uint8Array
>
}
readable
:
ReadableStream
<
RecordBatch
<
T
>
>
writable
:
WritableStream
<
Uint8Array
>
Static
through
Node
through
Node
(
options
?:
DuplexOptions
&
{
autoDestroy
:
boolean
}
)
:
Duplex
nocollapse
Parameters
Optional
options:
DuplexOptions
&
{
autoDestroy
:
boolean
}
Returns
Duplex
Modules
Arrow.dom
Field
Schema
Arrow.node
Record
Batch
Reader
auto
Destroy
closed
dictionaries
footer
num
Dictionaries
num
Record
Batches
schema
[async
Iterator]
[iterator]
cancel
is
Async
is
File
is
Stream
is
Sync
next
open
pipe
pipe
Through
pipe
To
read
Record
Batch
reset
return
tee
throw
toDOMStream
to
Node
Stream
from
read
All
throughDOM
through
Node
Generated using
TypeDoc