Index (Streams Distributed Process Store (DPS) Java API)

A B C D F G H I K L P R S
All Classes and Interfaces|All Packages|Serialized Form

A

acquireLock() - Method in interface com.teracloud.streams.dl.Lock: Acquire a distributed lock before accessing a critical shared resource.
acquireLock(double, double) - Method in interface com.teracloud.streams.dl.Lock: Acquire a distributed lock with lease time and max wait time before accessing a critical shared resource

B

base64Decode(String) - Method in interface com.teracloud.streams.dps.StoreFactory: Decode the given base64 string.
base64Encode(String) - Method in interface com.teracloud.streams.dps.StoreFactory: Base64 encode the given string.

C

clear() - Method in interface com.teracloud.streams.dps.Store: Deletes all the key-value pairs in this store.
com.teracloud.streams.dl - package com.teracloud.streams.dl: This package provides distributed locking functions which can be used for safe, concurrent access to distributed stores from multiple threads and processes.
com.teracloud.streams.dps - package com.teracloud.streams.dps: This package contains functions for creating and managing Stores.
createOrGetLock(String) - Method in interface com.teracloud.streams.dl.LockFactory: This function can be used to create a new distributed lock with a given lock name or obtain an existing distributed lock in the event that a distributed lock with the given lock name already exists.
createOrGetStore(String, String, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Create the new store if it does not already exist or return the store if it exists.
createStore(String, String, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Creates a new store with a given store name.

D

deserialize(ByteBuffer) - Method in interface com.teracloud.streams.dps.Store: Deserializes a ByteBuffer containing one or more serialized key-value pairs into this store, thereby populating it with those pairs.
DistributedLocks - Class in com.teracloud.streams.dl: This is the main entry point into the locking API, used to create a LockFactory.
DistributedLocks() - Constructor for class com.teracloud.streams.dl.DistributedLocks
DistributedStores - Class in com.teracloud.streams.dps: This is the main entry point for using the Distributed Store API - this class is used to get a StoreFactory, which in turn, is used to create Stores.
DistributedStores() - Constructor for class com.teracloud.streams.dps.DistributedStores

F

findStore(String) - Method in interface com.teracloud.streams.dps.StoreFactory: Finds a store with a given store name

G

get(T1) - Method in interface com.teracloud.streams.dps.Store: Get the value associated with the given key.
getDetailsAboutThisMachine() - Method in interface com.teracloud.streams.dps.StoreFactory: Get the details of the machine where this operator is running.
getErrorCode() - Method in exception com.teracloud.streams.dl.LockException
getErrorCode() - Method in exception com.teracloud.streams.dl.LockFactoryException
getErrorCode() - Method in exception com.teracloud.streams.dps.StoreException
getErrorCode() - Method in exception com.teracloud.streams.dps.StoreFactoryException
getErrorMessage() - Method in exception com.teracloud.streams.dl.LockException
getErrorMessage() - Method in exception com.teracloud.streams.dl.LockFactoryException
getErrorMessage() - Method in exception com.teracloud.streams.dps.StoreException
getErrorMessage() - Method in exception com.teracloud.streams.dps.StoreFactoryException
getId() - Method in interface com.teracloud.streams.dl.Lock: Get the id for this lock
getId() - Method in interface com.teracloud.streams.dps.Store
getKey() - Method in class com.teracloud.streams.dps.KeyValuePair
getKeySplTypeName() - Method in interface com.teracloud.streams.dps.Store
getLockFactory() - Static method in class com.teracloud.streams.dl.DistributedLocks: Get a LockFactory instance
getNoSqlDbProductName() - Method in interface com.teracloud.streams.dps.StoreFactory
getPidForLock(String) - Method in interface com.teracloud.streams.dl.LockFactory: Get the Linux process id that currently owns this lock.
getSafe(T1) - Method in interface com.teracloud.streams.dps.Store: Similar to get but with higher overhead arising from internal safety checks.
getStoreFactory() - Static method in class com.teracloud.streams.dps.DistributedStores: Return a store factory.
getStoreName() - Method in interface com.teracloud.streams.dps.Store
getTTL(T1, String, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Get a K/V pair with TTL (Time To Live in seconds) into the global area of the back-end data store.
getTTL(T1, String, String, boolean, boolean) - Method in interface com.teracloud.streams.dps.StoreFactory
getValue() - Method in class com.teracloud.streams.dps.KeyValuePair
getValueSplTypeName() - Method in interface com.teracloud.streams.dps.Store

H

has(T1) - Method in interface com.teracloud.streams.dps.Store: Check if the store contains a value for the given key
hasTTL(T1, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Check if a TTL based K/V pair for a given key exists in the global area of the back-end data store.
hasTTL(T1, String, boolean) - Method in interface com.teracloud.streams.dps.StoreFactory

I

initialize() - Static method in class com.teracloud.streams.dps.DistributedStores: This method must be called before getStoreFactory() can be used.
initialize(String) - Static method in class com.teracloud.streams.dps.DistributedStores: This is an overloaded method that takes a fully qualified DPS configuration file name.
isConnected() - Method in interface com.teracloud.streams.dps.StoreFactory: Check if there is an active connection to the back-end data store.
iterator() - Method in interface com.teracloud.streams.dps.Store

K

KeyValuePair - Class in com.teracloud.streams.dps
KeyValuePair(Object, Object) - Constructor for class com.teracloud.streams.dps.KeyValuePair

L

Lock - Interface in com.teracloud.streams.dl: This is an interface defining the available distributed lock (dl) methods.
LockException - Exception in com.teracloud.streams.dl: Any errors during distribute lock (dl) operation will result in this exception getting thrown.
LockException(long) - Constructor for exception com.teracloud.streams.dl.LockException
LockException(long, String) - Constructor for exception com.teracloud.streams.dl.LockException
LockException(String) - Constructor for exception com.teracloud.streams.dl.LockException
LockFactory - Interface in com.teracloud.streams.dl
LockFactoryException - Exception in com.teracloud.streams.dl: Any errors during lock creation will result in this exception getting thrown.
LockFactoryException(long) - Constructor for exception com.teracloud.streams.dl.LockFactoryException
LockFactoryException(long, String) - Constructor for exception com.teracloud.streams.dl.LockFactoryException
LockFactoryException(String) - Constructor for exception com.teracloud.streams.dl.LockFactoryException

P

put(T1, T2) - Method in interface com.teracloud.streams.dps.Store: Insert a key/value pair into the store.
putSafe(T1, T2) - Method in interface com.teracloud.streams.dps.Store: Same function as put, but slower due to overhead arising from internal safety checks.
putTTL(T1, T2, int, String, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Put a TTL based K/V pair stored in the global area of the back-end data store.
putTTL(T1, T2, int, String, String, boolean, boolean) - Method in interface com.teracloud.streams.dps.StoreFactory
putTTL(T1, T2, int, String, String, int[], boolean, boolean) - Method in interface com.teracloud.streams.dps.StoreFactory

R

reconnect() - Method in interface com.teracloud.streams.dps.StoreFactory: Reconnect with the back-end data store.
releaseLock() - Method in interface com.teracloud.streams.dl.Lock: Release ownership of the lock.
remove(T1) - Method in interface com.teracloud.streams.dps.Store: Removes the given key from the store.
removeLock(Lock) - Method in interface com.teracloud.streams.dl.LockFactory: This function can be used to remove a given distributed lock id.
removeStore(Store) - Method in interface com.teracloud.streams.dps.StoreFactory: Remove the given Store.
removeTTL(T1, String) - Method in interface com.teracloud.streams.dps.StoreFactory: Remove a TTL based K/V pair stored in the global area of the back-end data store.
removeTTL(T1, String, boolean) - Method in interface com.teracloud.streams.dps.StoreFactory
runDataStoreCommand(int, String, String, String, String, String, long[]) - Method in interface com.teracloud.streams.dps.StoreFactory: 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.
runDataStoreCommand(String) - Method in interface com.teracloud.streams.dps.StoreFactory: Run native commands on the chosen back-end data store.
runDataStoreCommand(List<RString>) - Method in interface com.teracloud.streams.dps.StoreFactory

S

serialize() - Method in interface com.teracloud.streams.dps.Store: Serialize the contents of this store into a ByteBuffer.
size() - Method in interface com.teracloud.streams.dps.Store
Store - Interface in com.teracloud.streams.dps: Represents a user created distributed store.
StoreException - Exception in com.teracloud.streams.dps
StoreException(long) - Constructor for exception com.teracloud.streams.dps.StoreException
StoreException(long, String) - Constructor for exception com.teracloud.streams.dps.StoreException
StoreException(String) - Constructor for exception com.teracloud.streams.dps.StoreException
StoreFactory - Interface in com.teracloud.streams.dps: This is an interface for the store factory with the available methods declared here.
StoreFactoryException - Exception in com.teracloud.streams.dps
StoreFactoryException(long) - Constructor for exception com.teracloud.streams.dps.StoreFactoryException
StoreFactoryException(long, String) - Constructor for exception com.teracloud.streams.dps.StoreFactoryException
StoreFactoryException(String) - Constructor for exception com.teracloud.streams.dps.StoreFactoryException
StoreIterator - Interface in com.teracloud.streams.dps: This class represents an iterator over the contents of a Store.

A B C D F G H I K L P R S
All Classes and Interfaces|All Packages|Serialized Form