Splits a line by a sparator into tokens
Extends Interceptor
This interceptor cares about the handling of the messages. It will add the hops and copies the messages
config
endpoint
This module will turn an array of tokens into an object.
opts
validate
Add custom actions to the rowActions. These actions will be executed per row
actions
Reads the stream data and split it into lines.
data
enc
cb
Flushes the data. Only needed if there are multi row fields used
cb
Adds an error to the stream data
data
The current stream dataerror
The error to be added.Creates a hash function to compute a content hash without the multirow fields
contentHashFields
multiRowFields
Creates the checks for checking boolean values
chunkDefinition
The chunk definition for these records.Creates a function which generates a hash from the given content and stores the generated Hash under the given name in the record
hashFields
All the field names used to create the hashhashName
The name to be used to store the hash value back in the recordThe function gerates the hash for the given record
record
The record to create the hash forWith npm do:
npm install kronos-interceptor-object-data-processor-chunk
BSD-2-Clause