| Modifier and Type | Method and Description | 
|---|---|
static String | 
JsonMapper.toJson(Tuple tuple)
Return a plain json representation of a tuple. 
 | 
static String | 
JsonMapper.toUnicodeAsciiJson(Tuple tuple)
Return a json representation where all String leafs are returned as ascii unicode representation. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
Tuple | 
Entry.value
the entry value 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
Tuple.add(Object element)
Add a tuple element into a set. 
 | 
Tuple | 
Tuple.append(Object element)
Add a abject element at the end of an array. 
 | 
Tuple | 
TupleBuilder.build()  | 
Tuple | 
Tuple.cutPrefix(String s)
Remove a matching prefix 
 | 
Tuple | 
Tuple.cutSuffix(String s)
Remove a matching prefix 
 | 
Tuple | 
Tuple.duplicate()
Clone a tuple. 
 | 
Tuple[] | 
Tuple.elements()
Returns an array of elements. 
 | 
Tuple | 
Tuple.fromEscapedJson()
This method assumes your tuple holds a string leaf value. 
 | 
Tuple | 
Tuple.get(String key)
Return a sub-tuple by key. 
 | 
Tuple | 
Tuple.get(Tuple key)
Return a sub-tuple by key. 
 | 
Tuple | 
Tuple.getByKey(String key)
Return a sub-tuple by key. 
 | 
Tuple | 
Tuple.getDeep(String key)
Return a sub-tuple by key recursively. 
 | 
Tuple | 
Tuple.getDeepEs(String key)
Return a sub-tuple by key recursively. 
 | 
Tuple | 
Tuple.getElement()
This method returns a new empty array element. 
 | 
Tuple | 
Tuple.getElement(int index)
Retrieve the ith item from this tuple. 
 | 
static Tuple | 
TupleFactory.getLeafTuple(Object o)
Return a new leaf tuple. 
 | 
static Tuple | 
TupleFactory.getNewTuple()
Use this method to create a new empty tuples. 
 | 
static Tuple | 
TupleFactory.getNewTuple(Object value)
Use this method to create a non empty root tuple. 
 | 
Tuple | 
Punchlet.getResourceTuple(String name)
Return a     resource json tuple. 
 | 
Tuple | 
Tuple.getSingleChild()
Return the single child of this tuple. 
 | 
Tuple | 
TupleAvroEncoder.getTuple(org.apache.avro.generic.GenericData.Record record)  | 
static Tuple | 
TupleFactory.getTupleFromCsv(String content,
               String hashKey,
               String delimiter,
               boolean inferTypes,
               boolean hasHeader,
               boolean lowerCaseKeys)
Build a punch tuple from a CSV file content. 
 | 
static Tuple | 
TupleFactory.getTupleFromCsv(String s,
               String hashKey,
               String delimiter,
               List<String> columnNames,
               boolean inferTypes,
               boolean lowerCaseKeys)
Build a punch tuple from a CSV file content. 
 | 
static Tuple | 
TupleFactory.getTupleFromJson(Object mapper,
                String fromJson)
Deprecated. 
 
use TupleFactory.getTupleFromJson(String fromJson, Object mapper). Will be removed later.
 Only keep for compatibility with existing parsers 
 | 
static Tuple | 
TupleFactory.getTupleFromJson(String s)
Retrieve a tuple from a valid Json String. 
 | 
static Tuple | 
TupleFactory.getTupleFromJson(String s,
                Object jsonMapper)  | 
static Tuple | 
TupleFactory.getTupleFromList(List<Object> input)  | 
static Tuple | 
TupleFactory.getTupleFromMap(Map map)
Get a tuple from a map. 
 | 
Tuple | 
Entry.getValue()  | 
Tuple | 
Tuple.merge(Tuple b)
See mergeWith(). 
 | 
Tuple | 
Tuple.mergeWith(Tuple b)
Return a merge of two Tuples A and B recursively. 
 | 
Tuple | 
IResourceBuilder.onEnd()
Callback that tells you the scan is done. 
 | 
Tuple | 
Tuple.putAll(Map<String,Object> map)
Put all the provided tuple key values in this tuple. 
 | 
Tuple | 
Tuple.remove(String key)
Return and removes a sub-tuple by key. 
 | 
Tuple | 
Tuple.replaceAllKeys(String regex,
              String replacement)
For each inner property Tuple contained in this tuple, replaces each
 substring occurence of its key that matches the given regular expression with
 the given replacement. 
 | 
Tuple | 
Tuple.replaceAllKeyValues(String regex,
                   String replacement)
Combines  
replaceAllKeys(java.lang.String, java.lang.String) and replaceAllValues(java.lang.String, java.lang.String) in one call. | 
Tuple | 
Tuple.replaceAllValues(String regex,
                String replacement)
For each inner String value contained in this tuple, replaces each substring
 occurence that matches the given regular expression with the given
 replacement. 
 | 
Tuple | 
Tuple.select(String... keys)
Given a tuple, return a selection of one or several of its child. 
 | 
