All Classes and Interfaces
Class
Description
Ack levels for use with
depot clients.Used for specifying aggregators in Rama topologies in conjunction with
agg or compoundAgg
methodsRepresents an unknown value being appended to a sequence.
This interface defines the functionality required in order to
create, store and manage Rama cluster backups.
Provide a test implementation for a backup provider implementation.
Core API for specifying dataflow code using the builder pattern.
Used to create cases for
Block.cond(com.rpl.rama.Case...)Interface for retrieving depots, PStates, and query topology clients from a real cluster
or
InProcessClusterStatic methods for making aggregation templates for
Block.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 module
Interface for implementing custom depot partitioners
Information about a depot partition.
Final diff sent to proxy callback after
close is called on it.Base class for diff data which represents incremental change to a value coming from
a
PState.proxy(Path, ProxyState.Callback) proxy} call on a PState.Base interface for stream and microbatch topologies
Specifies an expression to be used in an argument position in dataflow code.
This interface is used to integrate external queue systems as depots inside Rama.
Collection of static utility methods
Simulates a Rama cluster in a single process.
Represents a key in a map changing to a new value.
Represents a value for a key changing.
Represents a key being removed from data structure.
Represents changes for values for multiple keys in a data structure.
Represents multiple keys being removed from map data structure.
Object to specify parallelism settings for modules launched on an
InProcessClusterSpecifies a limit aggregator for use with
limitAggDeclares vars for a
loopWithVars call using builder pattern
Example: LoopVars.var("*a", 1).var("*b", 2)Depot source options for microbatch topologies using builder pattern
Microbatch topologies documentation
Helper utility for unit testing a
RamaOperation
outside the context of a module or Block.Information about a captured emit
Information about current module and worker retrievable during topology execution with
Ops.MODULE_INSTANCE_INFOChange between old and new values is represented by multiple diffs in the order in which they happened.
Represents a value being added to a multi-set (a map from element to count).
Represents a value being removed from a multi-set (a map from element to count).
Interface for implementing custom navigators for use in a
PathOld value has been replaced by a new value.
Enum to specify option for
MicrobatchSourceOptions.startFromOffsetAgo(long, OffsetAgo)
or StreamSourceOptions.startFromOffsetAgo(long, OffsetAgo)Interface for emitting results from custom
RamaOperation implementationsInterface that has methods that are common across partitioned objects (depots, PStates).
Information common to all partitioned objects (depots, PStates).
A Path defines how to navigate to target values in a data structure as a series of steps.
Reactive result of one of
PState proxy methods.Interface for specifying callbacks for fine-grained diffs as data changes
Interface for thread-safe PState clients.
Builder-style interface for specifying options when declaring a PState in a module
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<?, ?>)Builder-style interface for declaring options on PState schemas
Client for invoking a query topology.
Base interface for custom accumulator implementations.
Interface for custom accumulator implementations of zero arguments.
Interface for custom accumulator implementations of one argument.
Interface for custom accumulator implementations of two arguments.
Interface for custom accumulator implementations of three arguments.
Interface for custom accumulator implementations of four arguments.
Interface for custom accumulator implementations of five arguments.
Interface for custom accumulator implementations of six arguments.
Interface for custom accumulator implementations of seven arguments.
Interface for custom accumulator implementations of eight arguments.
API for connecting to a Rama cluster and getting clients for depots, PStates, and query
topologies.
Base interface for custom combiner implementations.
Interface for implementing serialization for custom types.
Base interface for custom function implementations.
Interface for custom function implementations of zero arguments
Interface for custom function implementations of one argument
Interface for custom function implementations of two arguments
Interface for custom function implementations of three arguments
Interface for custom function implementations of four arguments
Interface for custom function implementations of five arguments
Interface for custom function implementations of six arguments
Interface for custom function implementations of seven arguments
Interface for custom function implementations of eight arguments
Defines a Rama module.
A module specifies an arbitrary collection of depots, ETLs, PStates, and query topologies to deploy onto a Rama cluster.
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.
Base interface for custom operation implementations.
Interface for custom operation implementation of zero arguments.
Interface for custom operation implementation of one argument.
Interface for custom operation implementation of two arguments.
Interface for custom operation implementation of three arguments.
Interface for custom operation implementation of four arguments.
Interface for custom operation implementation of five arguments.
Interface for custom operation implementation of six arguments.
Interface for custom operation implementation of seven arguments.
Interface for custom operation implementation of eight arguments.
Objects implementing this interface will be serialized by Rama across disk or network boundaries using
Java serialization.
Represents value being re-queried from scratch.
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.
Represents unknown change to a sequence starting from a particular index.
Represents a value for an index of a sequence changing.
Represents changes for values for multiple indexes in a sequence.
Represents one or more values being removed starting at some index in a sequence.
Represents a value being inserted at some index in a sequence.
Represents multiple values being inserted at some index in a sequence.
Represents a value in a sequence being moved from one index to another, shifting other values to new indexes
in the process.
Represents a value being added to a set.
Represents a value being removed from a set.
Interface for declaring options for
Path.sortedMapRangeFrom(java.lang.Object) or Path.sortedSetRangeFrom(java.lang.Object).Interface for declaring options for
Path.sortedMapRange(java.lang.Object, java.lang.Object) or Path.sortedSetRange(java.lang.Object, java.lang.Object).Interface for declaring options for
Path.sortedMapRangeTo(java.lang.Object) or Path.sortedSetRangeTo(java.lang.Object).Depot source options for stream topologies using builder pattern
Stream topologies documentation
Represents a subbatch for use with
subBatch in a batch blockInterface for declaring options on a subindexed PState schema
Used to create cases for
Block.subSource(java.lang.Object, com.rpl.rama.SubSource...)Provides contextual information for
TaskGlobalObject.prepareForTask(int, TaskGlobalContext).Objects implementing this interface that are provided to
RamaModule.Setup.declareObject(String, Object)
can specialize their implementation per task.Defines a
task global object that will have TaskGlobalObjectWithTick.tick() called
at a regular frequency.Used for sharing resources across tasks in a task thread
Helper utility compatible with
Block.localSelect(java.lang.String, com.rpl.rama.Path) and Block.localTransform(java.lang.String, com.rpl.rama.Path).Builder-style object for customizing options to a call to
Agg.topMonotonic(int, java.lang.String)Sent when the proxy has been terminated by Rama due to having too many failures.
Change between old and new values is unknown.
Class for providing options to
InProcessCluster.updateModule(RamaModule, UpdateOptions)Used for sharing resources across tasks in a worker