com.rpl.rama

Interface PState

public interface PState

Interface for thread-safe PState clients. These are also known as "foreign PStates". A PState client is retrieved using a RamaClusterManager on a real cluster or InProcessCluster in a test environment.

Static methods on this class implement schemas for use when declaring a PState in a module with pstate.

See Also:

PStates documentation

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PState.Declaration Builder-style interface for specifying options when declaring a PState in a module
static interface	PState.Schema Builder-style interface for declaring options on PState schemas

Method Summary

Modifier and Type	Method and Description
static PState.Schema	fixedKeysSchema(java.lang.Object... keyAndSchemas) Declare schema for map with different schema for each key.
static PState.Schema	listSchema(java.lang.Class valClass) Declare a list schema
static PState.Schema	listSchema(PState.Schema valueSchema) Declare a list schema
static PState.Schema	mapSchema(java.lang.Class keyClass, java.lang.Class valueSchema) Declare a map schema
static PState.Schema	mapSchema(java.lang.Class keyClass, PState.Schema valueSchema) Declare a map schema
<T> ProxyState<T>	proxy(java.lang.Object partitioningKey, Path path) Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> ProxyState<T>	proxy(java.lang.Object partitioningKey, Path path, ProxyState.Callback<T> callback) Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> ProxyState<T>	proxy(Path path) Reactive query of PState with Path that must navigate to exactly one value.
<T> ProxyState<T>	proxy(Path path, ProxyState.Callback<T> callback) Reactive query of PState with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<ProxyState<T>>	proxyAsync(java.lang.Object partitioningKey, Path path) Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<ProxyState<T>>	proxyAsync(java.lang.Object partitioningKey, Path path, ProxyState.Callback<T> callback) Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<ProxyState<T>>	proxyAsync(Path path) Reactive query of PState with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<ProxyState<T>>	proxyAsync(Path path, ProxyState.Callback<T> callback) Reactive query of PState with Path that must navigate to exactly one value.
<T> java.util.List<T>	select(java.lang.Object partitioningKey, Path path) Queries PState with Path using explicit partitioning key.
<T> java.util.List<T>	select(Path path) Queries PState with Path.
<T> java.util.concurrent.CompletableFuture<java.util.List<T>>	selectAsync(java.lang.Object partitioningKey, Path path) Queries PState with Path using explicit partitioning key.
<T> java.util.concurrent.CompletableFuture<java.util.List<T>>	selectAsync(Path path) Queries PState with Path.
<T> T	selectOne(java.lang.Object partitioningKey, Path path) Queries PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> T	selectOne(Path path) Queries PState with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<T>	selectOneAsync(java.lang.Object partitioningKey, Path path) Queries PState using explicit partitioning key with Path that must navigate to exactly one value.
<T> java.util.concurrent.CompletableFuture<T>	selectOneAsync(Path path) Queries PState with Path that must navigate to exactly one value.
static PState.Schema	setSchema(java.lang.Class valClass) Declare a set schema

Method Detail

mapSchema

static PState.Schema mapSchema(java.lang.Class keyClass,
                               java.lang.Class valueSchema)

Declare a map schema

Parameters:

keyClass - Type of keys in map

valueSchema - Type of values in map

mapSchema

static PState.Schema mapSchema(java.lang.Class keyClass,
                               PState.Schema valueSchema)

Declare a map schema

Parameters:

keyClass - Type of keys in map

valueSchema - Schema for nested data structures for map values

setSchema

static PState.Schema setSchema(java.lang.Class valClass)

Declare a set schema

Parameters:

valClass - Type of values in set

listSchema

static PState.Schema listSchema(java.lang.Class valClass)

Declare a list schema

Parameters:

valClass - Type of values in list

listSchema

static PState.Schema listSchema(PState.Schema valueSchema)

Declare a list schema

Parameters:

valueSchema - Schema for values in list

fixedKeysSchema

static PState.Schema fixedKeysSchema(java.lang.Object... keyAndSchemas)

Declare schema for map with different schema for each key. Specified keys are the only ones allowed when writing, but they're all optional. Example: PState.fixedKeysSchema("a", Long.class, "b", PState.setSchema(String.class)

Parameters:

keyAndSchemas - Alternating declarations of keys and the Class or PState.Schema schema for that key

select

<T> java.util.List<T> select(Path path)

Queries PState with Path. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Blocking operation.

Type Parameters:

T - Type of navigated values

Parameters:

path - Query path

Returns:

List of navigated values

See Also:

Paths documentation

select

<T> java.util.List<T> select(java.lang.Object partitioningKey,
                             Path path)

Queries PState with Path using explicit partitioning key. Blocking operation.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

List of navigated values

See Also:

Paths documentation

selectOne

<T> T selectOne(Path path)

Queries PState with Path that must navigate to exactly one value. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Blocking operation.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

Returns:

Navigated value

See Also:

Paths documentation