Tuple | 
Tuple.set(Object v)
Assign this tuple a new leaf value 
 | 
Tuple | 
Tuple.set(String key,
   Object v)
Add an object as property to this tuple. 
 | 
Tuple[] | 
Tuple.splitAsTupleArray(String s)
Split this string into a Tuple array of the given regular expression. 
 | 
Tuple | 
Tuple.toLowerCase()  | 
Tuple | 
Tuple.toUpperCase()  | 
static Tuple | 
Punchlet.tuple()
Return a new tuple 
 | 
static Tuple | 
Punchlet.tuple(Object... elements)
Construct a new tuple. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<Tuple> | 
Tuple.asArray()
Returns an ordered list of elements if the tuple is an array or a set. 
 | 
Collection<Tuple> | 
Tuple.asCollection()
Returns a collection of elements. 
 | 
Set<Tuple> | 
Tuple.asSet()
Returns a set of elements. 
 | 
Supplier<Tuple> | 
S3ResourceHandlerBuilder.getTupleSupplier()  | 
Supplier<Tuple> | 
RemoteResourceHandlerBuilder.getTupleSupplier()  | 
abstract Supplier<Tuple> | 
AbstractRemoteResourceHandlerBuilder.getTupleSupplier()  | 
Collection<Tuple> | 
Tuple.getValues()
Returns the collection of inner property values. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ContainsOperator | 
Punchlet.contains(Tuple map,
        String... keys)
Return a  
ContainsOperator operator. | 
boolean | 
Tuple.containsOneOf(Tuple resource)
Check if this tuple contains one of several sub-string. 
 | 
static ConvertorOperator | 
Punchlet.convert(Tuple input)
Return a convertor operator, transforming XML or JSON strings into tuples. 
 | 
static void | 
Punchlet.dump(Tuple t)
Dump to stdout a plain String representation of a tuple. 
 | 
boolean | 
Tuple.equalsOneOf(Tuple resource)
Check if this tuple contains a sub-string. 
 | 
void | 
PunchletSequence.execute(Punchlet fromPunchlet,
       Tuple root,
       org.thales.punch.api.IReceiver<Tuple> receiver)
Execute a chain of punchlet starting from a specific one. 
 | 
void | 
PunchletDag.execute(Tuple root)  | 
void | 
PunchletDag.execute(Tuple root,
       org.thales.punch.api.IReceiver<Tuple> receiver)
Execute a chain of punchlet starting from a specific one. 
 | 
FindByIntervalOperator | 
Punchlet.findByInterval(Tuple map)
Return a FindByIntervalOperator, acting on the passed json map. 
 | 
static FindByIntervalOperator | 
Punchlet.findByInterval(Tuple map,
              String key)
Return a FindByIntervalOperator, acting on the passed json map. 
 | 
static FindByIntervalOperator | 
Punchlet.findByInterval(Tuple map,
              String min,
              String max)
Return a  
FindByIntervalOperator operator with min and
 max property interval boundaries. | 
FindByKeyOperator | 
Punchlet.findByKey(Tuple map,
         String... keys)
Return a  
FindByKeyOperator operator. | 
Tuple | 
Tuple.get(Tuple key)
Return a sub-tuple by key. 
 | 
static org.apache.avro.generic.GenericRecord | 
TupleFactory.getAvroRecord(org.apache.avro.Schema schema,
             Tuple tuple)
Tuple to avro conversion method 
 | 
org.apache.avro.generic.GenericRecord | 
TupleAvroEncoder.getAvroRecord(Tuple tuple)  | 
static String | 
TupleFactory.getJsonFromTuple(Tuple tuple)
Get a valid Json representation from a tuple. 
 | 
static String | 
TupleFactory.getJsonFromTuple(Tuple tuple,
                Object mapper)
Get a valid Json representation from a tuple. 
 | 
void | 
PunchletSequence.invoke(Tuple root)  | 
IpMatchOperator | 
Punchlet.ipmatch(Tuple resource)
the ipmatch method lets you check if an IP address is contained in a list. 
 | 
Tuple | 
Tuple.merge(Tuple b)
See mergeWith(). 
 | 
Tuple | 
Tuple.mergeWith(Tuple b)
Return a merge of two Tuples A and B recursively. 
 | 
static MoveOperator | 
Punchlet.move(Tuple tuple)
Get a move operator to move a tuple from one place to another. 
 | 
void | 
PunchletEventCallback.onReceive(Punchlet punchlet,
         Tuple event)
The upcall to receive events generated by a punchlet 
 | 
static void | 
Punchlet.print(Tuple... tuples)
Pretty print a tuple. 
 | 
static void | 
Punchlet.remove(Tuple tuple)
Remove a tuple. 
 | 
boolean | 
Tuple.remove(Tuple element)
Set operation: remove an element from a set. 
 | 
static boolean | 
Punchlet.toBoolean(Tuple tuple)
The toDouble operator returns a long value contained in a tuple. 
 | 
static double | 
Punchlet.toDouble(Tuple tuple)
The toDouble operator returns a double value contained in a tuple. 
 | 
