RecordBatchStreamReader class final

Sequential reader of an Arrow IPC stream.

Iterating yields the remaining record batches once (the reader is a single-pass cursor). Dictionary replacements and deltas apply to the batches that follow them.

Inheritance

Properties

first → RecordBatch
The first element.
no setterinherited
hashCode → int
The hash code for this object.
no setterinherited
isEmpty → bool
Whether this collection has no elements.
no setterinherited
isNotEmpty → bool
Whether this collection has at least one element.
no setterinherited
iterator → Iterator<RecordBatch>
A new Iterator that allows iterating the elements of this Iterable.
no setteroverride
last → RecordBatch
The last element.
no setterinherited
length → int
The number of elements in this Iterable.
no setterinherited
limits → IpcLimits
The limits applied while decoding.
no setter
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
schema → Schema
The stream schema.
no setter
single → RecordBatch
Checks that this iterable has only one element, and returns that element.
no setterinherited

Methods

any(bool test(RecordBatch element)) → bool
Checks whether any element of this iterable satisfies test.
inherited
cast<R>() → Iterable<R>
A view of this iterable as an iterable of R instances.
inherited
contains(Object? element) → bool
Whether the collection contains an element equal to element.
inherited
elementAt(int index) → RecordBatch
Returns the indexth element.
inherited
every(bool test(RecordBatch element)) → bool
Checks whether every element of this iterable satisfies test.
inherited
expand<T>(Iterable<T> toElements(RecordBatch element)) → Iterable<T>
Expands each element of this Iterable into zero or more elements.
inherited
firstWhere(bool test(RecordBatch element), {RecordBatch orElse()?}) → RecordBatch
The first element that satisfies the given predicate test.
inherited
fold<T>(T initialValue, T combine(T previousValue, RecordBatch element)) → T
Reduces a collection to a single value by iteratively combining each element of the collection with an existing value
inherited
followedBy(Iterable<RecordBatch> other) → Iterable<RecordBatch>
Creates the lazy concatenation of this iterable and other.
inherited
forEach(void action(RecordBatch element)) → void
Invokes action on each element of this iterable in iteration order.
inherited
join([String separator = ""]) → String
Converts each element to a String and concatenates the strings.
inherited
lastWhere(bool test(RecordBatch element), {RecordBatch orElse()?}) → RecordBatch
The last element that satisfies the given predicate test.
inherited
map<T>(T toElement(RecordBatch e)) → Iterable<T>
The current elements of this iterable modified by toElement.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
readAll() → Table
Reads every remaining batch into a Table with schema.
readNextBatch() → RecordBatch?
Decodes the next record batch, or returns null at end of stream.
reduce(RecordBatch combine(RecordBatch value, RecordBatch element)) → RecordBatch
Reduces a collection to a single value by iteratively combining elements of the collection using the provided function.
inherited
singleWhere(bool test(RecordBatch element), {RecordBatch orElse()?}) → RecordBatch
The single element that satisfies test.
inherited
skip(int count) → Iterable<RecordBatch>
Creates an Iterable that provides all but the first count elements.
inherited
skipWhile(bool test(RecordBatch element)) → Iterable<RecordBatch>
Creates an Iterable that skips leading elements while test is satisfied.
inherited
take(int count) → Iterable<RecordBatch>
Creates a lazy iterable of the count first elements of this iterable.
inherited
takeWhile(bool test(RecordBatch element)) → Iterable<RecordBatch>
Creates a lazy iterable of the leading elements satisfying test.
inherited
toList({bool growable = true}) → List<RecordBatch>
Creates a List containing the elements of this Iterable.
inherited
toSet() → Set<RecordBatch>
Creates a Set containing the same elements as this iterable.
inherited
toString() → String
Returns a string representation of (some of) the elements of this.
inherited
where(bool test(RecordBatch element)) → Iterable<RecordBatch>
Creates a new lazy Iterable with all elements that satisfy the predicate test.
inherited
whereType<T>() → Iterable<R>
Creates a new lazy Iterable with all elements that have type T.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited