IBM InfoSphere Streams Version 4.1.0

Functions: SPL standard and specialized toolkits

SPL standard and specialized toolkits > 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.
area(T): Computes the area of the provided geometry, is always 0.0 for 0-d and 1-d objects. Area is computed on the spherical earth model for 2-d geometries. In case of an exception, -1 will be returned and the exception logged.
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.
azimuth(Metric.metricType, PointPropertyType.point128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::azimuth instead. This function computes the distance between the two points using the algorithm provided in the metric type
azimuth(Metric.metricType, PointPropertyType.point32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::azimuth instead. This function computes the distance between the two points using the algorithm provided in the metric type
azimuth(Metric.metricType, PointPropertyType.point64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::azimuth instead. This function computes the distance between the two points using the algorithm provided in the metric type
azimuth(T, T): Computes the azimuth between two points expressed in WGS84 coordinates, the input points are in WKT format.
base32GeohashToBinary(T): Converts a geohash in base32 format to a binary string.
binaryGeohashToBase32(T): Converts a geohash in binary format to a base32 string.
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.
calcCallCharm(float64, float64, float64, float64, float64, float64)
calcCallDelta(float64, float64, float64, float64, float64, float64)
calcCallDualDelta(float64, float64, float64, float64, float64, float64)
calcCallRho(float64, float64, float64, float64, float64, float64)
calcCallTheta(float64, float64, float64, float64, float64, float64)
calcCallValue1(float64, float64, float64, float64, float64, float64)
calcCallValue2(float64, float64, float64, float64, float64, float64)
calcColor(float64, float64, float64, float64, float64, float64)
calcDualGamma(float64, float64, float64, float64, float64, float64)
calcDvegaDtime(float64, float64, float64, float64, float64, float64)
calcGamma(float64, float64, float64, float64, float64, float64)
calcGreeks(float64, float64, float64, float64, float64, float64)
calcPutCharm(float64, float64, float64, float64, float64, float64)
calcPutDelta(float64, float64, float64, float64, float64, float64)
calcPutDualDelta(float64, float64, float64, float64, float64, float64)
calcPutRho(float64, float64, float64, float64, float64, float64)
calcPutTheta(float64, float64, float64, float64, float64, float64)
calcPutValue1(float64, float64, float64, float64, float64, float64)
calcPutValue2(float64, float64, float64, float64, float64, float64)
calcSpeed(float64, float64, float64, float64, float64, float64)
calcVanna(float64, float64, float64, float64, float64, float64)
calcVega(float64, float64, float64, float64, float64, float64)
calcVomma(float64, float64, float64, float64, float64, float64)
calcZomma(float64, float64, float64, float64, float64, float64)
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).
containingGeohash(T, float64): Provides a utility method to do spatial aggregation on point geometry data, where the input geometry is expected to be a point (in WGS84 coordinates) in WKT format and a boxSize in meters.
contains(T, T): Determines if the first geometry contains the second geometry, geometries are specified in WKT format.
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.
convolve(list<float64>, list<float64>): The convolve function generates the convolution of two time series input signals.
correlationCoefficient(list<float32>, list<float32>): An SPL function is provided in the Financial Services Toolkit for computing the Coefficient of Correlation between two series of variables.
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.
createDirectory(rstring, int32): Attempts to create the directory that the path variable identifies, as if by ISO/IEC 9945 mkdir() with a second argument of S_IRWXU|S_IRWXG|S_IRWXO.
createLineSegment128( com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point128, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::lineSegment instead. This function creates a lineSegment128
createLineSegment32( com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point32, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::lineSegment instead. This function creates a lineSegment32
createLineSegment64( com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point64, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::lineSegment instead. This function creates a lineSegment64
createLineString128( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment128>): Deprecated as of Streams version 4.0. This function creates a list of lineSegment128
createLineString32( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment32>): Deprecated as of Streams version 4.0. This function creates a list of lineSegment32
createLineString64( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment64>): Deprecated as of Streams version 4.0. This function creates a list of lineSegment64
createLinearSimplePolygon128( list<com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point128>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::polygon or com.ibm.streams.geospatial.ext::orientedPolygon instead. This function creates a linear simple polygon128
createLinearSimplePolygon32( list<com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point32>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::polygon or com.ibm.streams.geospatial.orientedPolygon instead. This function creates a linear simple polygon32
createLinearSimplePolygon64( list<com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point64>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::polygon or com.ibm.streams.geospatial.ext::orientedPolygon instead. This function creates a linear simple polygon64
createPoint128(float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::point instead. This function creates a point128
createPoint32(float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::point instead. This function creates a point32
createPoint64(float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::point instead. This function creates a point64
createTimestamp(int64, uint32): Create a timestamp.
createTimestamp(int64, uint32, int32): Create a timestamp.
crosscorrelate(list<float64>, list<float64>): The crosscorrelate function generates the crosscorrelation of two time series input signals.
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.
destinationPoint(T, float64, float64): Computes the destination point given a point, the heading/azimuth, and the distance in meters, the input point is in WKT format with WGS84 coordinates, the output point is in WKT WGS84 format.
destinationPoint( com.ibm.streams.geospatial.twodimension.geometry::Metric.metricType, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point128, float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::destinationPoint instead. This function computes the distance between the two points using the algorithm provided in the metric type
destinationPoint( com.ibm.streams.geospatial.twodimension.geometry::Metric.metricType, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point32, float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::destinationPoint instead. This function computes the distance between the two points using the algorithm provided in the metric type
destinationPoint( com.ibm.streams.geospatial.twodimension.geometry::Metric.metricType, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point64, float64, float64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::destinationPoint instead. This function computes the distance between the two points using the algorithm provided in the metric type
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).
distance(Metric.metricType, PointPropertyType.point128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the algorithm provided in the metric type
distance(Metric.metricType, PointPropertyType.point32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the algorithm provided in the metric type
distance(Metric.metricType, PointPropertyType.point64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the algorithm provided in the metric type
distance(T, T): Computes the shortest distance in meters between given geometries in WKT format on the spherical earth model.
distanceEllipsoidal(PointPropertyType.point128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
distanceEllipsoidal(PointPropertyType.point32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
distanceEllipsoidal(PointPropertyType.point64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
distanceGreatCircle(PointPropertyType.point128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the GreatCircle Formula
distanceGreatCircle(PointPropertyType.point32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the GreatCircle Formula
distanceGreatCircle(PointPropertyType.point64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the GreatCircle Formula
distanceHaversine(PointPropertyType.point128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
distanceHaversine(PointPropertyType.point32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
distanceHaversine(PointPropertyType.point64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::distance instead. This function computes the distance between the two points using the Haversine Formula
dlAcquireLock(uint64, float64, float64, uint64): Acquire lock, with an explicit lease time in seconds and a maximum time to wait to acquire the lock.
dlAcquireLock(uint64, uint64): This function can be called to acquire a distributed lock.
dlCreateOrGetLock(rstring, uint64): Create a new distributed lock with a given name or get it if it already exists.
dlGetLastDistributedLockErrorCode(): Get the error code of the last DL error
dlGetLastDistributedLockErrorString(): Get the description of the error that occurred on the most recently executed operation in the DL API, if any.
dlGetPidForLock(rstring, uint64): Get the process id that is currently holding a given lock.
dlReleaseLock(uint64, uint64): Release the given distributed lock id.
dlRemoveLock(uint64, uint64): Remove the distributed lock with the given id.
domainID(): Return the domain ID that the PE is running in.
dpsBase64Decode(rstring, rstring): Base64 decode a given string.
dpsBase64Encode(rstring, rstring): Base64 encode a given string.
dpsBeginIteration(uint64, uint64): This function gets a store iterator that can be used to iterate over all the key-value pairs in a given store id.
dpsClear(uint64, uint64): Clear the given store.
dpsCreateOrGetStore(rstring, T1, T2, uint64): Create a new process store with a given name or simply return its handle it already exists.
dpsCreateStore(rstring, T1, T2, uint64): Create a new process store with a given name.
dpsDeserialize(uint64, blob, T1, T2, uint64): This function deserializes a given blob containing one or more serialized key-value pairs.
dpsEndIteration(uint64, uint64, uint64): This function must be called once all iteration is complete.
dpsFindStore(rstring, uint64): Find a process store given its name.
dpsGet(uint64, T1, T2, uint64): Given a key, retrieves its value from the given store.
dpsGetDetailsAboutThisMachine(rstring, rstring, rstring): Get details of the client machine where this operator is running.
dpsGetLastErrorCodeTTL(): Get the error code of the last error ocuured involving data that was stored with a Time To Live (TTL).
dpsGetLastErrorStringTTL(): Get the description of the last error that occurred involving data stored with a Time To Live (TTL).
dpsGetLastStoreErrorCode(): Get the error code of the last store error.
dpsGetLastStoreErrorString(): Get the description of the last store error.
dpsGetNext(uint64, uint64, T1, T2, uint64): This function is used to get the next key and value of given types in the given store when iterating over all the items in the store.
dpsGetNoSqlDbProductName(): Get the name of the NoSQL database product being used.
dpsGetSafe(uint64, T1, T2, uint64): Given a key, retrieve its value from the given store.
dpsGetSplTypeNameForKey(uint64): Get the SPL type name for the key of a given store id.
dpsGetSplTypeNameForValue(uint64): Get the SPL type name for the value of a given store id.
dpsGetStoreName(uint64): Get the store name for a given store id.
dpsGetTTL(T1, T2, uint64): Get an item that was stored with a TTL (Time To Live in seconds) value.
dpsHas(uint64, T1, uint64): Check if an item exists in the given store.
dpsHasTTL(T1, uint64): Check if an item exists that was stored with a TTL (Time To Live in seconds) value.
dpsPut(uint64, T1, T2, uint64): Put a new key-value pair into a store.
dpsPutSafe(uint64, T1, T2, uint64): Put an item into the given store.
dpsPutTTL(T1, T2, uint32, uint64): Put an key-value pair with in a TTL (Time To Live in seconds) value into the global area of the back-end data store.
dpsRemove(uint64, T1, uint64): Remove an item from the given store.
dpsRemoveStore(uint64, uint64): Remove a process store given its handle.
dpsRemoveTTL(T1, uint64): Remove an item that was stored with a TTL (Time To Live in seconds) value.
dpsRunDataStoreCommand(rstring, uint64): This function can be used to execute simple arbitrary back-end data store (fire and forget) native commands.
dpsRunDataStoreCommand(uint32, rstring, rstring, rstring, rstring, rstring, rstring, uint64): This is an advanced function that can be used to execute arbitrary back-end data store two way native commands for database technologies that work with cURL.
dpsSerialize(uint64, blob, T1, T2, uint64): This function serializes all the key-value pairs in a given store id into a blob.
dpsSize(uint64, uint64): Get the total number of key-value pairs in the given store.
dtw(list<float64>, list<float64>): This function uses dynamic time warping (DTW) to measure the similarity between two time series.
dtw_itakura(list<float64>, list<float64>, int32, float64): This function computes the Itakura Parallelogram DTW.
dtw_sakoe_chiba(list<float64>, list<float64>, int32): This function computes the Sakoe-Chiba Band based DTW.
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.
feetAndInchesToMeters(int32, int32): Deprecated since Streams version 4.0.
feetAndInchesToMeters(int64, int64): Deprecated since Streams version 4.0.
feetToMeters(float32): Deprecated since Streams version 4.0.
feetToMeters(float64): Deprecated since Streams version 4.0.
feetToMeters(int32): Deprecated since Streams version 4.0.
feetToMeters(int64): Deprecated since Streams version 4.0.
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.
generate_pulsetrain_wave(float64, uint32, float64, uint32): Generates a pulse train representation of a time series, with a specified frequency, duration, sampling rate, and hump size.
generate_sawtooth_wave(float64, uint32, uint32): Generates a sawtooth wave representation of a time series, with a specified frequency, duration, and sampling rate.
generate_sine_wave(float64, uint32, uint32): Generates a sine wave representation of a time series, with a specified frequency, duration, and sampling rate.
generate_square_wave(float64, uint32, uint32): Generates a square wave representation of time series with a specific frequency, duration, and sampling rate.
generate_triangular_wave(float64, uint32, uint32): Generates a triangular wave representation of a time series, with a specified frequency, duration, and sampling rate.
geohashDecode(T): Decodes a given geohash to its corresponding geometry in WKT format.
geohashDistanceEncode(T, float64): Encodes the input geometry as a bit representation geohash.
geohashEncode(T): Encodes the provided geometry as a geohash in bit representation.
geohashStringDecode(T): Decodes a given base 32 encoded geohash to its corresponding point geometry in WKT format.
geohashStringEncode(T): Encodes the provided point as a base 32 encoded string.
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.
getLatitude(PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLatitude instead. This function computes the latitude from a point
getLatitude(PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLatitude instead. This function computes the latitude from a point
getLatitude(PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLatitude instead. his function computes the latitude from a point
getLatitude(T): Extract latitude from WKT point geometry
getLongitude(PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLongitude instead. This function computes the Longitude from a point
getLongitude(PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLongitude instead. This function computes the Longitude from a point
getLongitude(PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.ext::getLongitude instead. This function computes the Longitude from a point
getLongitude(T): Extract longitude from WKT point geometry
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.
inchesToMeters(float32): Deprecated since Streams version 4.0.
inchesToMeters(float64): Deprecated since Streams version 4.0.
inchesToMeters(int32): Deprecated since Streams version 4.0.
inchesToMeters(int64): Deprecated since Streams version 4.0.
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.
intersects(T, T): Computes if the two geometries intersect, resulting in either true/false as the output.
isConsistentInputPort(uint32): Check if the input port is consistent.
isContained(CurvePropertyType.lineSegment128, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a lineSegment128 contains a point128
isContained(CurvePropertyType.lineSegment32, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a lineSegment32 contains a point32
isContained(CurvePropertyType.lineSegment64, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a lineSegment64 contains a point64
isContained(list<PointPropertyType.point128>, PointPropertyType.point128): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon128 contains a linearsimplepolygon128
isContained(list<PointPropertyType.point128>, list<PointPropertyType.point128>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon128 contains a linearsimplepolygon128
isContained(list<PointPropertyType.point32>, PointPropertyType.point32): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon32 contains a linearsimplepolygon32
isContained(list<PointPropertyType.point32>, list<PointPropertyType.point32>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon32 contains a linearsimplepolygon32
isContained(list<PointPropertyType.point64>, PointPropertyType.point64): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon64 contains a linearsimplepolygon64
isContained(list<PointPropertyType.point64>, list<PointPropertyType.point64>): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::contains instead. This function checks if a linearsimplepolygon64 contains a linearsimplepolygon64
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.
isValid(T): Validates the given input geometry, the input is in WKT format and the output is a true/false
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.
kilometersToMeters(float32): Deprecated since Streams version 4.0.
kilometersToMeters(float64): Deprecated since Streams version 4.0.
kilometersToMeters(int32): Deprecated since Streams version 4.0.
kilometersToMeters(int64): Deprecated since Streams version 4.0.
kthelem(list<T>, uint32): Compute the kth element in ascending order.
kthelem(list<T>[N], uint32): Compute the kth element in ascending order.
laggedConvolve(list<float64>, list<float64>, enum{STANDARD, FFT})
laggedCrosscorrelate(list<float64>, list<float64>, int32, enum{STANDARD, FFT})
lcss(list<float64>, list<float64>, int32, float64): This function computer the longest common subsequence (LCSS) between two time series.
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.
lineSegment(float64, float64, float64, float64): Constructs a line segment from four doubles, the order is specified as 'startlongitude, startlatitude, endlongitude, endlatitude' and the output is a WKT formatted geometry
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.
lpNorm(list<float64>, list<float64>, float64): This function computes the Lp distance between two time series.
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.
mapPointToLineString( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment128>, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point128, R): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::nearestPoint instead. This functions provides with the ability to (a) find coordinates of a point Q on a given line string route (e.g., route traveled by the bus) that is closest to a given point P (e.g., a position on the diverted route taken by the bus); (b) compute distance between point P and Q (e.g., to determine how far the bus has taken diversion from the original route) which is returned in variable crossTrackDistance, and (c) compute distance along the line string from start (first point) of line string (route) and point Q which is returned in the variable alongTrackDistance.
mapPointToLineString( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment32>, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point32, R): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::nearestPoint instead. This functions provides the ability to (a) find coordinates of a point Q on a given line string route (e.g., route traveled by the bus) that is closest to a given point P (e.g., a position on the diverted route taken by the bus); (b) compute distance between point P and Q (e.g., to determine how far the bus has taken diversion from the original route) which is returned in variable crossTrackDistance, and (c) compute distance along the line string from start (first point) of line string (route) and point Q which is returned in the variable alongTrackDistance.
mapPointToLineString( list<com.ibm.streams.geospatial.twodimension.geometry::CurvePropertyType.lineSegment64>, com.ibm.streams.geospatial.twodimension.geometry::PointPropertyType.point64, R): Deprecated as of Streams version 4.0. Use com.ibm.streams.geospatial.st::nearestPoint instead. This functions provides the ability to (a) find coordinates of a point Q on a given line string route (e.g., route traveled by the bus) that is closest to a given point P (e.g., a position on the diverted route taken by the bus); (b) compute distance between point P and Q (e.g., to determine how far the bus has taken diversion from the original route) which is returned in variable crossTrackDistance, and (c) compute distance along the line string from start (first point) of line string (route) and point Q which is returned in the variable alongTrackDistance.
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.
milesToMeters(float32): Deprecated since Streams version 4.0.
milesToMeters(float64): Deprecated since Streams version 4.0.
milesToMeters(int32): Deprecated since Streams version 4.0.
milesToMeters(int64): Deprecated since Streams version 4.0.
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).
nearestPoint(T, T): Finds the nearest point on a linestring from a given point, where both geometries are specified in WKT format and WGS84 coordinates.
newControlSignal(MQTTSourceUpdate.TopicsUpdateAction, list<rstring>, uint32): Convenience method for creating a control signal that modifies subscription setting for MQTTSource operator
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.
orientedPolygon(T): Constructs a polygon that has its orientation specified, the polygon is a simple polygon and specified as a string with comma separated longitude, latitude values (in WGS84 decimal degrees).
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.
point(float64, float64): Constructs a point geometry from a longitude and a latitude, both specified in decimal degrees in WGS84 Datum.
polygon(T): Constructs a polygon from a String representation, where the polygon is a simple polygon (without any holes) and is specified as follows: 'longitude_1, latitude_1, longitude_2, latitude_2, ... , longitude_n, latitude_n', where n is the number of points. This constructor will re-orient the polygon so that it always constructs the 'smaller' polygon. The output format is a WKT geometry
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).
rename(rstring, rstring, int32): Renames a file or directory, as if by ISO/IEC 9945 rename(). If the oldName and newName paths specify different locations, the file or directory is moved to the new location if that is supported by the system.
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.
rms(list<T>): The rms function generates the root mean square value from a list of numerical values.
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.
sha2hash160(blob): Computes a 160-bit SHA-2 hash value from a given input value.
sha2hash160(rstring): Computes a 160-bit SHA-2 hash value from a given input value.
sha2hash160raw(blob): Computes a 160-bit SHA-2 hash value from a given input value.
sha2hash160raw(rstring): Computes a 160-bit SHA-2 hash value from a given input value.
sha2hash224(blob): Computes a 224-bit SHA-2 hash value from a given input value.
sha2hash224(rstring): Computes a 224-bit SHA-2 hash value from a given input value.
sha2hash224raw(blob): Computes a 224-bit SHA-2 hash value from a given input value.
sha2hash224raw(rstring): Computes a 224-bit SHA-2 hash value from a given input value.
sha2hash256(blob): Computes a 256-bit SHA-2 hash value from a given input value.
sha2hash256(rstring): Computes a 256-bit SHA-2 hash value from a given input value.
sha2hash256raw(blob): Computes a 256-bit SHA-2 hash value from a given input value.
sha2hash256raw(rstring): Computes a 256-bit SHA-2 hash value from a given input value.
sha2hash384(blob): Computes a 384-bit SHA-2 hash value from a given input value.
sha2hash384(rstring): Computes a 384-bit SHA-2 hash value from a given input value.
sha2hash384raw(blob): Computes a 384-bit SHA-2 hash value from a given input value.
sha2hash384raw(rstring): Computes a 384-bit SHA-2 hash value from a given input value.
sha2hash512(blob): Computes a 512-bit SHA-2 hash value from a given input value.
sha2hash512(rstring): Computes a 512-bit SHA-2 hash value from a given input value.
sha2hash512raw(blob): Computes a 512-bit SHA-2 hash value from a given input value.
sha2hash512raw(rstring): Computes a 512-bit SHA-2 hash value from a given input value.
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.
timeBoxesForPeriod(int64, int64, int32): Computes the discrete time period covered by the start and end.
timeBoxesForPeriod(uint64, uint64, uint32): Computes the discrete time period covered by the start and end.
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.
toGeoJSON(T): Convert the given WKT formatted geometry to a GeoJSON format.
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.
within(T, T): Returns true if the first geometry is within the second.
withinDistance(T, T, float64): Returns true if the first geometry and the second geometry are within the specified distance in meters.
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.
yardsToMeters(float32): Deprecated since Streams version 4.0.
yardsToMeters(float64): Deprecated since Streams version 4.0.
yardsToMeters(int32): Deprecated since Streams version 4.0.
yardsToMeters(int64): Deprecated since Streams version 4.0.
year(timestamp): Extract the year from the time, using the current timezone.