static long | 
Punchlet.toLong(Tuple tuple)
The toDouble operator returns a long value contained in a tuple. 
 | 
static void | 
Punchlet.toLowerCase(Tuple... tuples)
Change tuple(s) content to lower case 
 | 
static void | 
Punchlet.toUpperCase(Tuple... tuples)
Change tuple(s) content to upper case. 
 | 
Long | 
Punchlet.tryEpochMs(Tuple t)
Convert a date to an epoch timestamp in seconds. 
 | 
Long | 
Punchlet.tryEpochMs(Tuple t,
          long defaultValue)
Convert a date to an epoch timestamp in seconds. 
 | 
Long | 
Punchlet.tryEpochSec(Tuple t)
Convert a date to an epoch timestamp in millisecond. 
 | 
Long | 
Punchlet.tryEpochSec(Tuple t,
           long defaultValue)
Convert a date to an epoch timestamp in millisecond. 
 | 
TupleAvroEncoder | 
TupleAvroEncoder.write(Tuple tuple)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PunchletSequence.execute(Punchlet fromPunchlet,
       Tuple root,
       org.thales.punch.api.IReceiver<Tuple> receiver)
Execute a chain of punchlet starting from a specific one. 
 | 
void | 
PunchletDag.execute(Tuple root,
       org.thales.punch.api.IReceiver<Tuple> receiver)
Execute a chain of punchlet starting from a specific one. 
 | 
static int | 
PunchletDag.getQueueNum(LinkedBlockingQueue<Tuple> q)  | 
| Constructor and Description | 
|---|
Entry(String key,
     Tuple tuple)
Ctor 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractTupleImpl
This class provide the many useful api methods defined in the Tuple interface. 
 | 
class  | 
DnsTuple
The DnsTuple is one of these tuple that give punchlets an access to the outside
 world. 
 | 
class  | 
GeoFeatureTuple
GeoTuple is the implementation of Tuple with geometry "geographic" 
 | 
class  | 
LoggerTuple
The logger tuple logs everything you write you write to a logger. 
 | 
class  | 
StormTuple
The Storm tuple allows a punchlet to emit Storm tuples values. 
 | 
class  | 
TupleImpl
We group here a number of basic tuple operations. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
Tuple | 
PunchletContext.child  | 
Tuple | 
PunchletContext.world
The world tuple allows for generic communications with the external environments 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Tuple | 
L.asTuple(Tuple v)  | 
Tuple | 
AbstractTupleImpl.cutPrefix(String s)  | 
Tuple | 
AbstractTupleImpl.cutSuffix(String s)  | 
Tuple | 
TupleImpl.duplicate()  | 
Tuple[] | 
TupleImpl.elements()  | 
Tuple | 
TupleFetcher.fetch(Tuple tuple)  | 
Tuple | 
TupleImpl.fromEscapedJson()  | 
Tuple | 
TupleImpl.get(String key)
Retrieve a child. 
 | 
Tuple | 
DnsTuple.get(String key)  | 
Tuple | 
AbstractTupleImpl.get(Tuple key)  | 
Tuple | 
TupleImpl.getByKey(String key)  | 
Tuple | 
AbstractTupleImpl.getDeep(String key)  | 
Tuple | 
AbstractTupleImpl.getDeepEs(String key)  | 
Tuple | 
TupleImpl.getElement()  | 
Tuple | 
TupleImpl.getElement(int index)  | 
Tuple | 
RuntimeContext.getJsonResource(String name)
Return a the content of a Json resource file, loaded as an in memory tuple 
 | 
Tuple | 
RuntimeContext.getRootTuple()  | 
Tuple | 
TupleImpl.getSingleChild()  | 
Tuple | 
PunchletContext.getWorldTuple()
Return the world tuple associated to your punchlet 
 | 
Tuple | 
TupleImpl.merge(Tuple b)  | 
Tuple | 
TupleImpl.mergeWith(Tuple b)  | 
Tuple | 
SimpleResourceBuilder.onEnd()  | 
Tuple | 
TupleImpl.putAll(Map<String,Object> map)  | 
Tuple | 
TupleImpl.replaceAllKeys(String regex,
              String replacement)  | 
Tuple | 
TupleImpl.replaceAllKeyValues(String regex,
                   String replacement)  | 
Tuple | 
AbstractTupleImpl.replaceAllValues(String regex,
                String replacement)  | 
Tuple | 
TupleImpl.select(String... keys)  | 
Tuple | 
TupleImpl.set(Object value)
Set a new value to a tuple 
 | 
Tuple | 
TupleImpl.set(String key,
   Object value)
Add a child object to a map tuple 
 | 
static Tuple | 
L.set(Tuple p,
   boolean v)  | 
static Tuple | 
L.set(Tuple p,
   double v)  | 
static Tuple | 
L.set(Tuple p,
   double[] v)  | 
static Tuple | 
L.set(Tuple p,
   float v)  | 
static Tuple | 
L.set(Tuple p,
   int v)  | 