selectOne

<T> T selectOne(java.lang.Object partitioningKey,
                Path path)

Queries PState using explicit partitioning key with Path that must navigate to exactly one value. Blocking operation.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

Navigated value

See Also:

Paths documentation

selectAsync

<T> java.util.concurrent.CompletableFuture<java.util.List<T>> selectAsync(Path path)

Queries PState with Path. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Non-blocking operation.

Type Parameters:

T - Type of navigated values

Parameters:

path - Query path

Returns:

Future for list of navigated values

See Also:

Paths documentation

selectAsync

<T> java.util.concurrent.CompletableFuture<java.util.List<T>> selectAsync(java.lang.Object partitioningKey,
                                                                          Path path)

Queries PState with Path using explicit partitioning key. Non-blocking operation.

Type Parameters:

T - Type of navigated values

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

Future for list of navigated values

See Also:

Paths documentation

selectOneAsync

<T> java.util.concurrent.CompletableFuture<T> selectOneAsync(Path path)

Queries PState with Path that must navigate to exactly one value. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Non-blocking operation.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

Returns:

Future for navigated value

See Also:

Paths documentation

selectOneAsync

<T> java.util.concurrent.CompletableFuture<T> selectOneAsync(java.lang.Object partitioningKey,
                                                             Path path)

Queries PState using explicit partitioning key with Path that must navigate to exactly one value. Non-blocking operation.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

Future for navigated value

See Also:

Paths documentation

proxy

<T> ProxyState<T> proxy(Path path)

Reactive query of PState with Path that must navigate to exactly one value. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Blocks until initial query finishes, then receives fine-grained updates to returned ProxyState in background.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

Returns:

Reactive value

See Also:

Reactivity documentation, Paths documentation

proxy

<T> ProxyState<T> proxy(java.lang.Object partitioningKey,
                        Path path)

Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value. Blocks until initial query finishes, then receives fine-grained updates to returned ProxyState in background.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

Reactive value

See Also:

Reactivity documentation, Paths documentation

proxy

<T> ProxyState<T> proxy(Path path,
                        ProxyState.Callback<T> callback)

Reactive query of PState with Path that must navigate to exactly one value. Receives fine-grained information about changes to value via provided callback. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Blocks until initial query finishes, then receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

callback - Function that receives fine-grained information about changes. Callbacks run on a separate dedicated thread.

Returns:

Reactive value

See Also:

Reactivity documentation, Paths documentation

proxy

<T> ProxyState<T> proxy(java.lang.Object partitioningKey,
                        Path path,
                        ProxyState.Callback<T> callback)

Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value. Receives fine-grained information about changes to value via provided callback. Blocks until initial query finishes, then receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

callback - Function that receives fine-grained information about changes. Callbacks run on a separate dedicated thread.

Returns:

Reactive value

See Also:

Reactivity documentation, Paths documentation

proxyAsync

<T> java.util.concurrent.CompletableFuture<ProxyState<T>> proxyAsync(Path path)

Reactive query of PState with Path that must navigate to exactly one value. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Non-blocking. Once ProxyState is delivered to returned future, the ProxyState receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

Returns:

Future for reactive value

See Also:

Reactivity documentation, Paths documentation

proxyAsync

<T> java.util.concurrent.CompletableFuture<ProxyState<T>> proxyAsync(java.lang.Object partitioningKey,
                                                                     Path path)

Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value. Non-blocking. Once ProxyState is delivered to returned future, the ProxyState receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

Returns:

Future for reactive value

See Also:

Reactivity documentation, Paths documentation

proxyAsync

<T> java.util.concurrent.CompletableFuture<ProxyState<T>> proxyAsync(Path path,
                                                                     ProxyState.Callback<T> callback)

Reactive query of PState with Path that must navigate to exactly one value. Receives fine-grained information about changes to value via provided callback. If PState has more than one partition, Path must start with key navigator and query will extract that key as partitioning key. Non-blocking. Once ProxyState is delivered to returned future, the ProxyState receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

path - Query path

callback - Function that receives fine-grained information about changes. Callbacks run on a separate dedicated thread.

Returns:

Future for reactive value

See Also:

Reactivity documentation, Paths documentation

proxyAsync

<T> java.util.concurrent.CompletableFuture<ProxyState<T>> proxyAsync(java.lang.Object partitioningKey,
                                                                     Path path,
                                                                     ProxyState.Callback<T> callback)

Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value. Receives fine-grained information about changes to value via provided callback. Non-blocking. Once ProxyState is delivered to returned future, the ProxyState receives fine-grained updates in background.

Type Parameters:

T - Type of navigated value

Parameters:

partitioningKey - Explicit partitioning key

path - Query path

callback - Function that receives fine-grained information about changes. Callbacks run on a separate dedicated thread.

Returns:

Future for reactive value

See Also:

Reactivity documentation, Paths documentation