Class: RecordStream

RecordStream

new RecordStream()

Class for Record Stream
Source:

Extends

  • stream.Transform

Classes

Parsable
Serializable

Methods

(static) filter(fn) → {RecordStream.Serializable}

Create a record stream which filters records and pass them to downstream
Parameters:
Name Type Description
fn RecordFilterFunction Record filtering function
Source:
Returns:
Type
RecordStream.Serializable

(static) map(fn) → {RecordStream.Serializable}

Create a record stream which maps records and pass them to downstream
Parameters:
Name Type Description
fn RecordMapFunction Record mapping function
Source:
Returns:
Type
RecordStream.Serializable

(static) recordMapStream(record, noevalopt) → {RecordStream.Serializable}

Create mapping stream using given record template
Parameters:
Name Type Attributes Description
record Record Mapping record object. In mapping field value, temlate notation can be used to refer field value in source record, if noeval param is not true.
noeval Boolean <optional>
 Disable template evaluation in mapping record.
Source:
Returns:
Type
RecordStream.Serializable

filter(fn) → {RecordStream}

Get record stream of queried records, applying the given filter function
Parameters:
Name Type Description
fn RecordFilterFunction Record filtering function
Source:
Returns:
Type
RecordStream

map(fn) → {RecordStream}

Get record stream of queried records applying the given mapping function
Parameters:
Name Type Description
fn RecordMapFunction Record mapping function
Source:
Returns:
Type
RecordStream