Splits a line by a sparator into tokens

• ChunkProcessorInterceptor
  • Parameters
• stream
• constructor
  • Parameters
• addRowActions
  • Parameters
• _transform
  • Parameters
• _flush
  • Parameters
• addError
  • Parameters
• createTmpHashAction
  • Parameters
• createFunctions
  • Parameters
• createHashFunction
  • Parameters
• record
  • Parameters

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 data
• error 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 hash
• hashName The name to be used to store the hash value back in the record

The function gerates the hash for the given record

• record The record to create the hash for

With npm do:

npm install kronos-interceptor-object-data-processor-chunk

BSD-2-Clause