static Tuple | 
L.set(Tuple p,
   long v)  | 
static Tuple | 
L.set(Tuple p,
   long[] v)  | 
static Tuple | 
L.set(Tuple p,
   Object o)  | 
static Tuple | 
L.set(Tuple p,
   short v)  | 
static Tuple | 
L.set(Tuple p,
   String[] v)  | 
static Tuple | 
L.set(Tuple p,
   Tuple v)  | 
Tuple | 
TupleImpl.setLeaf(Object o)
Deprecated.   
 | 
Tuple[] | 
TupleImpl.splitAsTupleArray(String regex)  | 
static Tuple | 
L.sum(Tuple p1,
   Tuple p2)
Compute the sum of two tuples. 
 | 
Tuple | 
AbstractTupleImpl.toLowerCase()  | 
Tuple | 
AbstractTupleImpl.toUpperCase()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Tuple> | 
TupleImpl.asArray()  | 
Collection<Tuple> | 
AbstractTupleImpl.asCollection()  | 
Set<Tuple> | 
TupleImpl.asSet()  | 
static com.github.veqryn.collect.Trie<com.github.veqryn.net.Cidr4,Tuple> | 
UtilsCidr.getCidrTrie(Tuple resource,
           String cidrField)
Given an input resource tuple, return a CIDR Trie structure. 
 | 
static List<Map.Entry<String,Tuple>> | 
PunchletResources.getTuplesByShortNames(Map<String,Tuple> jsonResources)
Simple conversion 
 | 
Collection<Tuple> | 
TupleImpl.getValues()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
RuntimeContext.addEvent(Tuple tuple)
Adds a new asynchronous event to the queue. 
 | 
static boolean | 
L.asBoolean(Tuple v)  | 
static double | 
L.asDouble(Tuple v)  | 
static float | 
L.asFloat(Tuple v)  | 
static int | 
L.asInt(Tuple v)  | 
static long | 
L.asLong(Tuple v)  | 
static short | 
L.asShort(Tuple v)  | 
static String | 
L.asString(Tuple v)  | 
static Tuple | 
L.asTuple(Tuple v)  | 
CidrMatchOperator | 
RuntimeContext.cidrmatch(Tuple cidr)
Return a CidrMatch operator for the corresponding index. 
 | 
int | 
AbstractTupleImpl.compareTo(Tuple o)  | 
int | 
TupleImpl.compareTo(Tuple o)  | 
boolean | 
AbstractTupleImpl.containsOneOf(Tuple resource)  | 
static double | 
L.divide(double l,
      Tuple p)  | 
static double | 
L.divide(long l,
      Tuple p)  | 
static double | 
L.divide(Tuple p,
      double l)  | 
static double | 
L.divide(Tuple p,
      long l)  | 
static double | 
L.divide(Tuple p,
      Tuple l)  | 
static boolean | 
L.equals(boolean v,
      Tuple p)  | 
static boolean | 
L.equals(double d,
      Tuple p)  | 
static boolean | 
L.equals(long l,
      Tuple p)  | 
static boolean | 
L.equals(String v,
      Tuple p)  | 
static boolean | 
L.equals(Tuple p,
      boolean v)  | 
static boolean | 
L.equals(Tuple p,
      double d)  | 
static boolean | 
L.equals(Tuple p,
      float f)  | 
static boolean | 
L.equals(Tuple p,
      int i)  | 
static boolean | 
L.equals(Tuple p,
      long l)  | 
static boolean | 
L.equals(Tuple p,
      short s)  | 
static boolean | 
L.equals(Tuple p,
      String v)  | 
boolean | 
TupleImpl.equalsOneOf(Tuple resource)  | 
void | 
PunchletContext.execute(Tuple root)
Execute the punchlet. 
 | 
Tuple | 
TupleFetcher.fetch(Tuple tuple)  | 
Tuple | 
AbstractTupleImpl.get(Tuple key)  | 
static String | 
UtilsCidr.getCidrFieldKey(Tuple t)
Given a tuple, return the key of the first element that match a CIDR format. 
 | 
static com.github.veqryn.collect.Trie<com.github.veqryn.net.Cidr4,Tuple> | 
UtilsCidr.getCidrTrie(Tuple resource,
           String cidrField)
Given an input resource tuple, return a CIDR Trie structure. 
 | 
protected org.ahocorasick.trie.Trie | 
AbstractTupleImpl.getCreateTrie(Tuple resourceTuple,
             String key)
Retrieve the Trie attached to a resource tuple, create one if not in there. 
 | 
static boolean | 
L.greater(double l,
       Tuple p)  | 
static boolean | 
L.greater(long l,
       Tuple p)  | 
static boolean | 
L.greater(Tuple p,
       double l)  | 
static boolean | 
L.greater(Tuple p,
       long l)  | 
static boolean | 
L.greaterEq(double l,
         Tuple p)  | 
static boolean | 
L.greaterEq(long l,
         Tuple p)  | 
static boolean | 
L.greaterEq(Tuple p,
         double l)  | 
