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() |
abstract Supplier<Tuple> |
AbstractRemoteResourceHandlerBuilder.getTupleSupplier() |
Supplier<Tuple> |
RemoteResourceHandlerBuilder.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.
|
boolean |
Tuple.remove(Tuple element)
Set operation: remove an element from a set.
|
static void |
Punchlet.remove(Tuple tuple)
Remove a tuple.
|
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 |
TupleImpl.compareTo(Tuple o) |
int |
AbstractTupleImpl.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) |
void |
RuntimeContext.remove(Tuple tuple)
Remove a tuple.
|
boolean |
AbstractTupleImpl.remove(Tuple element) |
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 |
ResourceOperator.asTuple() |
Tuple |
FetchCsvOperator.asTuple() |
Tuple |
FetchJsonOperator.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 |
CidrRangeOperator.onEnd() |
Tuple |
IpRangeOperator.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 |
DissectOperator.into(Tuple tuple)
Registers a tuple to hold the operator results.
|
boolean |
ContainsOperator.into(Tuple into)
Apply the operator an put the result into the provided tuple.
|
String |
DateOperator.into(Tuple tuple)
Fire and put the result of this operator into a destination tuple.
|
boolean |
CefOperator.into(Tuple tuple)
Fire the operator and put the result inside a destination tuple
|
boolean |
FindByKeyOperator.into(Tuple into)
Fire the operator
|
boolean |
CidrMatchOperator.into(Tuple tuple)
Fire the operator and put the result into the provided tuple
|
List<Tuple> |
ValidateSchemaOperator.into(Tuple result)
Stores validation results in provided tuple.
|
boolean |
SplitOperator.into(Tuple tuple)
Fire the operator and store the result in the passed tuple.
|
void |
NifiOperator.into(Tuple into)
Apply the operator an put the result into the provided tuple.
|
boolean |
MailOperator.into(Tuple tuple)
Put parsed headers and content into tuple.
|
boolean |
CidrRangeOperator.into(Tuple result)
Fire the operator
|
boolean |
ConvertorOperator.into(Tuple output)
Parse the input string and returns true if it was successfully converted into the output punch tuple.
|
boolean |
KvOperator.into(Tuple tuple)
Registers a tuple to hold the operator results.
|
boolean |
MoveOperator.into(Tuple dstTuple)
fire the move to the requested (Tuple) destination.
|
boolean |
CsvOperator.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 |
FindByIntervalOperator.into(Tuple into)
Actually perform the query and put the result into 'into'
|
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
|
boolean |
IGrokOperator.on(Tuple input) |
DissectOperator |
DissectOperator.on(Tuple input)
Set the input data for running this operator.
|
DateOperator |
DateOperator.on(Tuple tuple)
Take the input date from a Tuple.
|
CefOperator |
CefOperator.on(Tuple input)
Make the operator work on an input Tuple.
|
boolean |
GrokOperator.on(Tuple input)
Fire the grok matching.
|
Tuple |
UnflatTupleOperator.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.
|
ValidateSchemaOperator |
ValidateSchemaOperator.on(Tuple tuple)
Make the operator check if the provided tuple is conform with your schema.
|
SplitOperator |
SplitOperator.on(Tuple input)
Set the input value to split
|
MailOperator |
MailOperator.on(Tuple input)
Make the operator work on an input Tuple.
|
Tuple |
ToFlatTupleOperator.on(Tuple input)
Make the operator work on an input Tuple.
|
CidrRangeOperator |
CidrRangeOperator.on(Tuple ip)
Set the input ip value you want to match.
|
KvOperator |
KvOperator.on(Tuple input)
Set the input data for running this operator.
|
String |
ToKvOperator.on(Tuple input)
Make the operator work on an input Tuple.
|
CsvOperator |
CsvOperator.on(Tuple input)
Make the operator work on an input Tuple.
|
SyslogHeaderOperator |
SyslogHeaderOperator.on(Tuple log) |
IpRangeOperator |
IpRangeOperator.on(Tuple ip)
Set the input ip value you want to match.
|
FindByIntervalOperator |
FindByIntervalOperator.on(Tuple tuple)
Fire the operator on the provided tuple.
|
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 |
JsonToTupleResourceBuilder.onEnd() |
Tuple |
AbstractCsvResourceBuilder.onEnd() |
Tuple |
AbstractJsonResourceBuilder.onEnd() |
Modifier and Type | Method and Description |
---|---|
Tuple |
JsonToTuple.onEnd() |
Tuple |
CsvToTuple.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 |
ByteBufTuple.get(String key) |
Tuple |
LazyTuple.get(String key) |
Tuple |
LazyInPlaceTuple.get(String key) |
Tuple |
PlainTuple.onEnd() |
Tuple |
ByteBufTuple.onEnd() |
Tuple |
LazyTuple.onEnd() |
Tuple |
IResourceTuple.onEnd()
This signal tells you the loading of a remote resource is now terminated.
|
Tuple |
LazyInPlaceTuple.onEnd() |
Tuple |
ByteBufTuple.set(Object value) |
Tuple |
LazyTuple.set(Object value) |
Tuple |
LazyInPlaceTuple.set(Object value) |
Modifier and Type | Method and Description |
---|---|
void |
PlainTuple.addKeyValue(String k,
Tuple item) |
void |
ByteBufTuple.addKeyValue(String key,
Tuple item) |
void |
LazyTuple.addKeyValue(String k,
Tuple item) |
void |
IResourceTuple.addKeyValue(String k,
Tuple item)
Set or reset a value in a resource tuple
|
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.
|
Copyright © 2022. All rights reserved.