clojure-data-grinder-core.core
Enrichercljprotocol
Enricher is used to enrich data from a specific source. For instance read data from a table, and mix it with data coming in from a channel
Enricher is used to enrich data from a specific source. For instance read data from a table, and mix it with data coming in from a channel
mixclj
(mix this v)method to mix cache data with read data
method to mix cache data with read data
update-cacheclj
(update-cache this)method to read data from a cacheable source to be able to mix it in later
method to read data from a cacheable source to be able to mix it in later
Grindercljprotocol
Data Grinder -> processes the raw data
Data Grinder -> processes the raw data
grindclj
(grind this v)method to grind raw data into finely usable data
method to grind raw data into finely usable data
IGlobalStatecljprotocol
Defines a global state for the execution environment. Used to keep shared data between steps
Defines a global state for the execution environment. Used to keep shared data between steps
alterStateValueclj
(alterStateValue this key value)getStateValueclj
(getStateValue this key)Outputtercljprotocol
Contains all functions to output data
Contains all functions to output data
output-to-allclj
(output-to-all this value all-channels name)method to output the sourced data to all the configured output channels
method to output the sourced data to all the configured output channels
output-to-channelclj
(output-to-channel this value channel name)method to output the sourced data to a specific channel
method to output the sourced data to a specific channel
Sinkcljprotocol
Data Sink -> sinks the data into whatever form needed, DB, File, Cloud, etc
Data Sink -> sinks the data into whatever form needed, DB, File, Cloud, etc
sinkclj
(sink this v)method to sink data
method to sink data
Sourcecljprotocol
Source Step -> reads raw data ready to be processed
Source Step -> reads raw data ready to be processed
Stepcljprotocol
Base step that contains the methods common to all Steps in the processing pipeline
Base step that contains the methods common to all Steps in the processing pipeline
getStateclj
(getState this)initclj
(init this)initialize the current step
initialize the current step
stopclj
(stop this)validateclj
(validate this)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close