static boolean | 
L.greaterEq(Tuple p,
         long l)  | 
void | 
PunchletContext.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. 
 | 
Tuple | 
TupleImpl.merge(Tuple b)  | 
Tuple | 
TupleImpl.mergeWith(Tuple b)  | 
static double | 
L.minus(double d,
     Tuple p)  | 
static long | 
L.minus(long l,
     Tuple p)  | 
static double | 
L.minus(Tuple p,
     double d)  | 
static long | 
L.minus(Tuple p,
     long l)  | 
static long | 
L.mod(int l,
   Tuple p)  | 
static long | 
L.mod(long l,
   Tuple p)  | 
static long | 
L.mod(Tuple p,
   int i)  | 
static long | 
L.mod(Tuple p,
   long l)  | 
static double | 
L.multiply(double l,
        Tuple p)  | 
static double | 
L.multiply(long l,
        Tuple p)  | 
static double | 
L.multiply(Tuple p,
        double l)  | 
static double | 
L.multiply(Tuple p,
        long l)  | 
static double | 
L.multiply(Tuple p,
        Tuple l)  | 
static boolean | 
L.notEquals(boolean v,
         Tuple p)  | 
static boolean | 
L.notEquals(double d,
         Tuple p)  | 
static boolean | 
L.notEquals(long l,
         Tuple p)  | 
static boolean | 
L.notEquals(String v,
         Tuple p)  | 
static boolean | 
L.notEquals(Tuple p,
         boolean v)  | 
static boolean | 
L.notEquals(Tuple p,
         double d)  | 
static boolean | 
L.notEquals(Tuple p,
         float f)  | 
static boolean | 
L.notEquals(Tuple p,
         int i)  | 
static boolean | 
L.notEquals(Tuple p,
         long l)  | 
static boolean | 
L.notEquals(Tuple p,
         short s)  | 
static boolean | 
L.notEquals(Tuple p,
         String v)  | 
boolean | 
AbstractTupleImpl.remove(Tuple element)  | 
void | 
RuntimeContext.remove(Tuple tuple)
Remove a tuple. 
 | 
TupleImpl | 
LoggerTuple.set(String key,
   Tuple value)  | 
static Tuple | 
L.set(Tuple p,
   boolean v)  | 
static Tuple | 
L.set(Tuple p,
   double v)  | 
static Tuple | 
L.set(Tuple p,
   double[] v)  | 
static Tuple | 
L.set(Tuple p,
   float v)  | 
static Tuple | 
L.set(Tuple p,
   int v)  | 
static Tuple | 
L.set(Tuple p,
   long v)  | 
static Tuple | 
L.set(Tuple p,
   long[] v)  | 
static Tuple | 
L.set(Tuple p,
   Object o)  | 
static Tuple | 
L.set(Tuple p,
   short v)  | 
static Tuple | 
L.set(Tuple p,
   String[] v)  | 
static Tuple | 
L.set(Tuple p,
   Tuple v)  | 
void | 
RuntimeContext.setRootTuple(Tuple tuple)
Set the top level tuple. 
 | 
static boolean | 
L.smaller(double d,
       Tuple p)  | 
static boolean | 
L.smaller(long l,
       Tuple p)  | 
static boolean | 
L.smaller(Tuple p,
       double d)  | 
static boolean | 
L.smaller(Tuple p,
       long l)  | 
static boolean | 
L.smallerEq(double d,
         Tuple p)  | 
static boolean | 
L.smallerEq(long l,
         Tuple p)  | 
static boolean | 
L.smallerEq(Tuple p,
         double d)  | 
static boolean | 
L.smallerEq(Tuple p,
         long l)  | 
static String | 
L.sum(String s,
   Tuple p)  | 
static String | 
L.sum(Tuple p,
   String s)  | 
static Tuple | 
L.sum(Tuple p1,
   Tuple p2)
Compute the sum of two tuples. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static List<Map.Entry<String,Tuple>> | 
PunchletResources.getTuplesByShortNames(Map<String,Tuple> jsonResources)
Simple conversion 
 | 
void | 
PunchletDagExecutor.setOutputQueue(String affinity,
              List<LinkedBlockingQueue<Tuple>> queues)  | 
| Constructor and Description | 
|---|
PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue,
                   Map<String,LinkedBlockingQueue<Tuple>> affinityMap,
                   int layer,
                   int number,
                   Punchlet punchlet,
                   Tuple world)
Ctor. 
 | 
TestPunchlet(RuntimeContext r,
            Tuple test)  | 
| Constructor and Description | 
|---|
PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue,
                   Map<String,LinkedBlockingQueue<Tuple>> affinityMap,
                   int layer,
                   int number,
                   Punchlet punchlet,
                   Tuple world)
Ctor. 
 | 
PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue,
                   Map<String,LinkedBlockingQueue<Tuple>> affinityMap,
                   int layer,
                   int number,
                   Punchlet punchlet,
                   Tuple world)
Ctor. 
 | 
