public class Ops
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static com.rpl.rama.impl.NativeAnyArityRamaOperation |
AND
"and" operator based on values being "truthy" (not null or false).
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Class> |
CLASS
Emits
Class of argument. |
static com.rpl.rama.impl.NativeRamaFunction2<java.util.Collection,java.lang.Object,java.lang.Boolean> |
CONTAINS
Arguments are a collection and an object and returns boolean true or false
if the object is contained in the collection.
|
static com.rpl.rama.impl.NativeRamaFunction0<java.lang.Long> |
CURRENT_MICROBATCH_ID
Returns ID of current microbatch attempt.
|
static com.rpl.rama.impl.NativeRamaFunction0<java.lang.Integer> |
CURRENT_TASK_ID
Emits task ID where event is running
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Integer> |
DEC
Emits one less than input value as an
Integer |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Long> |
DEC_LONG
Emits one less than input value as a
Long |
static com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Double> |
DIV
Divides first argument by second argument and emits a
Double |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
EQUAL
Tests whether all arguments are equal and emits boolean true or false.
|
static com.rpl.rama.impl.NativeRamaOperation1<java.util.List<java.lang.Object>> |
EXPAND
Emits every element of input list as a separate field.
|
static com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> |
EXPLODE
Emits every element of input list individually.
|
static com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> |
EXPLODE_INDEXED
Emits every element of input list individually along with index of emit.
|
static com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> |
EXPLODE_MAP
Emits every key/value pair of input map individually.
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> |
EXTRACT_VALUE
Extracts contents of a PState as a value.
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> |
FIRST
Emits first element of input collection or
null if it is empty. |
static com.rpl.rama.impl.NativeRamaFunction2<java.lang.Object,java.lang.Object,java.lang.Object> |
GET
Arguments are a collection and a key and emits the value for the key in the collection.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
GREATER_THAN
Emits boolean true or false on if each argument is greater than the next argument.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
GREATER_THAN_OR_EQUAL
Emits boolean true or false on if each argument is greater than or equal to the next
argument.
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> |
IDENTITY
Emits input argument
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Integer> |
INC
Emits one more than input value as an
Integer |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Long> |
INC_LONG
Emits one more than input value as a
Long |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> |
IS_EVEN
Emits boolean true or false on whether input argument is an even number
|
static com.rpl.rama.impl.NativeRamaFunction2<java.lang.Class,java.lang.Object,java.lang.Boolean> |
IS_INSTANCE_OF
Arguments are a
Class and object and emits boolean true or false on whether the
second argument is an instance of the first argument |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> |
IS_NEGATIVE
Emits boolean true or false on whether input argument is a negative number
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> |
IS_NOT_NULL
Emits boolean true or false on whether input argument is not
null |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> |
IS_NULL
Emits boolean true or false on whether input argument is
null |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> |
IS_NUMBER
Emits boolean true or false on whether input argument is a number
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> |
IS_ODD
Emits boolean true or false on whether input argument is an odd number
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> |
IS_POSITIVE
Emits boolean true or false on whether input argument is a positive number
|
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> |
LAST
Emits last element of input collection or
null if it is empty. |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LESS_THAN
Emits boolean true or false on if each argument is less than the next argument.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LESS_THAN_OR_EQUAL
Emits boolean true or false on if each argument is less than or equal to the next argument.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LOG_DEBUG
Logs at debug level using slf4j Logger.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LOG_ERROR
Logs at error level using slf4j Logger.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LOG_INFO
Logs at info level using slf4j Logger.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LOG_TRACE
Logs at trace level using slf4j Logger.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
LOG_WARN
Logs at warn level using slf4j Logger.
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
MAX
Emits maximum value of all input arguments
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
MIN
Emits minimum value of all input arguments
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
MINUS
Emits result of subtracting all arguments after the first argument from the first argument as
an
Integer . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
MINUS_LONG
Emits result of subtracting all arguments after the first argument from the first argument as
a
Long . |
static com.rpl.rama.impl.NativeRamaFunction0<ModuleInstanceInfo> |
MODULE_INSTANCE_INFO
Emits
ModuleInstanceInfo for module and worker of running event |
static com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Integer> |
MODULO
Emits first argument modulo the second argument as an
Integer |
static com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Long> |
MODULO_LONG
Emits first argument modulo the second argument as a
Long |
static com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> |
NOT
"not" operator based on whether input is "truthy" (not null or false).
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
NOT_EQUAL
Tests whether any arguments are not equal and emits boolean true or false.
|
static com.rpl.rama.impl.NativeAnyArityRamaOperation |
OR
"or" operator based on values being "truthy" (not null or false).
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
PLUS
Emits result of adding all input numbers together as an
Integer . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
PLUS_LONG
Emits result of adding all input numbers together as a
Long . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
PRINTLN
Prints all input arguments to stdout
|
static com.rpl.rama.impl.NativeRamaOperation2<java.lang.Number,java.lang.Number> |
RANGE
Arguments are a starting integer (inclusive) and an end integer (exclusive) and
emits each integer between than range individually
Example:
Block.each(Ops.RANGE, 10, 20).out("*i") |
static com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Integer> |
SIZE
Emits size of input collection as an
Integer |
static com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Integer> |
SUM
Emits sum of all numbers in input list as an
Integer . |
static com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Long> |
SUM_LONG
Emits sum of all numbers in input list as a
Long . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
TIMES
Emits result of multiplying all input numbers together as an
Integer . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
TIMES_LONG
Emits result of multiplying all input numbers together as a
Long . |
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
TO_STRING
Emits result of converting all input arguments to strings and concatenating them together
|
static com.rpl.rama.impl.NativeAnyArityRamaFunction |
TUPLE
Combines all input arguments into a
List
Example: Block.each(Ops.TUPLE, 1, 2, 3).out("*tuple") |
Constructor and Description |
---|
Ops() |
public static final com.rpl.rama.impl.NativeAnyArityRamaOperation AND
Expr
arguments after a non-truthy value.
AND
with zero arguments emits boolean true.public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Class> CLASS
Class
of argument. CLASS
on null emits null.public static final com.rpl.rama.impl.NativeRamaFunction2<java.util.Collection,java.lang.Object,java.lang.Boolean> CONTAINS
null
is considered an empty
collection.public static final com.rpl.rama.impl.NativeRamaFunction0<java.lang.Long> CURRENT_MICROBATCH_ID
public static final com.rpl.rama.impl.NativeRamaFunction0<java.lang.Integer> CURRENT_TASK_ID
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Integer> DEC
Integer
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Long> DEC_LONG
Long
public static final com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Double> DIV
Double
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction EQUAL
Object.equals(Object)
.public static final com.rpl.rama.impl.NativeRamaOperation1<java.util.List<java.lang.Object>> EXPAND
Block.each(Ops.EXPAND, Arrays.asList(1, 2, 3)).out("*a", "*b", "*c")
public static final com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> EXPLODE
public static final com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> EXPLODE_INDEXED
Block.each(Ops.EXPLODE_INDEXED, Arrays.asList(1, 2, 3)).out("*index", "*val")
public static final com.rpl.rama.impl.NativeRamaOperation1<java.lang.Object> EXPLODE_MAP
Block.each(Ops.EXPLODE_MAP, m).out("*key", "*val")
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> FIRST
null
if it is empty. null
is
considered an empty collection.public static final com.rpl.rama.impl.NativeRamaFunction2<java.lang.Object,java.lang.Object,java.lang.Object> GET
null
for
non-existing keys. null
is considered an empty collection.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction GREATER_THAN
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction GREATER_THAN_OR_EQUAL
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> IDENTITY
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Integer> INC
Integer
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Long> INC_LONG
Long
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> IS_EVEN
public static final com.rpl.rama.impl.NativeRamaFunction2<java.lang.Class,java.lang.Object,java.lang.Boolean> IS_INSTANCE_OF
Class
and object and emits boolean true or false on whether the
second argument is an instance of the first argumentpublic static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> IS_NEGATIVE
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> IS_NOT_NULL
null
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> IS_NULL
null
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> IS_NUMBER
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> IS_ODD
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Number,java.lang.Boolean> IS_POSITIVE
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> LAST
null
if it is empty. null
is
considered an empty collection.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LESS_THAN
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LESS_THAN_OR_EQUAL
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LOG_DEBUG
Logger
class, and rest of arguments correspond to that interface.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LOG_ERROR
Logger
class, and rest of arguments correspond to that interface.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LOG_INFO
Logger
class, and rest of arguments correspond to that interface.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LOG_TRACE
Logger
class, and rest of arguments correspond to that interface.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction LOG_WARN
Logger
class, and rest of arguments correspond to that interface.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction MAX
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction MIN
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction MINUS
Integer
. If called with only one argument, emits negative of that value.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction MINUS_LONG
Long
. If called with only one argument, emits negative of that value.public static final com.rpl.rama.impl.NativeRamaFunction0<ModuleInstanceInfo> MODULE_INSTANCE_INFO
ModuleInstanceInfo
for module and worker of running eventpublic static final com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Integer> MODULO
Integer
public static final com.rpl.rama.impl.NativeRamaFunction2<java.lang.Number,java.lang.Number,java.lang.Long> MODULO_LONG
Long
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Boolean> NOT
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction NOT_EQUAL
Object.equals(Object)
.public static final com.rpl.rama.impl.NativeAnyArityRamaOperation OR
Expr
arguments after a truthy value.
OR
with zero arguments emits null
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction PLUS
Integer
. If no arguments, emits
zero.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction PLUS_LONG
Long
. If no arguments, emits
zero.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction PRINTLN
public static final com.rpl.rama.impl.NativeRamaOperation2<java.lang.Number,java.lang.Number> RANGE
Block.each(Ops.RANGE, 10, 20).out("*i")
public static final com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Integer> SIZE
Integer
public static final com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Integer> SUM
Integer
. Emits zero for empty list.public static final com.rpl.rama.impl.NativeRamaFunction1<java.util.Collection,java.lang.Long> SUM_LONG
Long
. Emits zero for empty list.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction TIMES
Integer
. If no
arguments, emits one.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction TIMES_LONG
Long
. If no
arguments, emits one.public static final com.rpl.rama.impl.NativeAnyArityRamaFunction TO_STRING
public static final com.rpl.rama.impl.NativeAnyArityRamaFunction TUPLE
List
Example: Block.each(Ops.TUPLE, 1, 2, 3).out("*tuple")
public static final com.rpl.rama.impl.NativeRamaFunction1<java.lang.Object,java.lang.Object> EXTRACT_VALUE
Class
schema.