IBM InfoSphere Streams Version 4.1.1

Functions: spl 1.2.1

SPL standard and specialized toolkits > spl 1.2.1 > Functions

Functions

PEID(): Return the PE ID for the current processing element that this operator is executing in.
PI(): Value of PI.
abort(): Abort program execution.
abs(T): Compute the absolute value.
abs(T): Compute the absolute value.
abs(complex32): Compute the absolute value.
abs(complex64): Compute the absolute value.
abs(list<T>): Compute the absolute value of a list.
abs(list<T>[N]): Compute the absolute value of a list.
acos(T): Compute the arc-cosine.
add(timestamp, float64): Add a time difference to a timestamp (in seconds as float64).
add(timestamp, int64): Add a time difference to a timestamp (in nanoseconds as int64).
appLog(enum{error, warn, info}, T): Log a message in the logging system.
appLog(enum{error, warn, info}, T, T): Log a message in the logging system.
appTrc(enum{error, warn, info, debug, trace}, T): Log a message in the tracing system.
appTrc(enum{error, warn, info, debug, trace}, T, T): Log a message in the tracing system.
appendM(blob, list<uint8>): Append to blob.
appendM(blob, uint8): Append to blob.
appendM(list<T>, T): Append to a list (mutating version).
appendM(list<T>[N], T): Append to a list (mutating version).
appendM(rstring[N], rstring): Append an rstring to a bounded rstring.
appendM(rstring[N], rstring[M]): Append a bounded rstring to a bounded rstring.
asin(T): Compute the arcsine.
assert(boolean): Check assertion at runtime.
assert(boolean, T): Check assertion at runtime (with message).
assert(list<boolean>): Check assertion at runtime.
assert(list<boolean>[N]): Check assertion at runtime.
assert(map<T, boolean>): Check assertion at runtime.
assert(map<T, boolean>[N]): Check assertion at runtime.
assignFrom(T1, T2): Assign matching fields of a tuple from another one.
at(list<T>, list<uint32>): Multi-element access.
at(list<T>[N], list<uint32>): Multi-element access.
atan(T): Compute the arc-tangent.
avg(list<T>): Compute the average of a list.
avg(list<T>[N]): Compute the average of a list.
blobSize(blob): Get the size of a blob.
block(float64): Block until shutdown is requested, or the specified amount of time has elapsed, whichever comes first.
ceil(T): Compute the smallest integer value equal to or greater than a value.
ceil(decimal32): Compute the smallest integer value equal to or greater than a value.
ceil(decimal64): Compute the smallest integer value equal to or greater than a value.
clearM(T): Clear (empty) a list.
clearM(blob): Clear (empty) a list.
clearerr(uint64): Clear end of file indicator.
concat(list<T>, list<T>): Concatenate lists.
concat(list<T>, list<T>[N]): Concatenate lists.
concat(list<T>[N], list<T>): Concatenate lists.
concat(list<T>[N], list<T>[M]): Concatenate lists.
concat(rstring, rstring): Concatenate two rstrings, returning an rstring.
concat(rstring, rstring[N]): Concatenate an rstring with a bounded rstring, returning an rstring.
concat(rstring[N], rstring): Concatenate a bounded rstring with an rstring, returning an rstring.
concat(rstring[N], rstring[M]): Concatenate two bounded rstrings, returning an rstring.
concatM(list<T>, list<T>): Concatenate lists (mutating version).
concatM(list<T>, list<T>[N]): Concatenate lists (mutating version).
concatM(list<T>[N], list<T>): Concatenate lists (mutating version).
concatM(list<T>[N], list<T>[M]): Concatenate lists (mutating version).
concatM(set<T>, set<T>): Concatenate sets (mutating version).
concatM(set<T>, set<T>[N]): Concatenate sets (mutating version).
concatM(set<T>[N], set<T>): Concatenate sets (mutating version).
concatM(set<T>[N], set<T>[M]): Concatenate sets (mutating version).
convertFromBlob(blob): Convert a blob to an rstring.
convertFromUtf8(rstring, rstring): Convert UTF-8 encoded string into data as raw bytes with a specified encoding.
convertFromUtf8ToString(rstring, rstring): Convert UTF-8 encoded string into a string with a specified encoding.
convertToBlob(rstring): Convert an rstring to a blob.
convertToUtf8(list<uint8>, rstring): Convert data given as raw bytes with a specified encoding into a UTF-8 encoded string.
convertToUtf8(list<uint8>[N], rstring): Convert data given as raw bytes with a specified encoding into a UTF-8 encoded string.
convertToUtf8(rstring, rstring): Convert data given as raw bytes with a specified encoding into a UTF-8 encoded string.
convertToXML(X, T): Convert a string to XML, returning the success status.
convertToXML(X, T, int32): Convert a string to XML, returning the success status and an error code.
cos(T): Compute the cosine.
countDistinct(list<T>): Compute distinct count of a list.
countDistinct(list<T>[N]): Compute distinct count of a list.
createCustomMetric(rstring, rstring, enum{Gauge, Counter, Time}, int64): Create the specified custom metric for the current operator and set its initial value.
createCustomMetric(ustring, ustring, enum{Gauge, Counter, Time}, int64): Create the specified custom metric for the current operator and set its initial value.
createTimestamp(int64, uint32): Create a timestamp.
createTimestamp(int64, uint32, int32): Create a timestamp.
csvTokenize(rstring): CSV tokenize string.
csvTokenize(ustring): CSV tokenize string.
ctime(timestamp): Convert a time value to a date and time string, using the current timezone.
dataDirectory(): Return the absolute pathname to the data directory for the Processing Element.
day(timestamp): Extract the day of month from the time, using the current timezone.
dayOfWeek(timestamp): Extract the day of week from the time, using the current timezone.
dayOfYear(timestamp): Extract the day of year from the time, using the current timezone.
diffAsNanos(timestamp, timestamp): Compute the difference between two timestamps (in nanoseconds as int64).
diffAsSecs(timestamp, timestamp): Compute the difference between two timestamps (in seconds as float64).
domainID(): Return the domain ID that the PE is running in.
evalPredicate(rstring, T, int32): Evaluates the SPL predicate, represented as an rstring, using the given tuple.
exp(T): Compute e to a power.
exp(T): Compute e to a power.
fclose(uint64, int32): Close a file.
feof(uint64): Test if the stream is at end of file.
fflush(uint64, int32): Flush a file to disk.
find(list<T>, T): Find matching values in a list.
find(list<T>[N], T): Find matching values in a list.
findFirst(T, T): Find a substring in a string, starting at index 0.
findFirst(T, T, int32): Find a substring in a string.
findFirst(list<T>, T): Find the first occurrence of a matching value in a list, starting at index 0.
findFirst(list<T>, T, int32): Find the first occurrence of a matching value in a list.
findFirst(list<T>, list<T>): Find the first occurrence of a matching value sequence in a list, starting at index 0.
findFirst(list<T>, list<T>, int32): Find the first occurrence of a matching value sequence in a list.
findFirst(list<T>[N], T): Find the first occurrence of a matching value in a list, starting at index 0.
findFirst(list<T>[N], T, int32): Find the first occurrence of a matching value in a list.
findFirst(list<T>[N], list<T>[M]): Find the first occurrence of a matching value sequence in a list, starting at index 0.
findFirst(list<T>[N], list<T>[M], int32): Find the first occurrence of a matching value sequence in a list.
findFirstNotOf(T, T): Find a non-matching character in a string, starting at index 0.
findFirstNotOf(T, T, int32): Find a non-matching character in a string.
findFirstNotOf(list<T>, list<T>): Find the first occurrence of a non-matching value in a list, starting at index 0.
findFirstNotOf(list<T>, list<T>, int32): Find the first occurrence of a non-matching value in a list.
findFirstNotOf(list<T>, list<T>[N]): Find the first occurrence of a non-matching value in a list, starting at index 0.
findFirstNotOf(list<T>, list<T>[N], int32): Find the first occurrence of a non-matching value in a list.
findFirstNotOf(list<T>[N], list<T>): Find the first occurrence of a non-matching value in a list, starting at index 0.
findFirstNotOf(list<T>[N], list<T>, int32): Find the first occurrence of a non-matching value in a list.
findFirstNotOf(list<T>[N], list<T>[M]): Find the first occurrence of a non-matching value in a list, starting at index 0.
findFirstNotOf(list<T>[N], list<T>[M], int32): Find the first occurrence of a non-matching value in a list.
findFirstOf(T, T): Find a matching character in a string, starting at index 0.
findFirstOf(T, T, int32): Find a matching character in a string.
findFirstOf(list<T>, list<T>): Find the first occurrence of a matching value in a list, starting at index 0.
findFirstOf(list<T>, list<T>, int32): Find the first occurrence of a matching value in a list.
findFirstOf(list<T>, list<T>[N]): Find the first occurrence of a matching value in a list, starting at index 0.
findFirstOf(list<T>, list<T>[N], int32): Find the first occurrence of a matching value in a list.
findFirstOf(list<T>[N], list<T>): Find the first occurrence of a matching value in a list, starting at index 0.
findFirstOf(list<T>[N], list<T>, int32): Find the first occurrence of a matching value in a list.
findFirstOf(list<T>[N], list<T>[M]): Find the first occurrence of a matching value in a list, starting at index 0.
findFirstOf(list<T>[N], list<T>[M], int32): Find the first occurrence of a matching value in a list.
findLast(T, T, int32): Find a substring in a string.
findLast(list<T>, T, int32): Find the last occurrence of a matching value in a list.
findLast(list<T>, list<T>, int32): Find the last occurrence of a matching value sequence in a list.
findLast(list<T>[N], T, int32): Find the last occurrence of a matching value in a list.
findLast(list<T>[N], list<T>[M], int32): Find the last occurrence of a matching value sequence in a list.
findLastNotOf(T, T, int32): Find the last non-matching character in a string.
findLastNotOf(list<T>, list<T>, int32): Find the last occurrence of a non-matching value in a list.
findLastNotOf(list<T>, list<T>[N], int32): Find the last occurrence of a non-matching value in a list.
findLastNotOf(list<T>[N], list<T>, int32): Find the last occurrence of a non-matching value in a list.
findLastNotOf(list<T>[N], list<T>[M], int32): Find the last occurrence of a non-matching value in a list.
findLastOf(T, T, int32): Find a matching character in a string.
findLastOf(list<T>, list<T>, int32): Find the last occurrence of a matching value in a list.
findLastOf(list<T>, list<T>[N], int32): Find the last occurrence of a matching value in a list.
findLastOf(list<T>[N], list<T>, int32): Find the last occurrence of a matching value in a list.
findLastOf(list<T>[N], list<T>[M], int32): Find the last occurrence of a matching value in a list.
findNotOf(list<T>, list<T>): Find non-matching values in a list.
findNotOf(list<T>, list<T>[N]): Find non-matching values in a list.
findNotOf(list<T>[N], list<T>): Find non-matching values in a list.
findNotOf(list<T>[N], list<T>[M]): Find non-matching values in a list.
findOf(list<T>, list<T>): Find matching values in a list.
findOf(list<T>, list<T>[N]): Find matching values in a list.
findOf(list<T>[N], list<T>): Find matching values in a list.
findOf(list<T>[N], list<T>[M]): Find matching values in a list.
floor(T): Compute the largest integer value equal to or less than a value.
flushStdio(): Flush all stdio output streams.
fmod(T, T): Return the floating point remainder (see man 3 fmod for details and return values).
fopen(rstring, rstring, int32): Open a file.
fopen(ustring, ustring, int32): Open a file.
formatNumber(float64): Format a float using locale specific format.
formatNumber(float64, uint32, uint32, boolean): Format a float using locale specific format.
formatNumber(int64): Format an integer using locale specific format.
formatNumber(int64, uint32): Format an integer using locale specific format.
fread(list<uint8>, uint64, uint64, int32): Read a list of bytes from a file as binary.
freadBin(T, uint64, int32): Read an SPL Value from a file as a binary value.
freadLine(uint64, int32): Read a line from a file.
freadToken(uint64, int32): Read a 'token' from a file.
freadTxt(T, uint64, int32): Read an SPL Value from a file as a text string.
freadfile(blob, uint64, int32): Read a whole file into a blob as binary.
fromDecimal128(decimal128): Convert a decimal128 value to a timestamp.
fseek(uint64, int64, int32, int32): Set the current file position.
fstat(rstring, rstring, timestamp, int32): Return timestamp information about a file.
fstat(rstring, rstring, uint64, int32): Return information about a file.
fstat(uint64, rstring, timestamp, int32): Return timestamp information about a file.
fstat(uint64, rstring, uint64, int32): Return information about a file.
fstat(uint64, ustring, timestamp, int32): Return timestamp information about a file.
fstat(uint64, ustring, uint64, int32): Return information about a file.
fstat(ustring, ustring, timestamp, int32): Return timestamp information about a file.
fstat(ustring, ustring, uint64, int32): Return information about a file.
ftell(uint64, int32): Return the current file position.
fwrite(list<uint8>, uint64, uint64, uint64, int32): Write a list of bytes to a file as binary.
fwriteBin(T, uint64, int32): Write an SPL Value to a file as a binary value.
fwriteString(T, uint64, int32): Write a string to a file.
fwriteTxt(T, uint64, int32): Write an SPL Value to a file as a text string.
fwriteblob(blob, uint64, int32): Write a blob into a file as binary.
getApplicationDir(): Return the full path to the application directory.
getApplicationName(): Return the name of the application that is executing this operator.
getCPUCounterInNanoSeconds(): Obtain the CPU counter, which is an indication of relative time in nanoseconds.
getChannel(): Get the parallel channel index.
getCompileTimeListValue(rstring): Return the named compiler invocation argument list value (name="value0,value1").
getCompileTimeValue(rstring): Return a named compiler invocation argument value (name=value).
getCompileTimeValue(rstring, rstring): Return a named compiler invocation argument value (name=value).
getConfiguredHostName(): Get the hostname used by the streams instance for this host.
getConsistentRegionIndex(): Gets the index of the consistent region.
getCustomMetricNames(): Return the names of the custom metrics for the current operator.
getCustomMetricValue(rstring, int64): Get the specified custom metric value for the current operator.
getCustomMetricValue(ustring, int64): Get the specified custom metric value for the current operator.
getDrainTimeout(): Gets the drain timeout of a consistent region.
getEnvironmentVariable(rstring): Get the value of an environment variable.
getEnvironmentVariable(rstring, boolean): Get the value of an environment variable.
getEnvironmentVariable(rstring, rstring): Get the value of an environment variable.
getHostName(): Get the host name.
getIPAddress(): Get the IP address for the current host.
getInputPortImportFilterExpression(uint32, int32): Get the filter expression for an imported input port.
getInputPortImportSubscription(uint32, int32): Get the import subscription for an imported input port.
getInputPortMetricValue(uint32, enum{nTuplesProcessed, nTuplesDropped, nTuplesQueued, nWindowPunctsProcessed, nFinalPunctsProcessed, nWindowPunctsQueued, nFinalPunctsQueued, queueSize}, int64): Get the specified input port metric value for the current operator.
getJobGroup(): Return the name of the job group for the current job that this operator is executing in.
getJobName(): Return the name of the current job that this operator is executing in.
getMachineId(timestamp): Extract the machine id from a timestamp.
getMainCompositeName(): Return the name of the main composite.
getMaxChannels(): Get the maximum number of parallel channels.
getNanoseconds(timestamp): Extract the nanoseconds from a timestamp.
getOutputPortCongestionFactor(uint32): Return the maximum congestion factor for all connections from an output port that connects to another PE.
getOutputPortExportProperties(list<tuple<rstring name, rstring value, rstring typ>>, uint32): Get the export properties for an exported output port.
getOutputPortMetricValue(uint32, enum{nTuplesSubmitted, nWindowPunctsSubmitted, nFinalPunctsSubmitted}, int64): Get the specified output port metric value for the current operator.
getPEOutputPortConnections(uint32, list<tuple<int64 pe, int64 port, uint8 congestionFactor, uint64 nTuplesFilteredOut>>): Return the connection information for an output port that connects to another PE.
getRelaunchCount(): Return the number of times the PE that the operator is executing in has been relaunched.
getResetAttempt(): If the operator is in a consistent region, this function returns the retry attempt of resetting the consistent region to a consistent state.
getResetTimeout(): Gets the reset timeout of a consistent region.
getSeconds(timestamp): Extract the seconds from a timestamp.
getSequenceId(): Gets the current sequence identifier of a consistent region.
getShortHostName(): Get the short host name.
getSubmissionTimeListValue(rstring): Return the named submission time list value (name="value0,value1").
getSubmissionTimeValue(rstring): Return the named submission time value (name="value").
getSubmissionTimeValue(rstring, rstring): Return the named submission time value (name="value").
getThisCompositeInstanceName(): Return the name of the current composite instance.
getThisFileDir(): Return the full pathname of the directory of the current file name as an rstring.
getThisFileName(): Return the current file name as an rstring.
getThisFilePath(): Return the full pathname of the current file name as an rstring.
getThisLine(): Return the current line number as an int32.
getThisOperatorLogicalName(): Get the logical name of the operator.
getThisOperatorName(): Get the physical name of the operator.
getThisToolkitDir(): Return the full epath to the root directory of the toolkit containing the SPL file containing this call.
getTimestamp(): Get the current wall clock time.
getTimestampInSecs(): Get the current wall clock time in seconds (fractional).
gmday(timestamp): Extract the day of month from the time, using the UTC timezone.
gmdayOfWeek(timestamp): Extract the day of week from the time, using the UTC timezone.
gmdayOfYear(timestamp): Extract the day of year from the time, using the UTC timezone.
gmhour(timestamp): Extract the hour from the time, using the UTC timezone.
gmminute(timestamp): Extract the minute from the time, using the UTC timezone.
gmmonth(timestamp): Extract the month from the time, using the UTC timezone.
gmsecond(timestamp): Extract the second from the time, using the UTC timezone.
gmtime(timestamp, tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>): Convert a timestamp to broken-down time (Sys.tm) using UTC timezone.
gmyear(timestamp): Extract the year from the time, using the UTC timezone.
has(list<T>, T): Find whether a given value exists in a list.
has(list<T>[N], T): Find whether a given value exists in a list.
has(map<K, V>, K): Find whether a given key exists in a map.
has(map<K, V>[N], K): Find whether a given key exists in a map.
has(set<T>, T): Find whether a given value exists in a set.
has(set<T>[N], T): Find whether a given value exists in a set.
hasCustomMetric(rstring): Check if the specified custom metric exists.
hasCustomMetric(ustring): Check if the specified custom metric exists.
hashCode(T): Compute the hash of a value.
hashCodeForEach(L): Compute hashes of a list of values, using the same hashing method as hashCode().
hour(timestamp): Extract the hour from the time, using the current timezone.
imag(complex32): Return the 'imaginary' part of a complex number.
imag(complex64): Return the 'imaginary' part of a complex number.
infl(): Return a float64 infinity.
infw(): Return a float32 infinity.
inputPort(T): Return the index corresponding to an input port.
insert(list<T>, T, int32): Insert value into a list.
insert(list<T>, list<T>, int32): Insert a list of values into a list.
insert(list<T>, list<T>[N], int32): Insert a list of values into a list.
insert(list<T>[N], T, int32): Insert value into a list.
insert(list<T>[N], list<T>, int32): Insert a list of values into a list.
insert(list<T>[N], list<T>[M], int32): Insert a list of values into a list.
insert(map<K, V>, K, V): Insert an element into a map.
insert(map<K, V>[N], K, V): Insert an element into a map.
insert(set<V>, V): Insert into a set.
insert(set<V>[N], V): Insert into a set.
insertM(list<T>, T, int32): Insert value into a list (mutating version).
insertM(list<T>, list<T>, int32): Insert values into a list (mutating version).
insertM(list<T>, list<T>[N], int32): Insert values into a list (mutating version).
insertM(list<T>[N], T, int32): Insert value into a list (mutating version).
insertM(list<T>[N], list<T>, int32): Insert values into a list (mutating version).
insertM(list<T>[N], list<T>[M], int32): Insert values into a list (mutating version).
insertM(map<K, V>, K, V): Insert an element into a map (mutating version).
insertM(map<K, V>[N], K, V): Insert an element into a map (mutating version).
insertM(set<V>, V): Insert into a set (mutating version).
insertM(set<V>[N], V): Insert into a set (mutating version).
instanceID(): Return the instance ID that the PE is running in.
interpretRStringLiteral(rstring): Interpret an SPL rstring literal stored in a utf8 encoded string.
interpretUStringLiteral(rstring): Interpret an SPL ustring literal stored in a utf8 encoded string.
isConsistentInputPort(uint32): Check if the input port is consistent.
isControlInputPort(uint32): Check if the input port is a control port.
isDefaultValue(X): Return if this XML value contains the default (uninitialized) value.
isEACCES(int32): Return whether the value is EACCES.
isEAGAIN(int32): Return whether the value is EAGAIN.
isEBADF(int32): Return whether the value is EBADF.
isEFAULT(int32): Return whether the value is EFAULT.
isEFBIG(int32): Return whether the value is EFBIG.
isEINTR(int32): Return whether the value is EINTR.
isEINVAL(int32): Return whether the value is EINVAL.
isEIO(int32): Return whether the value is EIO.
isEISDIR(int32): Return whether the value is EISDIR.
isELOOP(int32): Return whether the value is ELOOP.
isEMFILE(int32): Return whether the value is EMFILE.
isENAMETOOLONG(int32): Return whether the value is ENAMETOOLONG.
isENFILE(int32): Return whether the value is ENFILE.
isENODEV(int32): Return whether the value is ENODEV.
isENOENT(int32): Return whether the value is ENOENT.
isENOMEM(int32): Return whether the value is ENOMEM.
isENOSPC(int32): Return whether the value is ENOSPC.
isENOTDIR(int32): Return whether the value is ENOTDIR.
isENXIO(int32): Return whether the value is ENXIO.
isEOF(int32): Return whether the value is EOF.
isEOVERFLOW(int32): Return whether the value is EOVERFLOW.
isEPERM(int32): Return whether the value is EPERM.
isEPIPE(int32): Return whether the value is EPIPE.
isEROFS(int32): Return whether the value is EROFS.
isESPIPE(int32): Return whether the value is ESPIPE.
isETXTBSY(int32): Return whether the value is ETXTBSY.
isEWOULDBLOCK(int32): Return whether the value is EWOULDBLOCK.
isEndOfConsistentRegion(): Check if the operator is an end operator of a consistent region.
isInConsistentRegion(): Check if the operator is in a consistent region.
isInf(T): Return whether the floating point value is an infinity.
isInf(T): Return whether the complex value is an infinity.
isLoggable(enum{error, warn, info}): Determine whether a message at the given level would be logged.
isNaN(T): Return whether the floating point value is a NaN.
isNaN(T): Return whether the complex value is a NaN.
isShutdown(): Check if shutdown is requested.
isStartOfConsistentRegion(): Check if the operator is a start operator of a consistent region.
isTraceable(enum{error, warn, info, debug, trace}): Determine whether a message at the given level would be traced.
isTriggerOfConsistentRegion(): Check if the operator the trigger operator of an operator-driven consistent region.
jobID(): Return the Job ID for the current job that this operator is executing in.
keys(map<K, V>): Return a list of the keys in the given map.
keys(map<K, V>[N]): Return a list of the keys in the given map.
kthelem(list<T>, uint32): Compute the kth element in ascending order.
kthelem(list<T>[N], uint32): Compute the kth element in ascending order.
length(T): Get the length of a string (the number of raw bytes).
lexicographicalCompare(list<T>, list<T>): Compare two lists in lexicographical order.
lexicographicalCompare(list<T>[N], list<T>[M]): Compare two lists in lexicographical order.
lg(T): Compute log base 10.
lg(T): Compute log base 10.
ln(T): Compute log base e.
ln(T): Compute log base e.
loadAndFormatResource(rstring, rstring, rstring): Loads a string from a toolkit resource.
loadAndFormatResource(rstring, rstring, rstring, T): Loads and formats a string from a toolkit resource.
loadAndFormatResource(rstring, rstring, rstring, T, rstring): Loads and formats a string from a toolkit resource.
loadAndFormatResource(rstring, rstring, rstring, rstring): Loads a string from a toolkit resource.
log(T): Compute log base e.
log(T): Compute log base e.
log(enum{error, info, debug, trace}, T): Log a message in the tracing system.
log(enum{error, info, debug, trace}, T, T): Log a message in the tracing system.
log10(T): Compute log base 10.
log10(T): Compute log base 10.
lower(T): Convert string to lowercase.
ltrim(T, T): Remove leading characters from a string.
makeRStringLiteral(rstring): Make an SPL rstring literal.
makeSequence(T, int32): Make a sequence.
makeSequence(T, int32): Make a sequence.
makeSequence(T, int32, T): Make a sequence.
makeUStringLiteral(ustring): Make an SPL ustring literal.
max(T, T): Compute the maximimum of two values.
max(list<T>): Find the maximum value in a list.
max(list<T>[N]): Find the maximum value in a list.
median(list<T>): Compute the median of a list for numeric types that have overloaded the arithmetic operators.
median(list<T>[N]): Compute the median of a list for numeric types that have overloaded the arithmetic operators.
min(T, T): Compute the minimum of two values.
min(list<T>): Find the minimum value in a list.
min(list<T>[N]): Find the minimum value in a list.
minute(timestamp): Extract the minute from the time, using the current timezone.
mkdir(rstring, uint32, int32): Create a directory
mktemp(rstring): Return the name of a temporary file created using a template.
month(timestamp): Extract the month from the time, using the current timezone.
nanl(): Return a float64 NaN (Not A Number).
nanw(): Return a float32 NaN (Not A Number).
optSEEK_CUR(): Indicator to seek relative to current file position.
optSEEK_END(): Indicator to seek relative to end of file.
optSEEK_SET(): Indicator to seek relative to start of file.
outputPort(T): Return the index corresponding to an output port.
pairwiseCompare(T, list<T>): Compare element-wise, with scalar.
pairwiseCompare(T, list<T>[N]): Compare element-wise, with scalar.
pairwiseCompare(list<T>, T): Compare element-wise, with scalar.
pairwiseCompare(list<T>, list<T>): Compare - element-wise.
pairwiseCompare(list<T>[N], T): Compare element-wise, with scalar.
pairwiseCompare(list<T>[N], list<T>[N]): Compare element-wise.
pairwiseMax(list<T>, list<T>): Compare and fetch the larger - element-wise.
pairwiseMax(list<T>[N], list<T>[N]): Compare and fetch the larger - element-wise.
pairwiseMin(list<T>, list<T>): Compare and fetch the smaller - element-wise.
pairwiseMin(list<T>[N], list<T>[N]): Compare and fetch the smaller - element-wise.
parseNumber(float64, rstring): Parse a string that represents a number, using the current locale.
parseNumber(float64, ustring): Parse a string that represents a number, using the current locale.
parseNumber(int64, rstring): Parse a string that represents a base 10 number, using the current locale.
parseNumber(int64, rstring, int32): Parse a string that represents a number, using the current locale.
parseNumber(int64, ustring): Parse a string that represents a number, using the current locale.
pow(T, T): Perform exponentiation.
pow(T, T): Perform exponentiation.
pow(T, T): Perform exponentiation.
print(T): Write any SPL type to stdout as an SPL literal.
printString(T): Write a string to stdout.
printStringLn(T): Write a string to stdout, followed by a newline, and then the output is flushed.
println(T): Write any SPL type to stdout, in serialized form, followed by a newline.
random(): Return a random number.
random(int32): Return a list of random numbers.
range(T): Return a list of values in the range from 0 to size(l)-1 Note: This is optimized by the SPL compiler to avoid creating the list in: for (int32 i in range(myList)).
range(int32): Return a list of values in the range from 0 to limit-1 Note: An empty list is returned if limit <= 0.
range(int32, int32): Return a list of values in the range from start to limit-1 Note: An empty list is returned if limit <= start.
range(int32, int32, int32): Return a list of values in the range from start to limit-1, with an increment of step Note: An empty list is returned if limit <= start for positive step or limit >= start for negative step.
real(complex32): Return the 'real' part of a complex number.
real(complex64): Return the 'real' part of a complex number.
regexMatch(rstring, rstring): Match a string with a regular expression using POSIX Extended Regular Expressions (ERE), including sub-expression (capture group) matching using parentheses "()".
regexMatch(ustring, ustring): Match a string with a regular expression using POSIX Extended Regular Expressions (ERE), including sub-expression (capture group) matching using parentheses "()".
regexMatchPerl(rstring, rstring): Match a string with a regular expression using a Perl regular expression, including sub-expression (capture group) matching using parentheses "()".
regexMatchPerl(ustring, ustring): Match a string with a regular expression using a Perl regular expression, including sub-expression (capture group) matching using parentheses "()".
regexReplace(rstring, rstring, rstring, boolean): Match and replace a string with a regular expression using POSIX Extended Regular Expressions (ERE), including sub-expression (capture group) matching using parentheses "()".
regexReplace(ustring, ustring, ustring, boolean): Match and replace a string with a regular expression using POSIX Extended Regular Expressions (ERE), including sub-expression (capture group) matching using parentheses "()".
regexReplacePerl(rstring, rstring, rstring, boolean): Match and replace a string with a regular expression using a Perl regular expression, including sub-expression (capture group) matching using parentheses "()".
regexReplacePerl(ustring, ustring, ustring, boolean): Match and replace a string with a regular expression using a Perl regular expression, including sub-expression (capture group) matching using parentheses "()".
remove(T, int32): Remove values from a list.
remove(T, int32, int32): Remove values from a list using a range.
remove(T, list<int32>): Remove values from a list using an index list.
remove(map<K, V>, K): Remove an element from a map.
remove(map<K, V>[N], K): Remove an element from a map.
remove(rstring, int32): Remove a file or directory.
remove(set<K>, K): Return a set with a key removed.
remove(set<K>[N], K): Return a set with a key removed.
remove(ustring, int32): Remove a file or directory.
removeM(T, int32): Remove values from a list (mutating version).
removeM(T, int32, int32): Remove values from a list using a range (mutating version).
removeM(map<K, V>, K): Remove an element from a map (mutating version).
removeM(map<K, V>[N], K): Remove an element from a map (mutating version).
removeM(set<K>, K): Remove K from a set (mutating version).
removeM(set<K>[N], K): Remove K from a set (mutating version).
resetConsistentRegion(): This function requests the ConsistentRegionControllerMXBean to restore the consistent region to the last established consistent state.
reverse(T): Reverse list of values.
reverseM(T): Reverse list of values (mutating version).
rewind(uint64): Set the current file position to file start.
round(T): Round a floating point value to the nearest integer.
rtrim(T, T): Remove trailing characters from a string.
second(timestamp): Extract the second from the time, using the current timezone.
selectFromList(list<boolean>, T, T): Select element-wise from two lists.
setCustomMetricValue(rstring, int64): Set the specified custom metric value for the current operator.
setCustomMetricValue(ustring, int64): Set the specified custom metric value for the current operator.
setDifference(T, T): Compute set difference.
setInputPortImportFilterExpression(rstring, uint32): Set the filter expression for an imported input port.
setInputPortImportSubscription(rstring, uint32): Set the import subscription for an imported input port.
setIntersection(T, T): Compute set intersection.
setOutputPortExportProperties(T, uint32): Set the export properties for an exported output port.
setOutputPortExportProperties(list<tuple<rstring name, rstring value, rstring typ>>, uint32): Set the export properties for an exported output port.
setUnion(T, T): Compute set union.
shutdownPE(): Shutdown the current processing element (PE).
sin(T): Compute the sine.
size(T): Get the size of a list.
size(blob): Get the size of a list.
slice(T, int32, int32): Slice list - extract items from the list.
slice(T, int32, int32, int32): Slice list - extract items from the list.
slice(T, int32, int32, int32, int32): Slice list - extract items from the list.
sort(list<T>): Sort values.
sort(list<T>[N]): Sort values.
sortIndices(list<T>): Sort values and return indexes.
sortIndices(list<T>[N]): Sort values and return indexes.
sortM(list<T>): Sort values (mutating version).
sortM(list<T>[N]): Sort values (mutating version).
sqrt(T): Compute the square root.
srand(int32): Seed the random number generator.
stddev(list<T>): Compute standard deviation of a list.
stddev(list<T>, boolean): Compute standard deviation of a list.
stddev(list<T>[N]): Compute standard deviation of a list.
stddev(list<T>[N], boolean): Compute standard deviation of a list.
strerror(int32): Convert an errno value to a string for intelligent printing.
strftime(tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>, rstring): Convert broken-down time (Sys.tm) to a date and time string. Note: This function is POSIX compliant, and uses the current locale.
strptime(rstring, rstring, tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>, uint32): Convert a date and time string to broken-down time (Sys.tm). Note: This function is POSIX compliant, and uses the current locale.
strtod(rstring): Convert a string to a floating point number.
strtod(rstring, int32): Convert a string to a floating point number.
strtoll(rstring, int32): Convert a string in base 2 to 36 to an signed number.
strtoll(rstring, int32, int32): Convert a string in base 2 to 36 to an signed number.
strtoull(rstring, int32): Convert a string in base 2 to 36 to an unsigned number.
strtoull(rstring, int32, int32): Convert a string in base 2 to 36 to an unsigned number.
substring(T, int32, int32): Get a substring from a string.
sum(list<T>): Compute the sum of a list.
sum(list<T>[N]): Compute the sum of a list.
swap(T, T): Swap any two SPL values
tan(T): Compute the tangent.
time(timestamp, rstring, tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>): Convert a timestamp to broken-down time (Sys.tm), using a specified timezone.
time(timestamp, tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>): Convert a timestamp to broken-down time (Sys.tm), using the current timezone.
timeStringToTimestamp(rstring, rstring, boolean): Converts date and time strings into a timestamp containing the time since the Epoch, using the current timezone.
timeStringToTimestamp(rstring, rstring, rstring, boolean): Converts date and time strings into a timestamp containing the time since the Epoch, using the specified timezone.
timeStringToTimestamp(ustring, ustring, boolean): Converts date and time strings into a timestamp containing the time since the Epoch, using the current timezone.
timeStringToTimestamp(ustring, ustring, ustring, boolean): Converts date and time strings into a timestamp containing the time since the Epoch, using the specified timezone.
timeStringtoTimestamp(rstring, rstring, boolean): DEPRECATED.
timeStringtoTimestamp(rstring, rstring, rstring, boolean): DEPRECATED.
timeStringtoTimestamp(ustring, ustring, boolean): DEPRECATED.
timeStringtoTimestamp(ustring, ustring, ustring, boolean): DEPRECATED.
toCharacterCode(T): Convert the first character of a string to its corresponding ASCII code.
toDecimal128(timestamp): Convert a timestamp to a decimal128 value.
toSet(list<T>): Convert a list to a set.
toSet(list<T>[N]): Convert a list to a set.
toTimestamp(enum{YYYYMMDDhhmmss, YYYY_MM_DD_hh_mm_ss, MM_DD_YYYY_hh_mm_ss, DD_MM_YYYY_hh_mm_ss, YYYY_MM_DD_hh_mm_ss_mmm, MM_DD_YYYY_hh_mm_ss_mmm, DD_MM_YYYY_hh_mm_ss_mmm}, T): Converts a date and time string into a timestamp containing the time since the Epoch, using the current time zone.
toTimestamp(enum{YYYYMMDDhhmmss, YYYY_MM_DD_hh_mm_ss, MM_DD_YYYY_hh_mm_ss, DD_MM_YYYY_hh_mm_ss, YYYY_MM_DD_hh_mm_ss_mmm, MM_DD_YYYY_hh_mm_ss_mmm, DD_MM_YYYY_hh_mm_ss_mmm}, T, T): Converts a date and time string into a timestamp containing the time since the Epoch, using the specified time zone.
toTimestamp(tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>): Convert a broken-down time (Sys.tm) into a timestamp containing the time since the Epoch.
toTimestamp(tuple<int32 sec, int32 min, int32 hour, int32 mday, int32 mon, int32 year, int32 wday, int32 yday, int32 isdst, int32 gmtoff, rstring zone>, boolean): Convert a broken-down time (Sys.tm) into a timestamp containing the time since the Epoch.
tokenize(rstring, rstring, boolean): Tokenize string.
tokenize(rstring, rstring, boolean, boolean, list<rstring>): Tokenize string.
tokenize(ustring, ustring, boolean): Tokenize string.
tokenize(ustring, ustring, boolean, boolean, list<ustring>): Tokenize string.
trim(T, T): Remove leading and trailing characters from a string.
upper(T): Convert string to uppercase.
xquery(X, rstring): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, rstring, int32): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, rstring, map<rstring, rstring>): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, rstring, map<rstring, rstring>, int32): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, ustring): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, ustring, int32): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, ustring, map<ustring, ustring>): Execute an XQuery programs against an XML value, and return a list of results.
xquery(X, ustring, map<ustring, ustring>, int32): Execute an XQuery programs against an XML value, and return a list of results.
year(timestamp): Extract the year from the time, using the current timezone.