RuntimeContext(boolean isAsynchronous,
              List<Map.Entry<String,Tuple>> resources,
              List<Map.Entry<String,String>> siddhiRules,
              Map<String,String> strings,
              io.krakens.grok.api.Grok[] groks,
              org.apache.commons.net.util.SubnetUtils[] subnets,
              org.joda.time.format.DateTimeFormatter[] dateFormats,
              org.logstash.dissect.Dissector[] dissectors,
              String[] dateFormatStrings)  | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
IMappingValidator.validate(Tuple tp,
        Tuple mapping)
Validate tuple with provided mapping tuple. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<Tuple> | 
IMappingValidator.validate(Tuple tp)
Validate tuple with already provided mapping tuples. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MappingValidatorBuilder | 
MappingValidatorBuilder.addMapping(Tuple mapping)
Add a mapping to the mapping list. 
 | 
List<Tuple> | 
IMappingValidator.validate(Tuple tp)
Validate tuple with already provided mapping tuples. 
 | 
Tuple | 
IMappingValidator.validate(Tuple tp,
        Tuple mapping)
Validate tuple with provided mapping tuple. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MappingValidatorBuilder | 
MappingValidatorBuilder.setMappings(List<Tuple> mappings)  | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
ElasticsearchMappingValidator.validate(Tuple docSrc,
        Tuple mapping)  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Tuple> | 
ElasticsearchMappingValidator.validate(Tuple docSrc)  | 
| Modifier and Type | Method and Description | 
|---|---|
HashMap<String,Object> | 
ElasticsearchMappingValidator.elasticsearchMappingValidation(Tuple docSrc,
                              Tuple mapping)  | 
List<Tuple> | 
ElasticsearchMappingValidator.validate(Tuple docSrc)  | 
Tuple | 
ElasticsearchMappingValidator.validate(Tuple docSrc,
        Tuple mapping)  | 
| Constructor and Description | 
|---|
ElasticsearchMappingValidator(List<Tuple> mappings)  | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
HttpOperator.asTuple()
Get response as Tuple 
 | 
Tuple | 
FetchJsonOperator.asTuple()  | 
Tuple | 
FetchCsvOperator.asTuple()  | 
Tuple | 
ResourceOperator.asTuple()  | 
Tuple | 
IpMatchOperator.getAttachmentFor(String input)
fire the operator on the provided string. 
 | 
Tuple | 
IpMatchOperator.getAttachmentFor(Tuple tuple)
fire the operator on the provided string. 
 | 
Tuple | 
FetchOperator.getResource()
This subl 
 | 
Tuple | 
UnflatTupleOperator.on(Tuple input)
Make the operator  work on an input Tuple. 
 | 
Tuple | 
ToFlatTupleOperator.on(Tuple input)
Make the operator  work on an input Tuple. 
 | 
Tuple | 
IpRangeOperator.onEnd()  | 
Tuple | 
CidrRangeOperator.onEnd()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Tuple> | 
ValidateSchemaOperator.into(Tuple result)
Stores validation results in provided tuple. 
 | 
List<Tuple> | 
ValidateSchemaOperator.validate()
Fire the operator and effectively check if your tuple conforms to your schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
NifiOperator | 
NifiOperator.addOutputRoute(Tuple tuple)
Add route to output routes 
 | 
FindByIntervalOperator | 
FindByIntervalOperator.between(Tuple tuple)
Look for all Json elements whose interval encloses the value contained in
 this tuple. 
 | 
boolean | 
IpMatchOperator.contains(Tuple tuple)
fire the operator on the provided tuple. 
 | 
boolean | 
GeoOperator.contains(Tuple t1,
        Tuple t2)
Return if the geoFeatureTuple T1 geometry contains geoFeatureTuple T2 
 | 
HttpOperator | 
HttpOperator.data(Tuple body)
Http POST and PUT data as plain string 
 | 
Double | 
GeoOperator.distance(Tuple t1,
        Tuple t2)
Return a distance between two tuples. 
 | 
double | 
GeoOperator.getArea(Tuple t)
Get Area of Geometry of GeoFeatureTuple 
 | 
Tuple | 
IpMatchOperator.getAttachmentFor(Tuple tuple)
fire the operator on the provided string. 
 | 
static Set<String> | 
NifiOperator.getRoutesFromTuple(Tuple tuple)
Extract list of routes as string from tuple 
 | 
boolean | 
IsOperator.in(Tuple tuple)
Check if the value is in this tuple. 
 | 
boolean | 
IsOperator.inside(Tuple tuple)
Deprecated. 
 
prefer  
IsOperator.in(Tuple) | 
Boolean | 
GeoOperator.intersect(Tuple t1,
         Tuple t2)
Return if the geometries of T1 geoFeatureTuple have a least one pint in common with Geometry of T2
 geoFeatureTuple 
 | 
boolean | 
CefOperator.into(Tuple tuple)
Fire the operator and put the result inside a destination tuple 
 | 
boolean | 
IpRangeOperator.into(Tuple result)
Fire the operator and store the result in the provided tuple. 
 | 
