| Interface | Description |
|---|---|
| Agg |
Used for specifying aggregators in Rama topologies in conjunction with
agg or compoundAgg
methods |
| Block |
Core API for specifying dataflow code using the builder pattern.
|
| Block.Impl | |
| Block.MultiOutImpl | |
| Block.Out | |
| Block.OutImpl | |
| Case |
Used to create cases for
Block.cond(com.rpl.rama.Case...) |
| Case.Impl | |
| Case.MultiOutImpl | |
| Case.Out | |
| Case.OutImpl | |
| CompoundAgg |
Static methods for making aggregation templates for
Block.compoundAgg(com.rpl.rama.CompoundAgg). |
| Depot |
Interface for thread-safe depot clients.
|
| Depot.Declaration |
Builder-style object to specify options when declaring a depot in a module
|
| Depot.Partitioning<T> |
Interface for implementing custom depot partitioners
|
| LoopVars |
Declares vars for a
loopWithVars call using builder pattern
Example: LoopVars.var("*a", 1).var("*b", 2) |
| LoopVars.Impl | |
| Navigator<T> |
Interface for implementing custom navigators for use in a
Path |
| Navigator.Next | |
| PartitionedObject |
Interface that has methods that are common across partitioned objects (depots, PStates).
|
| Path |
A Path defines how to navigate to target values in a data structure as a series of steps.
|
| Path.Impl | |
| ProxyState<T> |
Reactive result of one of
PState proxy methods. |
| ProxyState.Callback<T> |
Interface for specifying callbacks for fine-grained diffs as data changes
|
| PState |
Interface for thread-safe PState clients.
|
| PState.Declaration |
Builder-style interface for specifying options when declaring a PState in a module
|
| PState.MigratedSchema |
Builder-style interface for declaring options on a migrated schema declared with
PState.migrated(java.lang.Object, java.lang.String, com.rpl.rama.ops.RamaFunction1<?, ?>) |
| PState.Schema |
Builder-style interface for declaring options on PState schemas
|
| QueryTopologyClient<T> |
Client for invoking a query topology.
|
| RamaClusterManager |
API for connecting to a Rama cluster and getting clients for depots, PStates, and query
topologies.
|
| RamaCustomSerialization<T> |
Interface for implementing serialization for custom types.
|
| RamaModule |
Defines a Rama module.
A module specifies an arbitrary collection of depots, ETLs, PStates, and query topologies to deploy onto a Rama cluster. |
| RamaModule.Setup |
Used to define depots, global objects, and module dependencies
in a module definition.
|
| RamaModule.Topologies |
Used to define ETL and query topologies in a module definition.
|
| RamaSerializable |
Objects implementing this interface will be serialized by Rama across disk or network boundaries using
Java serialization.
|
| RocksDBOptionsBuilder |
Rama uses RocksDB in the underlying implementation for PStates that have a map in the top-level schema.
|
| SelectOptions |
Interface for declaring options for select calls in topologies.
|
| SelectOptions.Impl | |
| SortedRangeFromOptions |
Interface for declaring options for
Path.sortedMapRangeFrom(java.lang.Object) or Path.sortedSetRangeFrom(java.lang.Object). |
| SortedRangeFromOptions.Impl | |
| SortedRangeOptions |
Interface for declaring options for
Path.sortedMapRange(java.lang.Object, java.lang.Object) or Path.sortedSetRange(java.lang.Object, java.lang.Object). |
| SortedRangeOptions.Impl | |
| SortedRangeToOptions |
Interface for declaring options for
Path.sortedMapRangeTo(java.lang.Object) or Path.sortedSetRangeTo(java.lang.Object). |
| SortedRangeToOptions.Impl | |
| SubindexOptions |
Interface for declaring options on a subindexed PState schema
|
| SubindexOptions.Impl | |
| SubSource |
Used to create cases for
Block.subSource(java.lang.Object, com.rpl.rama.SubSource...) |
| SubSource.Impl | |
| SubSource.MultiOutImpl | |
| SubSource.Out | |
| SubSource.OutImpl |
| Class | Description |
|---|---|
| Constant |
Wrapper type to force an object to be a constant in dataflow code.
|
| Expr |
Specifies an expression to be used in an argument position in dataflow code.
|
| Helpers |
Collection of static utility methods
|
| LoopVars.LoopVar | |
| LoopVars.LoopVarsCollector | |
| ModuleInstanceInfo |
Information about current module and worker retrievable during topology execution with
Ops.MODULE_INSTANCE_INFO |
| SelectOptions.CaptureSelectOptions | |
| SortedRangeFromOptions.CapturedSortedRangeFromOptions | |
| SortedRangeOptions.CapturedSortedRangeOptions | |
| SortedRangeToOptions.CapturedSortedRangeToOptions | |
| SubBatch |
Represents a subbatch for use with
subBatch in a batch block |
| SubindexOptions.CapturedSubindexOptions |
| Enum | Description |
|---|---|
| AckLevel |
Ack levels for use with
depot clients. |
| ProxyState.Status |
| Exception | Description |
|---|---|
| RamaCompileException |