Module nifi_flowfile

NiFi Flowfile definition and helper functions.

Description

NiFi Flowfile definition and helper functions. Flowfile are simple messages with an attributes part and an optional payload.

Data Types

flowfile()

abstract datatype: flowfile()

A record to hold flowfile definition.

flowfiles()

abstract datatype: flowfiles()

Holds a set of flowfiles received or to be send.

Function Index

add/2Adds the Flowfile to Flowfiles.
add/3Create a new flowfile and add it to Flowfiles.
get_attribute/2
get_attributes/1
get_content/1
get_size/1
new/0Creates a new object to hold flowfiles.
new/2Creates a new flowfile with Attributes and Content.
remove/1Remove and returns a flowfile from Flowfile.

Function Details

add/2

add(Flowfile::flowfile(), Flowfiles::flowfiles()) -> flowfiles()

Adds the Flowfile to Flowfiles.

add/3

add(Attributes::map(), Content::binary(), Flowfiles::flowfiles()) -> flowfiles()

Create a new flowfile and add it to Flowfiles.

get_attribute/2

get_attribute(Flowfile::flowfile(), Key::binary()) -> binary()

get_attributes/1

get_attributes(Flowfile::flowfile()) -> map()

get_content/1

get_content(Flowfile::flowfile()) -> binary()

get_size/1

get_size(Flowfile::flowfile()) -> non_neg_integer()

new/0

new() -> flowfiles()

Creates a new object to hold flowfiles.

new/2

new(Attributes::map(), Content::binary()) -> flowfile()

Creates a new flowfile with Attributes and Content.

remove/1

remove(Flowfiles::flowfiles()) -> {{value, flowfile()}, flowfiles()} | {empty, flowfiles()}

Remove and returns a flowfile from Flowfile.


Generated by EDoc