boolean | 
DissectOperator.into(Tuple tuple)
Registers a tuple to hold the operator results. 
 | 
boolean | 
MailOperator.into(Tuple tuple)
Put parsed headers and content into tuple. 
 | 
boolean | 
KvOperator.into(Tuple tuple)
Registers a tuple to hold the operator results. 
 | 
boolean | 
SplitOperator.into(Tuple tuple)
Fire the operator and store the result in the passed tuple. 
 | 
List<Tuple> | 
ValidateSchemaOperator.into(Tuple result)
Stores validation results in provided tuple. 
 | 
boolean | 
ContainsOperator.into(Tuple into)
Apply the operator an put the result into the provided tuple. 
 | 
boolean | 
ConvertorOperator.into(Tuple output)
Parse the input string and returns true if it was successfully converted into the output punch tuple. 
 | 
void | 
NifiOperator.into(Tuple into)
Apply the operator an put the result into the provided tuple. 
 | 
boolean | 
CidrMatchOperator.into(Tuple tuple)
Fire the operator and put the result into the provided tuple 
 | 
boolean | 
CidrRangeOperator.into(Tuple result)
Fire the operator 
 | 
boolean | 
FindByKeyOperator.into(Tuple into)
Fire the operator 
 | 
boolean | 
MoveOperator.into(Tuple dstTuple)
fire the move to the requested (Tuple) destination. 
 | 
String | 
DateOperator.into(Tuple tuple)
Fire and put the result of this operator into a destination tuple. 
 | 
boolean | 
FindByIntervalOperator.into(Tuple into)
Actually perform the query and put the result into 'into' 
 | 
boolean | 
CsvOperator.into(Tuple tuple)
Fire the operator and put the result inside a destination tuple 
 | 
boolean | 
SyslogHeaderOperator.into(Tuple header,
    Tuple data)
Fire the operator. 
 | 
ContainsOperator | 
ContainsOperator.on(Tuple... tuples)
Take the lookup key from an array of tuples 
 | 
FindByKeyOperator | 
FindByKeyOperator.on(Tuple... tuples)
Take the lookup key from an array of tuples 
 | 
CefOperator | 
CefOperator.on(Tuple input)
Make the operator work on an input Tuple. 
 | 
IpRangeOperator | 
IpRangeOperator.on(Tuple ip)
Set the input ip value you want to match. 
 | 
DissectOperator | 
DissectOperator.on(Tuple input)
Set the input data for running this operator. 
 | 
MailOperator | 
MailOperator.on(Tuple input)
Make the operator work on an input Tuple. 
 | 
SyslogHeaderOperator | 
SyslogHeaderOperator.on(Tuple log)  | 
boolean | 
IGrokOperator.on(Tuple input)  | 
KvOperator | 
KvOperator.on(Tuple input)
Set the input data for running this operator. 
 | 
SplitOperator | 
SplitOperator.on(Tuple input)
Set the input value to split 
 | 
Tuple | 
UnflatTupleOperator.on(Tuple input)
Make the operator  work on an input Tuple. 
 | 
Tuple | 
ToFlatTupleOperator.on(Tuple input)
Make the operator  work on an input Tuple. 
 | 
ValidateSchemaOperator | 
ValidateSchemaOperator.on(Tuple tuple)
Make the operator check if the provided tuple is conform with your schema. 
 | 
String | 
ToKvOperator.on(Tuple input)
Make the operator  work on an input Tuple. 
 | 
CidrMatchOperator | 
CidrMatchOperator.on(Tuple tuple)
Make the operator ready to act on the provided tuple. 
 | 
CidrRangeOperator | 
CidrRangeOperator.on(Tuple ip)
Set the input ip value you want to match. 
 | 
DateOperator | 
DateOperator.on(Tuple tuple)
Take the input date from a Tuple. 
 | 
FindByIntervalOperator | 
FindByIntervalOperator.on(Tuple tuple)
Fire the operator on the provided tuple. 
 | 
CsvOperator | 
CsvOperator.on(Tuple input)
Make the operator work on an input Tuple. 
 | 
boolean | 
GrokOperator.on(Tuple input)
Fire the grok matching. 
 | 
Long | 
TryEpochOperator.tryEpoch(Tuple t)
Return the timestamp in second or millisecond 
 | 
Long | 
TryEpochOperator.tryEpoch(Tuple t,
        long defaultValue)  | 
ContainsOperator | 
ContainsOperator.where(String key,
     Tuple value)
Return an operator to find a named element which matches some tuple value. 
 | 
FindByKeyOperator | 
FindByKeyOperator.where(String key,
     Tuple value)
Return an operator to find a named element which matches some tuple value. 
 | 
| Constructor and Description | 
|---|
CidrMatchOperator(Tuple tupleMap)
Ctor. 
 | 
ContainsOperator(Tuple sourceMap,
                String... key)
Return a new containsOperator, ready to answer queries with one or
 several lookup values. 
 | 
FindByIntervalOperator(Tuple sourceTuple)
Create a  
FindByIntervalOperator operator expecting ranges of min max values given either
 as arrays of 2 values, i.e. | 
