Namespace com.ibm.streamsx.store.distributed

SPL standard and specialized toolkits > com.ibm.streamsx.dps 2.0.9 > com.ibm.streamsx.store.distributed

Functions

• 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.