public class PunchletSequence extends Punchlets
Regarding implementation this is a fake punchlet that only overloads a few methods, in particular the activate and the execute methods, and fire the activate and execute of each punchlet, in turn.
punchletList
_threadLocal, LOG
child, code, eventCount, metricRegistry, r, uuidGenerator, world
Constructor and Description |
---|
PunchletSequence()
Default ctor
|
Modifier and Type | Method and Description |
---|---|
PunchletSequence |
add(Punchlet punchlet)
Add a punchlet to the list
|
void |
execute(Punchlet fromPunchlet,
Tuple root,
org.thales.punch.api.IReceiver<Tuple> receiver)
Execute a chain of punchlet starting from a specific one.
|
void |
invoke(Tuple root)
This method only invoke the punchlet execute method and takes care of catching all
exception to make them transformed as punch runtime exceptions.
|
__isChained, activate, addEventCallback, isAsynchronous, setMetricContext
attach, bug, cef, cidrRange, cidrRange, coalesce, contains, contains, convert, convert, csv, currentTimeMillis, currentTimeNanos, date, date, date, dissect, dump, fetchCsv, fetchCsv, fetchJson, fetchJson, findByInterval, findByInterval, findByInterval, findByKey, findByKey, geo, geoip, geoOperator, getAttachement, getCode, getHostIp, getHostName, getResource, getResourceString, getResourceTuple, getUniqueMessageId, grok, http, ipmatch, ipmatch, ipRange, ipv4Range, ipv4Range, ipv6Range, ipv6Range, is, kv, logger, mail, meter, move, nifi, print, print, raise, remove, sha1, sleep, split, syslogHeader, toArray, toBoolean, toDouble, toFlatTuple, toKv, toLong, toLowerCase, toUpperCase, tryEpochMs, tryEpochMs, tryEpochSec, tryEpochSec, tuple, tuple, unflatTuple, validateSchema
ecount, every, execute, getPath, getPersistentId, getProperties, getRuntimeId, getWorldTuple, setCode, setPath, setPersistentId, setProperties, setRuntimeId
public void invoke(Tuple root)
PunchletContext
invoke
in class PunchletContext
root
- the input tuplepublic PunchletSequence add(Punchlet punchlet)
punchlet
- the additional punchletexecutors
- affinity
- public void execute(Punchlet fromPunchlet, Tuple root, org.thales.punch.api.IReceiver<Tuple> receiver)
fromPunchlet
- the first punchlet to start withroot
- the root document to pass to that punchlet and the subsequent ones.receiver
- Copyright © 2023. All rights reserved.