FindByIntervalOperator(Tuple sourceTuple,
                      String intervalKey)
Create a FindInterval operator expecting ranges of min max given in arrays of 2 value, i.e. 
 | 
FindByIntervalOperator(Tuple sourceTuple,
                      String minKey,
                      String maxKey)
Create a  
FindByIntervalOperator operator expecting ranges of min max, i.e. | 
FindByKeyOperator(Tuple sourceMap,
                 String... key)
Return a new FindByKeyOperatorRefactor, ready to answer queries with one
 or several lookup values. 
 | 
GrokOperator(io.krakens.grok.api.Grok grok,
            Tuple[] roots,
            TupleFetcher[] fetchers)
This constructor is not meant to be called by applications. 
 | 
IpMatchOperator(Tuple sourceTuple)
Constructor 
 | 
MoveOperator(Tuple tuple)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
AbstractRemoteResourceHandler.get()  | 
Tuple | 
LocalResourceHandler.get()  | 
static Tuple | 
RemoteResourceHandlers.getRemoteResource(String resourceName)
Return the object corresponding to this resource name. 
 | 
static Tuple | 
RemoteResourceHandlers.getRemoteResourceAsTuple(String resourceName)
Return the Tuple corresponding to this resource name. 
 | 
protected static Tuple | 
RemoteResourceHandler.getResourceFromFile(String resourceUrl,
                   IResourceBuilder builder)  | 
protected static Tuple | 
RemoteResourceHandler.getResourceFromHttp(String resourceUrl,
                   IResourceBuilder builder)  | 
protected static Tuple | 
S3RemoteResourceHandler.getResourceFromS3(IResourceBuilder builder,
                 String endpoint,
                 String bucket,
                 String object,
                 Path accessKey,
                 Path secretKey)  | 
Tuple | 
AbstractRemoteResourceHandler.AtomicTupleReference.getTuple()  | 
static Tuple | 
RemoteResourceHandler.testGetResourceFromFile(String resourceUrl,
                       IResourceBuilder builder)
Test method to fetch files. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Supplier<Tuple> | 
RemoteResourceHandlers.computeIfAbsent(String url,
               Function<? super String,? extends Supplier<Tuple>> mappingFunction)
This method will return the first  
IRemoteResourceHandler initialised
 in this JVM for the provided URL. | 
Supplier<Tuple> | 
AbstractRemoteResourceHandler.start()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AbstractRemoteResourceHandler.AtomicTupleReference.setContent(Tuple content)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Supplier<Tuple> | 
RemoteResourceHandlers.computeIfAbsent(String url,
               Function<? super String,? extends Supplier<Tuple>> mappingFunction)
This method will return the first  
IRemoteResourceHandler initialised
 in this JVM for the provided URL. | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
CsvToArrayResourceBuilder.onEnd()  | 
Tuple | 
AbstractCsvResourceBuilder.onEnd()  | 
Tuple | 
JsonToTupleResourceBuilder.onEnd()  | 
Tuple | 
AbstractJsonResourceBuilder.onEnd()  | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
CsvToTuple.onEnd()  | 
Tuple | 
JsonToTuple.onEnd()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ByteBufTuple
This is the most efficient implementation. 
 | 
class  | 
LazyInPlaceTuple
This variant uses internally two lazy tuples to
 avoid storing twice the loaded values: the current one and the newly loaded one. 
 | 
class  | 
LazyTuple
This  
IResourceTuple efficiently encode the value and defer their 
 transformation in a real tuple only if there is a match. | 
class  | 
PlainTuple
This is a plain tuple offering an IResource interface. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Tuple | 
LazyTuple.get(String key)  | 
Tuple | 
LazyInPlaceTuple.get(String key)  | 
Tuple | 
ByteBufTuple.get(String key)  | 
Tuple | 
LazyTuple.onEnd()  | 
Tuple | 
LazyInPlaceTuple.onEnd()  | 
Tuple | 
PlainTuple.onEnd()  | 
Tuple | 
IResourceTuple.onEnd()
This signal tells you the  loading of a remote resource is now terminated. 
 | 
Tuple | 
ByteBufTuple.onEnd()  | 
Tuple | 
LazyTuple.set(Object value)  | 
Tuple | 
LazyInPlaceTuple.set(Object value)  | 
Tuple | 
ByteBufTuple.set(Object value)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
LazyTuple.addKeyValue(String k,
           Tuple item)  | 
void | 
LazyInPlaceTuple.addKeyValue(String k,
           Tuple item)
This method is called from the thread that fetch a remote resource
 In all cases an onStart was fired before, and once done an 
 onEnd will follow. 
 | 
void | 
PlainTuple.addKeyValue(String k,
           Tuple item)  | 
void | 
IResourceTuple.addKeyValue(String k,
           Tuple item)
Set or reset a value in a resource tuple 
 | 
void | 
ByteBufTuple.addKeyValue(String key,
           Tuple item)  | 
Copyright © 2023. All rights reserved.