Package com.rpl.rama
package com.rpl.rama
-
ClassDescriptionAck levels for use with
depot clients.Used for specifying aggregators in Rama topologies in conjunction withaggorcompoundAggmethodsCore API for specifying dataflow code using the builder pattern.Used to create cases forBlock.cond(com.rpl.rama.Case...)Static methods for making aggregation templates forBlock.compoundAgg(com.rpl.rama.CompoundAgg).Wrapper type to force an object to be a constant in dataflow code.Interface for thread-safe depot clients.Builder-style object to specify options when declaring a depot in a moduleInterface for implementing custom depot partitionersSpecifies an expression to be used in an argument position in dataflow code.Collection of static utility methodsDeclares vars for aloopWithVarscall using builder pattern Example:LoopVars.var("*a", 1).var("*b", 2)Information about current module and worker retrievable during topology execution withOps.MODULE_INSTANCE_INFONavigator<T>Interface for implementing custom navigators for use in aPathInterface that has methods that are common across partitioned objects (depots, PStates).A Path defines how to navigate to target values in a data structure as a series of steps.ProxyState<T>Reactive result of one ofPStateproxymethods.Interface for specifying callbacks for fine-grained diffs as data changesInterface for thread-safe PState clients.Builder-style interface for specifying options when declaring a PState in a moduleBuilder-style interface for declaring options on a migrated schema declared withPState.migrated(java.lang.Object, java.lang.String, com.rpl.rama.ops.RamaFunction1<?, ?>)Builder-style interface for declaring options on PState schemasClient for invoking a query topology.API for connecting to a Rama cluster and getting clients for depots, PStates, and query topologies.Interface for implementing serialization for custom types.Defines a Rama module.
A module specifies an arbitrary collection of depots, ETLs, PStates, and query topologies to deploy onto a Rama cluster.Used to define depots, global objects, and module dependencies in a module definition.Used to define ETL and query topologies in a module definition.Objects implementing this interface will be serialized by Rama across disk or network boundaries using Java serialization.Rama uses RocksDB in the underlying implementation for PStates that have a map in the top-level schema.Interface for declaring options for select calls in topologies.Interface for declaring options forPath.sortedMapRangeFrom(java.lang.Object)orPath.sortedSetRangeFrom(java.lang.Object).Interface for declaring options forPath.sortedMapRange(java.lang.Object, java.lang.Object)orPath.sortedSetRange(java.lang.Object, java.lang.Object).Interface for declaring options forPath.sortedMapRangeTo(java.lang.Object)orPath.sortedSetRangeTo(java.lang.Object).Represents a subbatch for use withsubBatchin a batch blockInterface for declaring options on a subindexed PState schemaUsed to create cases forBlock.subSource(java.lang.Object, com.rpl.rama.SubSource...)