org.thales.punch.libraries.punchlang.api

Class PunchletSequence

java.lang.Object

org.thales.punch.libraries.punchlang.impl.PunchletContext

org.thales.punch.libraries.punchlang.api.Punchlet

org.thales.punch.libraries.punchlang.api.Punchlets

org.thales.punch.libraries.punchlang.api.PunchletSequence

public class PunchletSequence
extends Punchlets

The PunchletSequence class chains several punchlets. Watch out you cannot use filtering when chaining punchlets. All will be called possibly with an empty root tuple.

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.

Field Summary

Fields inherited from class org.thales.punch.libraries.punchlang.api.Punchlets

punchletList

Fields inherited from class org.thales.punch.libraries.punchlang.api.Punchlet

_threadLocal, LOG

Fields inherited from class org.thales.punch.libraries.punchlang.impl.PunchletContext

child, code, eventCount, metricRegistry, r, uuidGenerator, world

Constructor Summary

Constructors

Constructor and Description
PunchletSequence() Default ctor

Method Summary

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.

Methods inherited from class org.thales.punch.libraries.punchlang.api.Punchlets

__isChained, activate, addEventCallback, isAsynchronous, setMetricContext

Methods inherited from class org.thales.punch.libraries.punchlang.api.Punchlet

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

Methods inherited from class org.thales.punch.libraries.punchlang.impl.PunchletContext

ecount, every, execute, getPath, getPersistentId, getProperties, getRuntimeId, getWorldTuple, setCode, setPath, setPersistentId, setProperties, setRuntimeId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PunchletSequence

public PunchletSequence()

Default ctor

Method Detail

invoke

public void invoke(Tuple root)

Description copied from class: PunchletContext

This method only invoke the punchlet execute method and takes care of catching all exception to make them transformed as punch runtime exceptions.

Overrides:

invoke in class PunchletContext

Parameters:

root - the input tuple

add

public PunchletSequence add(Punchlet punchlet)

Add a punchlet to the list

Parameters:

punchlet - the additional punchlet

executors -

affinity -

Returns:

this instance

execute

public void execute(Punchlet fromPunchlet,
                    Tuple root,
                    org.thales.punch.api.IReceiver<Tuple> receiver)

Execute a chain of punchlet starting from a specific one.

Parameters:

fromPunchlet - the first punchlet to start with

root - the root document to pass to that punchlet and the subsequent ones.

receiver -