Skip navigation links
A B C D E F G H I K L M N O P Q R S T U V W Y Z 

A

accumulate(V) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg0
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg1
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg2
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg3
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2, T3) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg4
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2, T3, T4) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg5
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2, T3, T4, T5) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg6
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2, T3, T4, T5, T6) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg7
Combine current aggregated value with new input to produce new aggregated value
accumulate(V, T0, T1, T2, T3, T4, T5, T6, T7) - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg8
Combine current aggregated value with new input to produce new aggregated value
accumulator(RamaAccumulatorAgg0) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of zero arguments as an aggregator.
accumulator(RamaAccumulatorAgg1, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of one argument as an aggregator.
accumulator(RamaAccumulatorAgg2, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of two arguments as an aggregator.
accumulator(RamaAccumulatorAgg3, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of three arguments as an aggregator.
accumulator(RamaAccumulatorAgg4, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of four arguments as an aggregator.
accumulator(RamaAccumulatorAgg5, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of five arguments as an aggregator.
accumulator(RamaAccumulatorAgg6, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of six arguments as an aggregator.
accumulator(RamaAccumulatorAgg7, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of seven arguments as an aggregator.
accumulator(RamaAccumulatorAgg8, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Agg
Use a custom accumulator of eight arguments as an aggregator.
AckLevel - Enum in com.rpl.rama
Ack levels for use with depot clients.
ackReturn(Object) - Static method in interface com.rpl.rama.Block
Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK
ackReturn(Object) - Method in interface com.rpl.rama.Block.Impl
Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK
ackReturn(Object) - Method in interface com.rpl.rama.Case.Impl
Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK
ackReturn(Object) - Method in interface com.rpl.rama.SubSource.Impl
Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK
ackReturnAgg(RamaAccumulatorAgg1) - Static method in interface com.rpl.rama.module.StreamSourceOptions
Specifies aggregator to use for ack returns for processing off of this depot.
ackReturnAgg(RamaCombinerAgg) - Static method in interface com.rpl.rama.module.StreamSourceOptions
Specifies aggregator to use for ack returns for processing off of this depot.
ackReturnAgg(RamaFunction1<Object, Agg>) - Static method in interface com.rpl.rama.module.StreamSourceOptions
Specifies aggregator to use for ack returns for processing off of this depot.
ackReturnAgg(RamaAccumulatorAgg1) - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Specifies aggregator to use for ack returns for processing off of this depot.
ackReturnAgg(RamaCombinerAgg) - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Specifies aggregator to use for ack returns for processing off of this depot.
ackReturnAgg(RamaFunction1<Object, Agg>) - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Specifies aggregator to use for ack returns for processing off of this depot.
afterElem() - Static method in interface com.rpl.rama.Path
Navigates on a list to void element at end.
afterElem() - Method in interface com.rpl.rama.Path.Impl
Navigates on a list to void element at end.
Agg - Interface in com.rpl.rama
Used for specifying aggregators in Rama topologies in conjunction with agg or compoundAgg methods
agg(Agg) - Static method in interface com.rpl.rama.Block
Aggregates input in a batch block to a single value.
agg(String, Agg) - Static method in interface com.rpl.rama.Block
Update PState partition on current task with given aggregator.
agg(Agg) - Method in interface com.rpl.rama.Block.Impl
Aggregates input in a batch block to a single value.
agg(String, Agg) - Method in interface com.rpl.rama.Block.Impl
Update PState partition on current task with given aggregator.
agg(Agg) - Method in interface com.rpl.rama.Case.Impl
Aggregates input in a batch block to a single value.
agg(String, Agg) - Method in interface com.rpl.rama.Case.Impl
Update PState partition on current task with given aggregator.
agg(Agg) - Method in interface com.rpl.rama.SubSource.Impl
Aggregates input in a batch block to a single value.
agg(String, Agg) - Method in interface com.rpl.rama.SubSource.Impl
Update PState partition on current task with given aggregator.
AggOrCompoundAgg - Interface in com.rpl.rama.ops
 
all() - Static method in interface com.rpl.rama.Path
Navigates to every element of a collection.
all() - Method in interface com.rpl.rama.Path.Impl
Navigates to every element of a collection.
allPartition() - Static method in interface com.rpl.rama.Block
Executes subsequent code on all tasks in module
allPartition(String) - Static method in interface com.rpl.rama.Block
Executes subsequent code on all partitions of given depot or PState
allPartition() - Method in interface com.rpl.rama.Block.Impl
Executes subsequent code on all tasks in module
allPartition(String) - Method in interface com.rpl.rama.Block.Impl
Executes subsequent code on all partitions of given depot or PState
allPartition() - Method in interface com.rpl.rama.Case.Impl
Executes subsequent code on all tasks in module
allPartition(String) - Method in interface com.rpl.rama.Case.Impl
Executes subsequent code on all partitions of given depot or PState
allPartition() - Method in interface com.rpl.rama.SubSource.Impl
Executes subsequent code on all tasks in module
allPartition(String) - Method in interface com.rpl.rama.SubSource.Impl
Executes subsequent code on all partitions of given depot or PState
anchor(String) - Static method in interface com.rpl.rama.Block
Attaches a no-op node with the given anchor
anchor(String) - Method in interface com.rpl.rama.Block.Impl
Attaches a no-op node with the given anchor
anchor(String) - Method in interface com.rpl.rama.Case.Impl
Attaches a no-op node with the given anchor
anchor(String) - Method in interface com.rpl.rama.SubSource.Impl
Attaches a no-op node with the given anchor
and(Object) - Static method in interface com.rpl.rama.Agg
Applies "and" operator to all input.
AND - Static variable in class com.rpl.rama.ops.Ops
"and" operator based on values being "truthy" (not null or false).
append(Object) - Method in interface com.rpl.rama.Depot
Append data to depot using AckLevel.ACK.
append(Object, AckLevel) - Method in interface com.rpl.rama.Depot
Append data to depot using specified AckLevel.
appendAsync(Object) - Method in interface com.rpl.rama.Depot
Append data to depot using AckLevel.ACK.
appendAsync(Object, AckLevel) - Method in interface com.rpl.rama.Depot
Append data to depot using specified AckLevel.
AppendDiff - Class in com.rpl.rama.diffs
Represents an unknown value being appended to a sequence.
AppendDiff(int) - Constructor for class com.rpl.rama.diffs.AppendDiff
 
AppendDiff.Processor - Interface in com.rpl.rama.diffs
 
ascending() - Method in interface com.rpl.rama.ops.TopMonotonicAgg
Sort results in ascending order rather than descending order
atomicBlock(Block) - Static method in interface com.rpl.rama.Block
Runs subblock until it completes synchronously.
atomicBlock(Block) - Method in interface com.rpl.rama.Block.Impl
Runs subblock until it completes synchronously.
atomicBlock(Block) - Method in interface com.rpl.rama.Case.Impl
Runs subblock until it completes synchronously.
atomicBlock(Block) - Method in interface com.rpl.rama.SubSource.Impl
Runs subblock until it completes synchronously.
average(Object) - Static method in interface com.rpl.rama.Agg
Averages input into a java.lang.Long.

B

batchBlock(Block) - Static method in interface com.rpl.rama.Block
Specifies a batch block.
batchBlock(Block) - Method in interface com.rpl.rama.Block.Impl
Specifies a batch block.
batchBlock(Block) - Method in interface com.rpl.rama.Case.Impl
Specifies a batch block.
batchBlock(Block) - Method in interface com.rpl.rama.SubSource.Impl
Specifies a batch block.
beforeElem() - Static method in interface com.rpl.rama.Path
Navigates on a list to void element at beginning.
beforeElem() - Method in interface com.rpl.rama.Path.Impl
Navigates on a list to void element at beginning.
beforeIndex(Object) - Static method in interface com.rpl.rama.Path
Navigates on list to void element before an index.
beforeIndex(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on list to void element before an index.
beginning() - Static method in interface com.rpl.rama.Path
Navigates on a list to empty subsequence at beginning.
beginning() - Method in interface com.rpl.rama.Path.Impl
Navigates on a list to empty subsequence at beginning.
Block - Interface in com.rpl.rama
Core API for specifying dataflow code using the builder pattern.
Block.Impl - Interface in com.rpl.rama
 
Block.MultiOutImpl - Interface in com.rpl.rama
 
Block.Out - Interface in com.rpl.rama
 
Block.OutImpl - Interface in com.rpl.rama
 
branch(String, Block) - Static method in interface com.rpl.rama.Block
 
branch(String, Block) - Method in interface com.rpl.rama.Block.Impl
 
branch(String, Block) - Method in interface com.rpl.rama.Case.Impl
 
branch(String, Block) - Method in interface com.rpl.rama.SubSource.Impl
 

C

canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.AppendDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.DestroyedDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.Diff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyRemoveDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeysDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.NewValueDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.ResyncDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SetAddDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SetRemoveDiff
 
canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.UnknownDiff
 
CapturedEmit(String, Object...) - Constructor for class com.rpl.rama.test.MockOutputCollector.CapturedEmit
 
CapturedSortedRangeFromOptions() - Constructor for class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions
 
CapturedSortedRangeOptions() - Constructor for class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions
 
CapturedSortedRangeToOptions() - Constructor for class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions
 
CapturedSubindexOptions() - Constructor for class com.rpl.rama.SubindexOptions.CapturedSubindexOptions
 
captureNewValInto(String) - Method in interface com.rpl.rama.Agg
Captures updated value of aggregated location into var for post-agg phase of a batch block.
Case - Interface in com.rpl.rama
Used to create cases for Block.cond(com.rpl.rama.Case...)
Case.Impl - Interface in com.rpl.rama
 
Case.MultiOutImpl - Interface in com.rpl.rama
 
Case.Out - Interface in com.rpl.rama
 
Case.OutImpl - Interface in com.rpl.rama
 
change(T, Diff, T) - Method in interface com.rpl.rama.ProxyState.Callback
Callback method for changes to this value
choosePartitionIndex(T, int) - Method in interface com.rpl.rama.Depot.Partitioning
Computes partition number for append based on data and number of partitions in depot
CLASS - Static variable in class com.rpl.rama.ops.Ops
Emits Class of argument.
close() - Method in class com.rpl.rama.integration.ManagedResource
Closes the resource if it's an instance of java.io.Closeable.
clusterDepot(String, String) - Method in interface com.rpl.rama.cluster.ClusterManagerBase
Retrieve client for a Depot
clusterDepot(String, String, String) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a mirror depot that accesses a depot on another module.
ClusterManagerBase - Interface in com.rpl.rama.cluster
Interface for retrieving depots, PStates, and query topology clients from a real cluster or InProcessCluster
clusterPState(String, String) - Method in interface com.rpl.rama.cluster.ClusterManagerBase
Retrieve client for a PState
clusterPState(String, String, String) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a mirror PState that accesses a PState on another module.
clusterQuery(String, String) - Method in interface com.rpl.rama.cluster.ClusterManagerBase
Retrieve client for a query topology
clusterQuery(String, String, String) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a query topology reference for invoking a query topology on another module.
collect(Path) - Static method in interface com.rpl.rama.Path
Collects a list of values selected with given path from current point.
collect(Path) - Method in interface com.rpl.rama.Path.Impl
Collects a list of values selected with given path from current point.
collectOne(Path) - Static method in interface com.rpl.rama.Path
Collects a single value selected with given path from current point.
collectOne(Path) - Method in interface com.rpl.rama.Path.Impl
Collects a single value selected with given path from current point.
com.rpl.rama - package com.rpl.rama
 
com.rpl.rama.cluster - package com.rpl.rama.cluster
 
com.rpl.rama.diffs - package com.rpl.rama.diffs
 
com.rpl.rama.integration - package com.rpl.rama.integration
 
com.rpl.rama.module - package com.rpl.rama.module
 
com.rpl.rama.ops - package com.rpl.rama.ops
 
com.rpl.rama.test - package com.rpl.rama.test
 
combine(T, T) - Method in interface com.rpl.rama.ops.RamaCombinerAgg
Combine two values into an aggregated value
combiner(RamaCombinerAgg, Object) - Static method in interface com.rpl.rama.Agg
Use a custom combiner as an aggregator
compoundAgg(CompoundAgg) - Static method in interface com.rpl.rama.Block
Aggregates input in a batch block to a single value.
compoundAgg(String, CompoundAgg) - Static method in interface com.rpl.rama.Block
Update PState partition on current task with given aggregation template.
compoundAgg(CompoundAgg) - Method in interface com.rpl.rama.Block.Impl
Aggregates input in a batch block to a single value.
compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama.Block.Impl
Update PState partition on current task with given aggregation template.
compoundAgg(CompoundAgg) - Method in interface com.rpl.rama.Case.Impl
Aggregates input in a batch block to a single value.
compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama.Case.Impl
Update PState partition on current task with given aggregation template.
CompoundAgg - Interface in com.rpl.rama
Static methods for making aggregation templates for Block.compoundAgg(com.rpl.rama.CompoundAgg).
compoundAgg(CompoundAgg) - Method in interface com.rpl.rama.SubSource.Impl
Aggregates input in a batch block to a single value.
compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama.SubSource.Impl
Update PState partition on current task with given aggregation template.
cond(Case...) - Static method in interface com.rpl.rama.Block
Evaluates condition for each Case in order.
cond(Case...) - Method in interface com.rpl.rama.Block.Impl
Evaluates condition for each Case in order.
cond(Case...) - Method in interface com.rpl.rama.Case.Impl
Evaluates condition for each Case in order.
cond(Case...) - Method in interface com.rpl.rama.SubSource.Impl
Evaluates condition for each Case in order.
Constant - Class in com.rpl.rama
Wrapper type to force an object to be a constant in dataflow code.
Constant(Object) - Constructor for class com.rpl.rama.Constant
 
CONTAINS - Static variable in class com.rpl.rama.ops.Ops
Arguments are a collection and an object and returns boolean true or false if the object is contained in the collection.
continueLoop(Object...) - Static method in interface com.rpl.rama.Block
Executes another iteration of the loop.
continueLoop(Object...) - Method in interface com.rpl.rama.Block.Impl
Executes another iteration of the loop.
continueLoop(Object...) - Method in interface com.rpl.rama.Case.Impl
Executes another iteration of the loop.
continueLoop(Object...) - Method in interface com.rpl.rama.SubSource.Impl
Executes another iteration of the loop.
count() - Static method in interface com.rpl.rama.Agg
Counts input into a java.lang.Long
create() - Static method in interface com.rpl.rama.Block
Creates an empty Block that can have additional code attached.
create(Object) - Static method in interface com.rpl.rama.Case
Create a case matching on the given condition.
create() - Static method in interface com.rpl.rama.LoopVars
Creates an empty LoopVars.
create() - Static method in interface com.rpl.rama.module.MicrobatchSourceOptions
Creates an empty MicrobatchSourceOptions.
create() - Static method in interface com.rpl.rama.module.StreamSourceOptions
Creates an empty StreamSourceOptions.
create(int, String...) - Static method in interface com.rpl.rama.ops.LimitAgg
Creates a limit aggregator specification
create() - Static method in interface com.rpl.rama.Path
Creates an empty Path.
create() - Static method in interface com.rpl.rama.SortedRangeFromOptions
Creates an empty SortedRangeFromOptions.
create() - Static method in interface com.rpl.rama.SortedRangeOptions
Creates an empty SortedRangeOptions.
create() - Static method in interface com.rpl.rama.SortedRangeToOptions
Creates an empty SortedRangeToOptions.
create() - Static method in interface com.rpl.rama.SubindexOptions
Creates an empty SubindexOptions.
create(Class) - Static method in interface com.rpl.rama.SubSource
Create a subSource case matching on the given type exactly.
create() - Static method in interface com.rpl.rama.test.InProcessCluster
Creates an InProcessCluster
create(List<Class>) - Static method in interface com.rpl.rama.test.InProcessCluster
Creates an InProcessCluster with the specified RamaCustomSerialization implementations registered for all launched modules
create(PState.Schema) - Static method in interface com.rpl.rama.test.TestPState
Creates a TestPState with the given schema.
create(Class) - Static method in interface com.rpl.rama.test.TestPState
Creates a TestPState with the given schema.
create() - Static method in interface com.rpl.rama.test.UpdateOptions
Create empty instance
CURRENT_MICROBATCH_ID - Static variable in class com.rpl.rama.ops.Ops
Returns ID of current microbatch attempt.
CURRENT_TASK_ID - Static variable in class com.rpl.rama.ops.Ops
Emits task ID where event is running
customNav(Navigator) - Static method in interface com.rpl.rama.Path
Adds custom navigator implementation to Path
customNav(Navigator) - Method in interface com.rpl.rama.Path.Impl
Adds custom navigator implementation to Path
customNavBuilder(RamaFunction0<Navigator>) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of zero arguments.
customNavBuilder(RamaFunction1<T0, Navigator>, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of one argument.
customNavBuilder(RamaFunction2<T0, T1, Navigator>, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of two arguments.
customNavBuilder(RamaFunction3<T0, T1, T2, Navigator>, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of three arguments.
customNavBuilder(RamaFunction4<T0, T1, T2, T3, Navigator>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of four arguments.
customNavBuilder(RamaFunction5<T0, T1, T2, T3, T4, Navigator>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of five arguments.
customNavBuilder(RamaFunction6<T0, T1, T2, T3, T4, T5, Navigator>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of six arguments.
customNavBuilder(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, Navigator>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of seven arguments.
customNavBuilder(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, Navigator>, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Adds a custom navigator built dynamically with the provided function of eight arguments.
customNavBuilder(RamaFunction0<Navigator>) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of zero arguments.
customNavBuilder(RamaFunction1<T0, Navigator>, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of one argument.
customNavBuilder(RamaFunction2<T0, T1, Navigator>, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of two arguments.
customNavBuilder(RamaFunction3<T0, T1, T2, Navigator>, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of three arguments.
customNavBuilder(RamaFunction4<T0, T1, T2, T3, Navigator>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of four arguments.
customNavBuilder(RamaFunction5<T0, T1, T2, T3, T4, Navigator>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of five arguments.
customNavBuilder(RamaFunction6<T0, T1, T2, T3, T4, T5, Navigator>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of six arguments.
customNavBuilder(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, Navigator>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of seven arguments.
customNavBuilder(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, Navigator>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Adds a custom navigator built dynamically with the provided function of eight arguments.
customPartition(RamaFunction1<Integer, Integer>) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with one argument.
customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with two arguments.
customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with three arguments.
customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with four arguments.
customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with five arguments.
customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with six arguments.
customPartition(RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with seven arguments.
customPartition(RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes task to task ID specified by custom partitioner function with eight arguments.
customPartition(String, RamaFunction1<Integer, Integer>) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with one argument.
customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with two arguments.
customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with three arguments.
customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with four arguments.
customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with five arguments.
customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with six arguments.
customPartition(String, RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with seven arguments.
customPartition(String, RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Changes to task containing PState partition specified by custom partitioner function with eight arguments.
customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with one argument.
customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with two arguments.
customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with three arguments.
customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with four arguments.
customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with five arguments.
customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with six arguments.
customPartition(RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with seven arguments.
customPartition(RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes task to task ID specified by custom partitioner function with eight arguments.
customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with one argument.
customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with two arguments.
customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with three arguments.
customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with four arguments.
customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with five arguments.
customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with six arguments.
customPartition(String, RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with seven arguments.
customPartition(String, RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to task containing PState partition specified by custom partitioner function with eight arguments.
customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with one argument.
customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with two arguments.
customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with three arguments.
customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with four arguments.
customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with five arguments.
customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with six arguments.
customPartition(RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with seven arguments.
customPartition(RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes task to task ID specified by custom partitioner function with eight arguments.
customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with one argument.
customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with two arguments.
customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with three arguments.
customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with four arguments.
customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with five arguments.
customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with six arguments.
customPartition(String, RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with seven arguments.
customPartition(String, RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to task containing PState partition specified by custom partitioner function with eight arguments.
customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with one argument.
customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with two arguments.
customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with three arguments.
customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with four arguments.
customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with five arguments.
customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with six arguments.
customPartition(RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with seven arguments.
customPartition(RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes task to task ID specified by custom partitioner function with eight arguments.
customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with one argument.
customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with two arguments.
customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with three arguments.
customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with four arguments.
customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with five arguments.
customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with six arguments.
customPartition(String, RamaFunction7<Integer, T0, T1, T2, T3, T4, T5, Integer>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with seven arguments.
customPartition(String, RamaFunction8<Integer, T0, T1, T2, T3, T4, T5, T6, Integer>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task containing PState partition specified by custom partitioner function with eight arguments.

D

DEC - Static variable in class com.rpl.rama.ops.Ops
Emits one less than input value as an Integer
DEC_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits one less than input value as a Long
declareDepot(String, NativeDepotPartitioning) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a depot with the given partitioning scheme.
declareDepot(String, Class<T>) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a depot with the given partitioning scheme.
declareObject(String, Object) - Method in interface com.rpl.rama.RamaModule.Setup
Defines an object to be copied to all tasks.
declareTickDepot(String, long) - Method in interface com.rpl.rama.RamaModule.Setup
Defines a depot that emits at the given frequency of time.
define(RamaModule.Setup, RamaModule.Topologies) - Method in interface com.rpl.rama.RamaModule
Specifies all depots, PStates, ETLs, and query topologies for this module.
Depot - Interface in com.rpl.rama
Interface for thread-safe depot clients.
Depot.Declaration - Interface in com.rpl.rama
Builder-style object to specify options when declaring a depot in a module
Depot.Partitioning<T> - Interface in com.rpl.rama
Interface for implementing custom depot partitioners
depotPartitionAppend(String, Object, AckLevel) - Static method in interface com.rpl.rama.Block
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object) - Static method in interface com.rpl.rama.Block
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama.Block.Impl
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object) - Method in interface com.rpl.rama.Block.Impl
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama.Case.Impl
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object) - Method in interface com.rpl.rama.Case.Impl
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama.SubSource.Impl
Append data to the partition of the depot represented by current task.
depotPartitionAppend(String, Object) - Method in interface com.rpl.rama.SubSource.Impl
Append data to the partition of the depot represented by current task.
deserialize(DataInput) - Method in interface com.rpl.rama.RamaCustomSerialization
Deserialize object
DestroyedDiff - Class in com.rpl.rama.diffs
Final diff sent to proxy callback after close is called on it.
DestroyedDiff() - Constructor for class com.rpl.rama.diffs.DestroyedDiff
 
DestroyedDiff.Processor - Interface in com.rpl.rama.diffs
 
destroyModule(String) - Method in interface com.rpl.rama.test.InProcessCluster
Destroy a module
Diff - Class in com.rpl.rama.diffs
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.
Diff() - Constructor for class com.rpl.rama.diffs.Diff
 
Diff.Processor - Interface in com.rpl.rama.diffs
 
directPartition(Object) - Static method in interface com.rpl.rama.Block
Changes to specified task ID
directPartition(String, Object) - Static method in interface com.rpl.rama.Block
Changes to specified partition of the given depot or PState
directPartition(Object) - Method in interface com.rpl.rama.Block.Impl
Changes to specified task ID
directPartition(String, Object) - Method in interface com.rpl.rama.Block.Impl
Changes to specified partition of the given depot or PState
directPartition(Object) - Method in interface com.rpl.rama.Case.Impl
Changes to specified task ID
directPartition(String, Object) - Method in interface com.rpl.rama.Case.Impl
Changes to specified partition of the given depot or PState
directPartition(Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to specified task ID
directPartition(String, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes to specified partition of the given depot or PState
disallow() - Static method in interface com.rpl.rama.Depot
Disallows depot clients from appending to this depot.
dispenseCollected() - Static method in interface com.rpl.rama.Path
Drops all collected values from subsequent navigation
dispenseCollected() - Method in interface com.rpl.rama.Path.Impl
Drops all collected values from subsequent navigation
DIV - Static variable in class com.rpl.rama.ops.Ops
Divides first argument by second argument and emits a Double
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.AppendDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.DestroyedDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.Diff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeyRemoveDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeysDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.NewValueDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.ResyncDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SetAddDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.SetRemoveDiff
 
doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs.UnknownDiff
 

E

each(RamaFunction0<R>) - Static method in interface com.rpl.rama.Block
Invokes a function of zero arguments.
each(RamaFunction1<T0, R>, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of one argument.
each(RamaFunction2<T0, T1, R>, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of two arguments.
each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of three arguments.
each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of four arguments.
each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of five arguments.
each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of six arguments.
each(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of seven arguments.
each(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R>, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of eight arguments.
each(RamaOperation0) - Static method in interface com.rpl.rama.Block
Invokes an operation of zero arguments.
each(RamaOperation1<T0>, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of one argument.
each(RamaOperation2<T0, T1>, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of two arguments.
each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of three arguments.
each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of four arguments.
each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of five arguments.
each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of six arguments.
each(RamaOperation7<T0, T1, T2, T3, T4, T5, T6>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of seven arguments.
each(RamaOperation8<T0, T1, T2, T3, T4, T5, T6, T7>, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes an operation of eight arguments.
each(RamaFunction0<R>) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of zero arguments.
each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of one argument.
each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of two arguments.
each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of three arguments.
each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of four arguments.
each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of five arguments.
each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of six arguments.
each(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of seven arguments.
each(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of eight arguments.
each(RamaOperation0) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of zero arguments.
each(RamaOperation1<T0>, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of one argument.
each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of two arguments.
each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of three arguments.
each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of four arguments.
each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of five arguments.
each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of six arguments.
each(RamaOperation7<T0, T1, T2, T3, T4, T5, T6>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of seven arguments.
each(RamaOperation8<T0, T1, T2, T3, T4, T5, T6, T7>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes an operation of eight arguments.
each(RamaFunction0<R>) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of zero arguments.
each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of one argument.
each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of two arguments.
each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of three arguments.
each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of four arguments.
each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of five arguments.
each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of six arguments.
each(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of seven arguments.
each(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of eight arguments.
each(RamaOperation0) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of zero arguments.
each(RamaOperation1<T0>, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of one argument.
each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of two arguments.
each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of three arguments.
each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of four arguments.
each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of five arguments.
each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of six arguments.
each(RamaOperation7<T0, T1, T2, T3, T4, T5, T6>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of seven arguments.
each(RamaOperation8<T0, T1, T2, T3, T4, T5, T6, T7>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes an operation of eight arguments.
each(RamaFunction0<R>) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of zero arguments.
each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of one argument.
each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of two arguments.
each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of three arguments.
each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of four arguments.
each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of five arguments.
each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of six arguments.
each(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of seven arguments.
each(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of eight arguments.
each(RamaOperation0) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of zero arguments.
each(RamaOperation1<T0>, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of one argument.
each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of two arguments.
each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of three arguments.
each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of four arguments.
each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of five arguments.
each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of six arguments.
each(RamaOperation7<T0, T1, T2, T3, T4, T5, T6>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of seven arguments.
each(RamaOperation8<T0, T1, T2, T3, T4, T5, T6, T7>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes an operation of eight arguments.
eachAsync(RamaFunction0<CompletableFuture>) - Static method in interface com.rpl.rama.Block
Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Block
Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction0<CompletableFuture>) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Block.Impl
Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction0<CompletableFuture>) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Case.Impl
Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction0<CompletableFuture>) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture.
eachAsync(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, CompletableFuture>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture.
emit(Object...) - Method in interface com.rpl.rama.ops.OutputCollector
Emit any number of fields to the default output stream.
emit(Object...) - Method in class com.rpl.rama.test.MockOutputCollector
 
emitLoop(Object...) - Static method in interface com.rpl.rama.Block
Emits from a loop.
emitLoop(Object...) - Method in interface com.rpl.rama.Block.Impl
Emits from a loop.
emitLoop(Object...) - Method in interface com.rpl.rama.Case.Impl
Emits from a loop.
emitLoop(Object...) - Method in interface com.rpl.rama.SubSource.Impl
Emits from a loop.
emitStream(String, Object...) - Method in interface com.rpl.rama.ops.OutputCollector
Emit any number of fields to a named output stream.
emitStream(String, Object...) - Method in class com.rpl.rama.test.MockOutputCollector
 
end() - Static method in interface com.rpl.rama.Path
Navigates on a list to empty subsequence at end.
end() - Method in interface com.rpl.rama.Path.Impl
Navigates on a list to empty subsequence at end.
endOffset(int) - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns the end offset of the given partition index (exclusive).
EQUAL - Static variable in class com.rpl.rama.ops.Ops
Tests whether all arguments are equal and emits boolean true or false.
equals(Object) - Method in class com.rpl.rama.diffs.AppendDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.DestroyedDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.KeyDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.KeyRemoveDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.KeysDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.MultiDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.NewValueDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.ResyncDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SetAddDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.SetRemoveDiff
 
equals(Object) - Method in class com.rpl.rama.diffs.UnknownDiff
 
equals(Object) - Method in class com.rpl.rama.test.MockOutputCollector.CapturedEmit
 
ETLTopologyBase<T> - Interface in com.rpl.rama.module
Base interface for stream and microbatch topologies
excludeStart() - Method in class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions
 
excludeStart() - Static method in interface com.rpl.rama.SortedRangeFromOptions
Excludes the start key from the results (by default it's included).
excludeStart() - Method in interface com.rpl.rama.SortedRangeFromOptions.Impl
Excludes the start key from the results (by default it's included).
excludeStart() - Method in class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions
 
excludeStart() - Static method in interface com.rpl.rama.SortedRangeOptions
Excludes the start key from the results (by default it's included).
excludeStart() - Method in interface com.rpl.rama.SortedRangeOptions.Impl
Excludes the start key from the results (by default it's included).
execute() - Method in interface com.rpl.rama.Block.Impl
Execute the given Block on the current thread.
EXPAND - Static variable in class com.rpl.rama.ops.Ops
Emits every element of input list as a separate field.
EXPLODE - Static variable in class com.rpl.rama.ops.Ops
Emits every element of input list individually.
EXPLODE_INDEXED - Static variable in class com.rpl.rama.ops.Ops
Emits every element of input list individually along with index of emit.
EXPLODE_MAP - Static variable in class com.rpl.rama.ops.Ops
Emits every key/value pair of input map individually.
explodeMaterialized(String) - Static method in interface com.rpl.rama.Block
Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...).
explodeMaterialized(String) - Method in interface com.rpl.rama.Block.Impl
Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...).
explodeMaterialized(String) - Method in interface com.rpl.rama.Case.Impl
Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...).
explodeMaterialized(String) - Method in interface com.rpl.rama.SubSource.Impl
Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...).
explodeMicrobatch(String) - Static method in interface com.rpl.rama.Block
Emits all data for this microbatch source across all partitions of depot
explodeMicrobatch(String) - Method in interface com.rpl.rama.Block.Impl
Emits all data for this microbatch source across all partitions of depot
explodeMicrobatch(String) - Method in interface com.rpl.rama.Case.Impl
Emits all data for this microbatch source across all partitions of depot
explodeMicrobatch(String) - Method in interface com.rpl.rama.SubSource.Impl
Emits all data for this microbatch source across all partitions of depot
Expr - Class in com.rpl.rama
Specifies an expression to be used in an argument position in dataflow code.
Expr(RamaFunction0<R>) - Constructor for class com.rpl.rama.Expr
Constructs an expression with zero arguments
Expr(RamaFunction1<T0, R>, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with one argument
Expr(RamaFunction2<T0, T1, R>, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with two arguments
Expr(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with three arguments
Expr(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with four arguments
Expr(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with five arguments
Expr(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with six arguments
Expr(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R>, Object, Object, Object, Object, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with seven arguments
Expr(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R>, Object, Object, Object, Object, Object, Object, Object, Object) - Constructor for class com.rpl.rama.Expr
Constructs an expression with eight arguments
Expr(NativeAnyArityRamaOperation, Object...) - Constructor for class com.rpl.rama.Expr
Constructs an expression for built-in operation that takes any number of arguments
ExternalDepot - Interface in com.rpl.rama.integration
This interface is used to integrate external queue systems as depots inside Rama.
EXTRACT_VALUE - Static variable in class com.rpl.rama.ops.Ops
Extracts contents of a PState as a value.

F

fetchFrom(int, long, long) - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns the sequence of records between the given range of offsets.
fetchFrom(int, long) - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns a chunk of records starting at the given offset.
filteredList(Path) - Static method in interface com.rpl.rama.Path
Navigates to sublist of elements filtered based on given Path.
filteredList(Path) - Method in interface com.rpl.rama.Path.Impl
Navigates to sublist of elements filtered based on given Path.
filterEqual(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is equal to provided value.
filterEqual(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is equal to provided value.
filterGreaterThan(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is greater than provided value.
filterGreaterThan(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is greater than provided value.
filterGreaterThanOrEqual(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is greater than or equal to provided value.
filterGreaterThanOrEqual(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is greater than or equal to provided value.
filterLessThan(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is less than provided value.
filterLessThan(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is less than provided value.
filterLessThanOrEqual(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is less than or equal to provided value.
filterLessThanOrEqual(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is less than or equal to provided value.
filterNotEqual(Object) - Static method in interface com.rpl.rama.Path
Continues navigation if current value is not equal to provided value.
filterNotEqual(Object) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if current value is not equal to provided value.
filterNotSelected(Path) - Static method in interface com.rpl.rama.Path
Continues navigation if provided path executed on current value navigates to zero values.
filterNotSelected(Path) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if provided path executed on current value navigates to zero values.
filterPred(RamaFunction1<T0, R0>) - Static method in interface com.rpl.rama.Path
Continues navigation if provided function returns true on current value.
filterPred(RamaFunction1<T0, R0>) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if provided function returns true on current value.
filterSelected(Path) - Static method in interface com.rpl.rama.Path
Continues navigation if provided path executed on current value navigates to at least one value.
filterSelected(Path) - Method in interface com.rpl.rama.Path.Impl
Continues navigation if provided path executed on current value navigates to at least one value.
first(Object) - Static method in interface com.rpl.rama.Agg
Aggregates input to the first input seen
FIRST - Static variable in class com.rpl.rama.ops.Ops
Emits first element of input collection or null if it is empty.
first() - Static method in interface com.rpl.rama.Path
Navigates on list to first element if not empty.
first() - Method in interface com.rpl.rama.Path.Impl
Navigates on list to first element if not empty.
fixedKeysSchema(Object...) - Static method in interface com.rpl.rama.PState
Declare schema for map with different schema for each key.
freshBatchSource() - Static method in interface com.rpl.rama.Block
Declares a new batch source within pre-agg portion of a batch block
freshBatchSource() - Method in interface com.rpl.rama.Block.Impl
Declares a new batch source within pre-agg portion of a batch block
freshBatchSource() - Method in interface com.rpl.rama.Case.Impl
Declares a new batch source within pre-agg portion of a batch block
freshBatchSource() - Method in interface com.rpl.rama.SubSource.Impl
Declares a new batch source within pre-agg portion of a batch block

G

gainedLeadership() - Method in interface com.rpl.rama.integration.TaskGlobalObject
This function is called on this object whenever the task on which it lives gains leadership.
genHashingIndexKeys(int) - Static method in class com.rpl.rama.Helpers
Generates a key that hashes to each task in a range of tasks.
genHashingIndexKeys(String, int) - Static method in class com.rpl.rama.Helpers
Generates a key starting with the given prefix that hashes to each task in a range of tasks.
genPStateVar(String) - Static method in class com.rpl.rama.Helpers
Generates a unique PState var with the given prefix
genPStateVar() - Static method in class com.rpl.rama.Helpers
Generates a unique PState var
genVar(String) - Static method in class com.rpl.rama.Helpers
Generates a unique var with the given prefix
genVar() - Static method in class com.rpl.rama.Helpers
Generates a unique var
GET - Static variable in class com.rpl.rama.ops.Ops
Arguments are a collection and a key and emits the value for the key in the collection.
get() - Method in interface com.rpl.rama.ProxyState
Get current value of this object.
getAmt() - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
Number of removed elements
getArgs() - Method in class com.rpl.rama.Expr
 
getBeforeIndex() - Method in class com.rpl.rama.diffs.SequenceInsertDiff
Index where element was inserted
getBeforeIndex() - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
Index where elements were inserted
getBlock() - Method in class com.rpl.rama.SubBatch
 
getDiffs() - Method in class com.rpl.rama.diffs.MultiDiff
Diffs in the order in which they happened
getElem() - Method in class com.rpl.rama.diffs.MultiSetAddDiff
Value added to multi-set
getElem() - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
Value removed to multi-set
getElem() - Method in class com.rpl.rama.diffs.SequenceInsertDiff
Inserted value
getElem() - Method in class com.rpl.rama.diffs.SetAddDiff
Value of object added to set
getElem() - Method in class com.rpl.rama.diffs.SetRemoveDiff
Value of object removed from set
getElems() - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
Inserted elements
getEmits() - Method in class com.rpl.rama.test.MockOutputCollector
Retrieve captured emits in the order in which they happened
getEmitsByStream() - Method in class com.rpl.rama.test.MockOutputCollector
Retrieve captured emits split by stream name.
getFrequencyMillis() - Method in interface com.rpl.rama.integration.TaskGlobalObjectWithTick
Defines the frequency at which TaskGlobalObjectWithTick.tick() is called.
getFromIndex() - Method in class com.rpl.rama.diffs.SequenceChangeDiff
Sequence changed for every index after this index
getFromIndex() - Method in class com.rpl.rama.diffs.SequenceReorderDiff
Index of element before move
getFromKey() - Method in class com.rpl.rama.diffs.KeyChangeDiff
Original value of key
getGeneratedVarPrefix(String) - Static method in class com.rpl.rama.Helpers
Gets prefix string used to generate a var
getIndex() - Method in class com.rpl.rama.diffs.AppendDiff
Index of append, same as size of sequence before the append
getIndex() - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
Index of changed value
getIndex() - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
Starting index where elements were removed
getIndexToDiff() - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
Map of index to diffs for their changed values
getKey() - Method in class com.rpl.rama.diffs.KeyDiff
Key of changed value
getKey() - Method in class com.rpl.rama.diffs.KeyRemoveDiff
Removed key
getKeys() - Method in class com.rpl.rama.diffs.KeysRemoveDiff
Removed keys
getKeyToDiff() - Method in class com.rpl.rama.diffs.KeysDiff
Map of keys to diffs for their values
getMaxAmt() - Method in class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions
 
getMaxAmt() - Method in class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions
 
getModuleInstanceId() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns module instance ID
getModuleInstanceInfo() - Method in interface com.rpl.rama.integration.TaskGlobalContext
Returns information about current module.
getModuleName() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns name of module
getModuleName() - Method in interface com.rpl.rama.RamaModule
Optional method to override the name of the module.
getModuleStatus(String) - Method in interface com.rpl.rama.RamaClusterManager
Get status of a launched module
getNewCount() - Method in class com.rpl.rama.diffs.MultiSetAddDiff
Number of times element appears after adding it
getNewCount() - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
Number of times element appears after removing it
getNewSize() - Method in class com.rpl.rama.diffs.SequenceChangeDiff
Size of sequence after change
getNumPartitions() - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns the number of partitions in the external queue.
getNumTasks() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns number of tasks in module
getNumTasks() - Method in class com.rpl.rama.test.LaunchConfig
 
getNumThreads() - Method in class com.rpl.rama.test.LaunchConfig
 
getNumWorkers() - Method in class com.rpl.rama.test.LaunchConfig
 
getOldCount() - Method in class com.rpl.rama.diffs.MultiSetAddDiff
Number of times element appears before adding it
getOldCount() - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
Number of times element appears before removing it
getOldSize() - Method in class com.rpl.rama.diffs.SequenceChangeDiff
Size of sequence before change
getOldSize() - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
Size of sequence before removes
getOldSize() - Method in class com.rpl.rama.diffs.SequenceInsertDiff
Size of sequence before the insert
getOldSize() - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
Size of sequence before inserts
getOp() - Method in class com.rpl.rama.Expr
 
getOutputs() - Method in class com.rpl.rama.SubBatch
 
getPort() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns port of worker where ModuleInstanceInfo was fetched
getReplicaId() - Method in interface com.rpl.rama.integration.TaskGlobalContext
Returns replica ID of this task thread.
getReplicationFactor() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns replication factor of module
getResource() - Method in class com.rpl.rama.integration.ManagedResource
Constructs the resource using the provided constructor if it doesn't yet exist in the resource map
getSequenceSize() - Method in class com.rpl.rama.diffs.SequenceReorderDiff
Size of sequence
getStreamName() - Method in class com.rpl.rama.test.MockOutputCollector.CapturedEmit
 
getSupervisorId() - Method in class com.rpl.rama.ModuleInstanceInfo
Returns supervisor ID where ModuleInstanceInfo was fetched
getTaskGroup() - Method in interface com.rpl.rama.integration.TaskGlobalContext
Returns set of all task IDs in the task group where this task global is being prepared.
getToIndex() - Method in class com.rpl.rama.diffs.SequenceReorderDiff
New index for element after move
getToKey() - Method in class com.rpl.rama.diffs.KeyChangeDiff
New value of key
getVal() - Method in class com.rpl.rama.diffs.NewValueDiff
New value of object
getValDiff() - Method in class com.rpl.rama.diffs.KeyDiff
Diff of changed value
getValDiff() - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
Diff of changed value
getValue() - Method in class com.rpl.rama.Constant
 
getValues() - Method in class com.rpl.rama.test.MockOutputCollector.CapturedEmit
 
getVarName() - Method in interface com.rpl.rama.integration.TaskGlobalContext
Returns the var name assigned to this object in the module definition.
getVars() - Method in class com.rpl.rama.LoopVars.LoopVarsCollector
 
global() - Method in interface com.rpl.rama.Depot.Declaration
Configures depot to have a single partition.
global() - Method in interface com.rpl.rama.PState.Declaration
Configures PState to have a single partition.
globalPartition() - Static method in interface com.rpl.rama.Block
Changes to task 0
globalPartition(String) - Static method in interface com.rpl.rama.Block
Changes to partition 0 of given depot or PState.
globalPartition() - Method in interface com.rpl.rama.Block.Impl
Changes to task 0
globalPartition(String) - Method in interface com.rpl.rama.Block.Impl
Changes to partition 0 of given depot or PState.
globalPartition() - Method in interface com.rpl.rama.Case.Impl
Changes to task 0
globalPartition(String) - Method in interface com.rpl.rama.Case.Impl
Changes to partition 0 of given depot or PState.
globalPartition() - Method in interface com.rpl.rama.SubSource.Impl
Changes to task 0
globalPartition(String) - Method in interface com.rpl.rama.SubSource.Impl
Changes to partition 0 of given depot or PState.
GREATER_THAN - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on if each argument is greater than the next argument.
GREATER_THAN_OR_EQUAL - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on if each argument is greater than or equal to the next argument.
groupBy(String, Block) - Static method in interface com.rpl.rama.Block
Groups input by one key and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, Block) - Static method in interface com.rpl.rama.Block
Groups input by two keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, Block) - Static method in interface com.rpl.rama.Block
Groups input by three keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, Block) - Static method in interface com.rpl.rama.Block
Groups input by four keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, Block) - Static method in interface com.rpl.rama.Block
Groups input by five keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, String, Block) - Static method in interface com.rpl.rama.Block
Groups input by six keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by one key and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by two keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by three keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by four keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by five keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, String, Block) - Method in interface com.rpl.rama.Block.Impl
Groups input by six keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by one key and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by two keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by three keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by four keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by five keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, String, Block) - Method in interface com.rpl.rama.Case.Impl
Groups input by six keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by one key and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by two keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by three keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by four keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by five keys and performs aggregations in the specified block on each group of data independently.
groupBy(String, String, String, String, String, String, Block) - Method in interface com.rpl.rama.SubSource.Impl
Groups input by six keys and performs aggregations in the specified block on each group of data independently.

H

hashBy(NativeRamaFunction1) - Static method in interface com.rpl.rama.Depot
Depot partitioning based on hashing a value from the data being appended.
hashBy(Class<T>) - Static method in interface com.rpl.rama.Depot
Depot partitioning based on hashing a value from the data being appended.
hashCode() - Method in class com.rpl.rama.diffs.AppendDiff
 
hashCode() - Method in class com.rpl.rama.diffs.DestroyedDiff
 
hashCode() - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
hashCode() - Method in class com.rpl.rama.diffs.KeyDiff
 
hashCode() - Method in class com.rpl.rama.diffs.KeyRemoveDiff
 
hashCode() - Method in class com.rpl.rama.diffs.KeysDiff
 
hashCode() - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
hashCode() - Method in class com.rpl.rama.diffs.MultiDiff
 
hashCode() - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
hashCode() - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
hashCode() - Method in class com.rpl.rama.diffs.NewValueDiff
 
hashCode() - Method in class com.rpl.rama.diffs.ResyncDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SetAddDiff
 
hashCode() - Method in class com.rpl.rama.diffs.SetRemoveDiff
 
hashCode() - Method in class com.rpl.rama.diffs.UnknownDiff
 
hashPartition(Object) - Static method in interface com.rpl.rama.Block
Changes tasks based on hash of argument modulo number of tasks in module.
hashPartition(String, Object) - Static method in interface com.rpl.rama.Block
Changes tasks based on hash of argument modulo number of partitions of given depot or PState.
hashPartition(Object) - Method in interface com.rpl.rama.Block.Impl
Changes tasks based on hash of argument modulo number of tasks in module.
hashPartition(String, Object) - Method in interface com.rpl.rama.Block.Impl
Changes tasks based on hash of argument modulo number of partitions of given depot or PState.
hashPartition(Object) - Method in interface com.rpl.rama.Case.Impl
Changes tasks based on hash of argument modulo number of tasks in module.
hashPartition(String, Object) - Method in interface com.rpl.rama.Case.Impl
Changes tasks based on hash of argument modulo number of partitions of given depot or PState.
hashPartition(Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes tasks based on hash of argument modulo number of tasks in module.
hashPartition(String, Object) - Method in interface com.rpl.rama.SubSource.Impl
Changes tasks based on hash of argument modulo number of partitions of given depot or PState.
Helpers - Class in com.rpl.rama
Collection of static utility methods
Helpers() - Constructor for class com.rpl.rama.Helpers
 
hook(String) - Static method in interface com.rpl.rama.Block
Changes attachment point for subsequent code to node with given anchor
hook(String) - Method in interface com.rpl.rama.Block.Impl
Changes attachment point for subsequent code to node with given anchor
hook(String) - Method in interface com.rpl.rama.Case.Impl
Changes attachment point for subsequent code to node with given anchor
hook(String) - Method in interface com.rpl.rama.SubSource.Impl
Changes attachment point for subsequent code to node with given anchor

I

IDENTITY - Static variable in class com.rpl.rama.ops.Ops
Emits input argument
idFunction(RamaFunction1<T, R>) - Method in interface com.rpl.rama.ops.TopMonotonicAgg
Function to extract ID from data to de-duplicate results
idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration.ManagedResource
 
idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration.TaskThreadManagedResource
 
idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration.WorkerManagedResource
 
ifPath(Path, Path) - Static method in interface com.rpl.rama.Path
Tests condition against current point and continues navigating with thenPath if condition passes.
ifPath(Path, Path, Path) - Static method in interface com.rpl.rama.Path
Tests condition against current point and continues navigating with thenPath if condition passes.
ifPath(Path, Path) - Method in interface com.rpl.rama.Path.Impl
Tests condition against current point and continues navigating with thenPath if condition passes.
ifPath(Path, Path, Path) - Method in interface com.rpl.rama.Path.Impl
Tests condition against current point and continues navigating with thenPath if condition passes.
ifTrue(Object, Block) - Static method in interface com.rpl.rama.Block
If argument is truthy (not null or boolean false), runs the given subblock.
ifTrue(Object, Block, Block) - Static method in interface com.rpl.rama.Block
If argument is truthy (not null or boolean false), runs thenBlock.
ifTrue(Object, Block) - Method in interface com.rpl.rama.Block.Impl
If argument is truthy (not null or boolean false), runs the given subblock.
ifTrue(Object, Block, Block) - Method in interface com.rpl.rama.Block.Impl
If argument is truthy (not null or boolean false), runs thenBlock.
ifTrue(Object, Block) - Method in interface com.rpl.rama.Case.Impl
If argument is truthy (not null or boolean false), runs the given subblock.
ifTrue(Object, Block, Block) - Method in interface com.rpl.rama.Case.Impl
If argument is truthy (not null or boolean false), runs thenBlock.
ifTrue(Object, Block) - Method in interface com.rpl.rama.SubSource.Impl
If argument is truthy (not null or boolean false), runs the given subblock.
ifTrue(Object, Block, Block) - Method in interface com.rpl.rama.SubSource.Impl
If argument is truthy (not null or boolean false), runs thenBlock.
INC - Static variable in class com.rpl.rama.ops.Ops
Emits one more than input value as an Integer
INC_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits one more than input value as a Long
includeEnd() - Method in class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions
 
includeEnd() - Method in interface com.rpl.rama.SortedRangeOptions.Impl
Includes the end key in the results (by default it's excluded).
includeEnd() - Static method in interface com.rpl.rama.SortedRangeOptions
Includes the end key in the results (by default it's excluded).
includeEnd() - Method in class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions
 
includeEnd() - Method in interface com.rpl.rama.SortedRangeToOptions.Impl
Includes the end key in the results (by default it's excluded).
includeEnd() - Static method in interface com.rpl.rama.SortedRangeToOptions
Includes the end key in the results (by default it's excluded).
index(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to the index of a list if it exists.
index(Object) - Static method in interface com.rpl.rama.Path
Navigates to the index of a list if it exists.
indexedVals() - Method in interface com.rpl.rama.Path.Impl
Navigates to pairs of [index, value] for every element of list.
indexedVals() - Static method in interface com.rpl.rama.Path
Navigates to pairs of [index, value] for every element of list.
indexVar(String) - Method in interface com.rpl.rama.ops.LimitAgg
If set also emits the index of each emit to the specified var
init - Variable in class com.rpl.rama.LoopVars.LoopVar
 
initialValue(Object) - Method in interface com.rpl.rama.PState.Declaration
Specifies starting value for PState.
initVal() - Method in interface com.rpl.rama.ops.RamaAccumulatorAgg
Initial value for aggregation
InProcessCluster - Interface in com.rpl.rama.test
Simulates a Rama cluster in a single process.
invoke() - Method in interface com.rpl.rama.ops.RamaFunction0
Computes result of function from input arguments
invoke(T0) - Method in interface com.rpl.rama.ops.RamaFunction1
Computes result of function from input arguments
invoke(T0, T1) - Method in interface com.rpl.rama.ops.RamaFunction2
Computes result of function from input arguments
invoke(T0, T1, T2) - Method in interface com.rpl.rama.ops.RamaFunction3
Computes result of function from input arguments
invoke(T0, T1, T2, T3) - Method in interface com.rpl.rama.ops.RamaFunction4
Computes result of function from input arguments
invoke(T0, T1, T2, T3, T4) - Method in interface com.rpl.rama.ops.RamaFunction5
Computes result of function from input arguments
invoke(T0, T1, T2, T3, T4, T5) - Method in interface com.rpl.rama.ops.RamaFunction6
Computes result of function from input arguments
invoke(T0, T1, T2, T3, T4, T5, T6) - Method in interface com.rpl.rama.ops.RamaFunction7
Computes result of function from input arguments
invoke(T0, T1, T2, T3, T4, T5, T6, T7) - Method in interface com.rpl.rama.ops.RamaFunction8
Computes result of function from input arguments
invoke(OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation0
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation1
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation2
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation3
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, T3, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation4
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, T3, T4, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation5
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, T3, T4, T5, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation6
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, T3, T4, T5, T6, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation7
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(T0, T1, T2, T3, T4, T5, T6, T7, OutputCollector) - Method in interface com.rpl.rama.ops.RamaOperation8
Executes operation and emits results by calling methods on the provided OutputCollector
invoke(Object...) - Method in interface com.rpl.rama.QueryTopologyClient
Blocking invoke.
invokeAsync(Object...) - Method in interface com.rpl.rama.QueryTopologyClient
Non-blocking invoke.
invokeNext(Object) - Method in interface com.rpl.rama.Navigator.Next
 
invokeQuery(String, Object...) - Method in interface com.rpl.rama.Block.Impl
Invokes a colocated or mirror query topology
invokeQuery(String, Object...) - Static method in interface com.rpl.rama.Block
Invokes a colocated or mirror query topology
invokeQuery(String, Object...) - Method in interface com.rpl.rama.Case.Impl
Invokes a colocated or mirror query topology
invokeQuery(String, Object...) - Method in interface com.rpl.rama.SubSource.Impl
Invokes a colocated or mirror query topology
IS_EVEN - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is an even number
IS_INSTANCE_OF - Static variable in class com.rpl.rama.ops.Ops
Arguments are a Class and object and emits boolean true or false on whether the second argument is an instance of the first argument
IS_NEGATIVE - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is a negative number
IS_NOT_NULL - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is not null
IS_NULL - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is null
IS_NUMBER - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is a number
IS_ODD - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is an odd number
IS_POSITIVE - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on whether input argument is a positive number
isCollected(RamaFunction1<T0, R0>) - Method in interface com.rpl.rama.Path.Impl
Stops navigation if given function on collected values returns false.
isCollected(RamaFunction1<T0, R0>) - Static method in interface com.rpl.rama.Path
Stops navigation if given function on collected values returns false.
isEndIncluded() - Method in class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions
 
isEndIncluded() - Method in class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions
 
isFlushRequired() - Method in interface com.rpl.rama.ops.RamaCombinerAgg
Controls memory usage when Rama performs two-phase optimization for combiners.
isGeneratedVar(String) - Static method in class com.rpl.rama.Helpers
Tests if a string has the format of a regular var or PState var
isSizeTracked() - Method in class com.rpl.rama.SubindexOptions.CapturedSubindexOptions
 
isStartIncluded() - Method in class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions
 
isStartIncluded() - Method in class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions
 

K

keepTrue(Object) - Method in interface com.rpl.rama.Block.Impl
Continues dataflow execution only if arg is truthy (not null or boolean false).
keepTrue(Object) - Static method in interface com.rpl.rama.Block
Continues dataflow execution only if arg is truthy (not null or boolean false).
keepTrue(Object) - Method in interface com.rpl.rama.Case.Impl
Continues dataflow execution only if arg is truthy (not null or boolean false).
keepTrue(Object) - Method in interface com.rpl.rama.SubSource.Impl
Continues dataflow execution only if arg is truthy (not null or boolean false).
key(Object...) - Method in interface com.rpl.rama.Path.Impl
Navigates to value for a key in a map.
key(Object...) - Static method in interface com.rpl.rama.Path
Navigates to value for a key in a map.
KeyChangeDiff - Class in com.rpl.rama.diffs
Represents a key in a map changing to a new value.
KeyChangeDiff(Object, Object) - Constructor for class com.rpl.rama.diffs.KeyChangeDiff
 
KeyChangeDiff.Processor - Interface in com.rpl.rama.diffs
 
KeyDiff - Class in com.rpl.rama.diffs
Represents a value for a key changing.
KeyDiff(Object, Diff) - Constructor for class com.rpl.rama.diffs.KeyDiff
 
KeyDiff.Processor - Interface in com.rpl.rama.diffs
 
keyPartitioner(Class<F>) - Method in interface com.rpl.rama.PState.Declaration
Changes the default key partitioner to a custom one.
KeyRemoveDiff - Class in com.rpl.rama.diffs
Represents a key being removed from data structure.
KeyRemoveDiff(Object) - Constructor for class com.rpl.rama.diffs.KeyRemoveDiff
 
KeyRemoveDiff.Processor - Interface in com.rpl.rama.diffs
 
KeysDiff - Class in com.rpl.rama.diffs
Represents changes for values for multiple keys in a data structure.
KeysDiff(Map<Object, Diff>) - Constructor for class com.rpl.rama.diffs.KeysDiff
 
KeysDiff.Processor - Interface in com.rpl.rama.diffs
 
KeysRemoveDiff - Class in com.rpl.rama.diffs
Represents multiple keys being removed from map data structure.
KeysRemoveDiff(Set<Object>) - Constructor for class com.rpl.rama.diffs.KeysRemoveDiff
 
KeysRemoveDiff.Processor - Interface in com.rpl.rama.diffs
 

L

last(Object) - Static method in interface com.rpl.rama.Agg
Aggregates input to the last input seen
LAST - Static variable in class com.rpl.rama.ops.Ops
Emits last element of input collection or null if it is empty.
last() - Method in interface com.rpl.rama.Path.Impl
Navigates on list to last element if not empty.
last() - Static method in interface com.rpl.rama.Path
Navigates on list to last element if not empty.
LaunchConfig - Class in com.rpl.rama.test
Object to specify parallelism settings for modules launched on an InProcessCluster
LaunchConfig(int, int) - Constructor for class com.rpl.rama.test.LaunchConfig
Create LaunchConfig.
launchModule(RamaModule, LaunchConfig) - Method in interface com.rpl.rama.test.InProcessCluster
Launch a module.
LESS_THAN - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on if each argument is less than the next argument.
LESS_THAN_OR_EQUAL - Static variable in class com.rpl.rama.ops.Ops
Emits boolean true or false on if each argument is less than or equal to the next argument.
limitAgg(LimitAgg) - Method in interface com.rpl.rama.Block.Impl
Limits incoming data to a fixed amount according to optional sort options.
limitAgg(LimitAgg) - Static method in interface com.rpl.rama.Block
Limits incoming data to a fixed amount according to optional sort options.
limitAgg(LimitAgg) - Method in interface com.rpl.rama.Case.Impl
Limits incoming data to a fixed amount according to optional sort options.
LimitAgg - Interface in com.rpl.rama.ops
Specifies a limit aggregator for use with limitAgg
limitAgg(LimitAgg) - Method in interface com.rpl.rama.SubSource.Impl
Limits incoming data to a fixed amount according to optional sort options.
list(Object) - Static method in interface com.rpl.rama.Agg
Aggregates all input to a java.util.List data structure.
list(AggOrCompoundAgg...) - Static method in interface com.rpl.rama.CompoundAgg
Specifies a fixed-size list template
listSchema(Class) - Static method in interface com.rpl.rama.PState
Declare a list schema
listSchema(PState.Schema) - Static method in interface com.rpl.rama.PState
Declare a list schema
localClear(String) - Method in interface com.rpl.rama.Block.Impl
Removes all data from the PState partition on current task.
localClear(String) - Static method in interface com.rpl.rama.Block
Removes all data from the PState partition on current task.
localClear(String) - Method in interface com.rpl.rama.Case.Impl
Removes all data from the PState partition on current task.
localClear(String) - Method in interface com.rpl.rama.SubSource.Impl
Removes all data from the PState partition on current task.
localSelect(String, Path) - Method in interface com.rpl.rama.Block.Impl
Navigates into the PState partition on current task using the given Path.
localSelect(String, Path) - Static method in interface com.rpl.rama.Block
Navigates into the PState partition on current task using the given Path.
localSelect(String, Path) - Method in interface com.rpl.rama.Case.Impl
Navigates into the PState partition on current task using the given Path.
localSelect(String, Path) - Method in interface com.rpl.rama.SubSource.Impl
Navigates into the PState partition on current task using the given Path.
localTransform(String, Path) - Method in interface com.rpl.rama.Block.Impl
Executes transform Path on the PState partition on current task.
localTransform(String, Path) - Static method in interface com.rpl.rama.Block
Executes transform Path on the PState partition on current task.
localTransform(String, Path) - Method in interface com.rpl.rama.Case.Impl
Executes transform Path on the PState partition on current task.
localTransform(String, Path) - Method in interface com.rpl.rama.SubSource.Impl
Executes transform Path on the PState partition on current task.
LOG_DEBUG - Static variable in class com.rpl.rama.ops.Ops
Logs at debug level using slf4j Logger.
LOG_ERROR - Static variable in class com.rpl.rama.ops.Ops
Logs at error level using slf4j Logger.
LOG_INFO - Static variable in class com.rpl.rama.ops.Ops
Logs at info level using slf4j Logger.
LOG_TRACE - Static variable in class com.rpl.rama.ops.Ops
Logs at trace level using slf4j Logger.
LOG_WARN - Static variable in class com.rpl.rama.ops.Ops
Logs at warn level using slf4j Logger.
loop(Block) - Method in interface com.rpl.rama.Block.Impl
Creates a dataflow loop with the given body.
loop(Block) - Static method in interface com.rpl.rama.Block
Creates a dataflow loop with the given body.
loop(Block) - Method in interface com.rpl.rama.Case.Impl
Creates a dataflow loop with the given body.
loop(Block) - Method in interface com.rpl.rama.SubSource.Impl
Creates a dataflow loop with the given body.
LoopVar(String, Object) - Constructor for class com.rpl.rama.LoopVars.LoopVar
 
LoopVars - Interface in com.rpl.rama
Declares vars for a loopWithVars call using builder pattern Example: LoopVars.var("*a", 1).var("*b", 2)
LoopVars.Impl - Interface in com.rpl.rama
 
LoopVars.LoopVar - Class in com.rpl.rama
 
LoopVars.LoopVarsCollector - Class in com.rpl.rama
 
LoopVarsCollector(PersistentVector) - Constructor for class com.rpl.rama.LoopVars.LoopVarsCollector
 
loopWithVars(LoopVars, Block) - Method in interface com.rpl.rama.Block.Impl
Creates a dataflow loop with the given vars and body.
loopWithVars(LoopVars, Block) - Static method in interface com.rpl.rama.Block
Creates a dataflow loop with the given vars and body.
loopWithVars(LoopVars, Block) - Method in interface com.rpl.rama.Case.Impl
Creates a dataflow loop with the given vars and body.
loopWithVars(LoopVars, Block) - Method in interface com.rpl.rama.SubSource.Impl
Creates a dataflow loop with the given vars and body.

M

macro(Block) - Method in interface com.rpl.rama.Block.Impl
Inserts all code from given Block into the current callsite.
macro(Block) - Static method in interface com.rpl.rama.Block
Inserts all code from given Block into the current callsite.
macro(Block) - Method in interface com.rpl.rama.Case.Impl
Inserts all code from given Block into the current callsite.
macro(Block) - Method in interface com.rpl.rama.SubSource.Impl
Inserts all code from given Block into the current callsite.
makePrivate() - Method in interface com.rpl.rama.PState.Declaration
Configures PState to only be readable within the declaring topology.
ManagedResource<T> - Class in com.rpl.rama.integration
 
ManagedResource(String, TaskGlobalContext, Callable<T>) - Constructor for class com.rpl.rama.integration.ManagedResource
 
map(Object, Object) - Static method in interface com.rpl.rama.Agg
Aggregates all input to a java.util.Map data structure.
map(Object...) - Static method in interface com.rpl.rama.CompoundAgg
Specifies a map template
mapKey(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to a key in a map if it exists.
mapKey(Object) - Static method in interface com.rpl.rama.Path
Navigates to a key in a map if it exists.
mapKeys() - Method in interface com.rpl.rama.Path.Impl
Navigates to every key of a map.
mapKeys() - Static method in interface com.rpl.rama.Path
Navigates to every key of a map.
mapSchema(Class, Class) - Static method in interface com.rpl.rama.PState
Declare a map schema
mapSchema(Class, PState.Schema) - Static method in interface com.rpl.rama.PState
Declare a map schema
mapVals() - Method in interface com.rpl.rama.Path.Impl
Navigates to every value of a map.
mapVals() - Static method in interface com.rpl.rama.Path
Navigates to every value of a map.
materialize(Object...) - Method in interface com.rpl.rama.Block.Impl
Produces a temporary PState of tuples within a batch block in a microbatch topology.
materialize(Object...) - Static method in interface com.rpl.rama.Block
Produces a temporary PState of tuples within a batch block in a microbatch topology.
materialize(Object...) - Method in interface com.rpl.rama.Case.Impl
Produces a temporary PState of tuples within a batch block in a microbatch topology.
materialize(Object...) - Method in interface com.rpl.rama.SubSource.Impl
Produces a temporary PState of tuples within a batch block in a microbatch topology.
max(Object) - Static method in interface com.rpl.rama.Agg
Computes maximum value from input
MAX - Static variable in class com.rpl.rama.ops.Ops
Emits maximum value of all input arguments
maxAmt(int) - Method in class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions
 
maxAmt(int) - Method in interface com.rpl.rama.SortedRangeFromOptions.Impl
Sets maximum number of elements to include in result (by default reads until the end of structure).
maxAmt(int) - Static method in interface com.rpl.rama.SortedRangeFromOptions
Sets maximum number of elements to include in result (by default reads until the end of structure).
maxAmt(int) - Method in class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions
 
maxAmt(int) - Method in interface com.rpl.rama.SortedRangeToOptions.Impl
Sets maximum number of elements to include in result (by default reads until the end of structure).
maxAmt(int) - Static method in interface com.rpl.rama.SortedRangeToOptions
Sets maximum number of elements to include in result (by default reads until the end of structure).
mergeMap(Object) - Static method in interface com.rpl.rama.Agg
Aggregates input java.util.Maps together into a single java.util.Map by adding all key/value pairs of each input.
microbatch(String) - Method in interface com.rpl.rama.RamaModule.Topologies
MicrobatchSourceOptions - Interface in com.rpl.rama.module
Depot source options for microbatch topologies using builder pattern Microbatch topologies documentation
MicrobatchSourceOptions.Impl - Interface in com.rpl.rama.module
 
MicrobatchTopology - Interface in com.rpl.rama.module
 
min(Object) - Static method in interface com.rpl.rama.Agg
Computes minimum value from input
MIN - Static variable in class com.rpl.rama.ops.Ops
Emits minimum value of all input arguments
MINUS - Static variable in class com.rpl.rama.ops.Ops
Emits result of subtracting all arguments after the first argument from the first argument as an Integer.
MINUS_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits result of subtracting all arguments after the first argument from the first argument as a Long.
MockOutputCollector - Class in com.rpl.rama.test
Helper utility for unit testing a RamaOperation outside the context of a module or Block.
MockOutputCollector() - Constructor for class com.rpl.rama.test.MockOutputCollector
 
MockOutputCollector.CapturedEmit - Class in com.rpl.rama.test
Information about a captured emit
MODULE_INSTANCE_INFO - Static variable in class com.rpl.rama.ops.Ops
Emits ModuleInstanceInfo for module and worker of running event
ModuleInstanceInfo - Class in com.rpl.rama
Information about current module and worker retrievable during topology execution with Ops.MODULE_INSTANCE_INFO
ModuleInstanceInfo(String, String, int, int, String, int) - Constructor for class com.rpl.rama.ModuleInstanceInfo
 
MODULO - Static variable in class com.rpl.rama.ops.Ops
Emits first argument modulo the second argument as an Integer
MODULO_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits first argument modulo the second argument as a Long
MultiDiff - Class in com.rpl.rama.diffs
Change between old and new values is represented by multiple diffs in the order in which they happened.
MultiDiff(List<Diff>) - Constructor for class com.rpl.rama.diffs.MultiDiff
 
MultiDiff.Processor - Interface in com.rpl.rama.diffs
 
multiPath(Path...) - Method in interface com.rpl.rama.Path.Impl
Navigates to each provided path in order, all starting from this point.
multiPath(Path...) - Static method in interface com.rpl.rama.Path
Navigates to each provided path in order, all starting from this point.
multiSet(Object) - Static method in interface com.rpl.rama.Agg
Aggregates input values into a java.util.Map from value to count
MultiSetAddDiff - Class in com.rpl.rama.diffs
Represents a value being added to a multi-set (a map from element to count).
MultiSetAddDiff(Object, int, int) - Constructor for class com.rpl.rama.diffs.MultiSetAddDiff
 
MultiSetAddDiff.Processor - Interface in com.rpl.rama.diffs
 
MultiSetRemoveDiff - Class in com.rpl.rama.diffs
Represents a value being removed from a multi-set (a map from element to count).
MultiSetRemoveDiff(Object, int, int) - Constructor for class com.rpl.rama.diffs.MultiSetRemoveDiff
 
MultiSetRemoveDiff.Processor - Interface in com.rpl.rama.diffs
 
must(Object...) - Method in interface com.rpl.rama.Path.Impl
Navigates to value for a key in a map only if key exists.
must(Object...) - Static method in interface com.rpl.rama.Path
Navigates to value for a key in a map only if key exists.

N

Navigator<T> - Interface in com.rpl.rama
Interface for implementing custom navigators for use in a Path
Navigator.Next - Interface in com.rpl.rama
 
NewValueDiff - Class in com.rpl.rama.diffs
Old value has been replaced by a new value.
NewValueDiff(Object) - Constructor for class com.rpl.rama.diffs.NewValueDiff
 
NewValueDiff.Processor - Interface in com.rpl.rama.diffs
 
NOT - Static variable in class com.rpl.rama.ops.Ops
"not" operator based on whether input is "truthy" (not null or false).
NOT_EQUAL - Static variable in class com.rpl.rama.ops.Ops
Tests whether any arguments are not equal and emits boolean true or false.
nth(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to value for index in a list.
nth(Object) - Static method in interface com.rpl.rama.Path
Navigates to value for index in a list.
nullToList() - Method in interface com.rpl.rama.Path.Impl
Navigates to empty list if currently navigated to null.
nullToList() - Static method in interface com.rpl.rama.Path
Navigates to empty list if currently navigated to null.
nullToSet() - Method in interface com.rpl.rama.Path.Impl
Navigates to empty set if currently navigated to null.
nullToSet() - Static method in interface com.rpl.rama.Path
Navigates to empty set if currently navigated to null.
nullToVal(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to given value if currently navigated to null.
nullToVal(Object) - Static method in interface com.rpl.rama.Path
Navigates to given value if currently navigated to null.
numWorkers(int) - Method in class com.rpl.rama.test.LaunchConfig
Override number of workers for module

O

objectsToDelete(String...) - Method in interface com.rpl.rama.test.UpdateOptions.Impl
Sets expected PStates and depots to be deleted with the module update
objectsToDelete(String...) - Static method in interface com.rpl.rama.test.UpdateOptions
Sets expected PStates and depots to be deleted with the module update
offsetAfterTimestampMillis(int, long) - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns the first offset of the given partition index after the given timestamp.
OffsetAgo - Enum in com.rpl.rama.module
open() - Static method in interface com.rpl.rama.RamaClusterManager
Create a RamaCluster instance using configuration in rama.yaml file on classpath.
open(Map<String, Object>) - Static method in interface com.rpl.rama.RamaClusterManager
Create a RamaCluster instance using provided configuration.
openInternal() - Static method in interface com.rpl.rama.RamaClusterManager
Create a RamaCluster instance using configuration in rama.yaml file on classpath.
openInternal(Map<String, Object>) - Static method in interface com.rpl.rama.RamaClusterManager
Create a RamaCluster instance using provided configuration.
Ops - Class in com.rpl.rama.ops
 
Ops() - Constructor for class com.rpl.rama.ops.Ops
 
or(Object) - Static method in interface com.rpl.rama.Agg
Applies "or" operator to all input.
OR - Static variable in class com.rpl.rama.ops.Ops
"or" operator based on values being "truthy" (not null or false).
originPartition() - Method in interface com.rpl.rama.Block.Impl
Changes back to starting task for a query topology invocation.
originPartition() - Static method in interface com.rpl.rama.Block
Changes back to starting task for a query topology invocation.
originPartition() - Method in interface com.rpl.rama.Case.Impl
Changes back to starting task for a query topology invocation.
originPartition() - Method in interface com.rpl.rama.SubSource.Impl
Changes back to starting task for a query topology invocation.
out(String...) - Method in interface com.rpl.rama.Block.Out
Capture output of previous node into vars.
out(String...) - Method in interface com.rpl.rama.Case.Out
Capture output of previous node into vars.
out(String...) - Method in interface com.rpl.rama.SubSource.Out
Capture output of previous node into vars.
OutputCollector - Interface in com.rpl.rama.ops
Interface for emitting results from custom RamaOperation implementations
outStream(String, String, String...) - Method in interface com.rpl.rama.Block.MultiOutImpl
Capture output of a non-default stream of previous node into vars.
outStream(String, String, String...) - Method in interface com.rpl.rama.Case.MultiOutImpl
Capture output of a non-default stream of previous node into vars.
outStream(String, String, String...) - Method in interface com.rpl.rama.SubSource.MultiOutImpl
Capture output of a non-default stream of previous node into vars.

P

Path - Interface in com.rpl.rama
A Path defines how to navigate to target values in a data structure as a series of steps.
Path.Impl - Interface in com.rpl.rama
 
pathBuilder(RamaFunction0<Path>) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of zero arguments.
pathBuilder(RamaFunction1<T0, Path>, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of one argument.
pathBuilder(RamaFunction2<T0, T1, Path>, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of two arguments.
pathBuilder(RamaFunction3<T0, T1, T2, Path>, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of three arguments.
pathBuilder(RamaFunction4<T0, T1, T2, T3, Path>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of four arguments.
pathBuilder(RamaFunction5<T0, T1, T2, T3, T4, Path>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of five arguments.
pathBuilder(RamaFunction6<T0, T1, T2, T3, T4, T5, Path>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of six arguments.
pathBuilder(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, Path>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of seven arguments.
pathBuilder(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, Path>, Object, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Concatenates a path to the current path constructed with the provided function of eight arguments.
pathBuilder(RamaFunction0<Path>) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of zero arguments.
pathBuilder(RamaFunction1<T0, Path>, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of one argument.
pathBuilder(RamaFunction2<T0, T1, Path>, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of two arguments.
pathBuilder(RamaFunction3<T0, T1, T2, Path>, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of three arguments.
pathBuilder(RamaFunction4<T0, T1, T2, T3, Path>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of four arguments.
pathBuilder(RamaFunction5<T0, T1, T2, T3, T4, Path>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of five arguments.
pathBuilder(RamaFunction6<T0, T1, T2, T3, T4, T5, Path>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of six arguments.
pathBuilder(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, Path>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of seven arguments.
pathBuilder(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, Path>, Object, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Concatenates a path to the current path constructed with the provided function of eight arguments.
pathPartition(String, Path) - Method in interface com.rpl.rama.Block.Impl
Changes to task for given PState containing data for given Path
pathPartition(String, Path) - Static method in interface com.rpl.rama.Block
Changes to task for given PState containing data for given Path
pathPartition(String, Path) - Method in interface com.rpl.rama.Case.Impl
Changes to task for given PState containing data for given Path
pathPartition(String, Path) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task for given PState containing data for given Path
pauseMicrobatchTopology(String, String) - Method in interface com.rpl.rama.test.InProcessCluster
Pauses the specified microbatch topology so it stops processing.
PLUS - Static variable in class com.rpl.rama.ops.Ops
Emits result of adding all input numbers together as an Integer.
PLUS_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits result of adding all input numbers together as a Long.
prepareForTask(int, TaskGlobalContext) - Method in interface com.rpl.rama.integration.TaskGlobalObject
Specializes this object for this particular task ID.
PRINTLN - Static variable in class com.rpl.rama.ops.Ops
Prints all input arguments to stdout
process(Diff.Processor) - Method in class com.rpl.rama.diffs.Diff
 
processAppendDiff(AppendDiff) - Method in interface com.rpl.rama.diffs.AppendDiff.Processor
 
processDestroyedDiff(DestroyedDiff) - Method in interface com.rpl.rama.diffs.DestroyedDiff.Processor
 
processKeyChangeDiff(KeyChangeDiff) - Method in interface com.rpl.rama.diffs.KeyChangeDiff.Processor
 
processKeyDiff(KeyDiff) - Method in interface com.rpl.rama.diffs.KeyDiff.Processor
 
processKeyRemoveDiff(KeyRemoveDiff) - Method in interface com.rpl.rama.diffs.KeyRemoveDiff.Processor
 
processKeysDiff(KeysDiff) - Method in interface com.rpl.rama.diffs.KeysDiff.Processor
 
processKeysRemoveDiff(KeysRemoveDiff) - Method in interface com.rpl.rama.diffs.KeysRemoveDiff.Processor
 
processMultiDiff(MultiDiff) - Method in interface com.rpl.rama.diffs.MultiDiff.Processor
 
processMultiSetAddDiff(MultiSetAddDiff) - Method in interface com.rpl.rama.diffs.MultiSetAddDiff.Processor
 
processMultiSetRemoveDiff(MultiSetRemoveDiff) - Method in interface com.rpl.rama.diffs.MultiSetRemoveDiff.Processor
 
processNewValueDiff(NewValueDiff) - Method in interface com.rpl.rama.diffs.NewValueDiff.Processor
 
processResyncDiff(ResyncDiff) - Method in interface com.rpl.rama.diffs.ResyncDiff.Processor
 
processSequenceChangeDiff(SequenceChangeDiff) - Method in interface com.rpl.rama.diffs.SequenceChangeDiff.Processor
 
processSequenceIndexChangeDiff(SequenceIndexChangeDiff) - Method in interface com.rpl.rama.diffs.SequenceIndexChangeDiff.Processor
 
processSequenceIndexChangesDiff(SequenceIndexChangesDiff) - Method in interface com.rpl.rama.diffs.SequenceIndexChangesDiff.Processor
 
processSequenceIndexRemoveDiff(SequenceIndexRemoveDiff) - Method in interface com.rpl.rama.diffs.SequenceIndexRemoveDiff.Processor
 
processSequenceInsertDiff(SequenceInsertDiff) - Method in interface com.rpl.rama.diffs.SequenceInsertDiff.Processor
 
processSequenceInsertsDiff(SequenceInsertsDiff) - Method in interface com.rpl.rama.diffs.SequenceInsertsDiff.Processor
 
processSequenceReorderDiff(SequenceReorderDiff) - Method in interface com.rpl.rama.diffs.SequenceReorderDiff.Processor
 
processSetAddDiff(SetAddDiff) - Method in interface com.rpl.rama.diffs.SetAddDiff.Processor
 
processSetRemoveDiff(SetRemoveDiff) - Method in interface com.rpl.rama.diffs.SetRemoveDiff.Processor
 
processUnknownDiff(UnknownDiff) - Method in interface com.rpl.rama.diffs.UnknownDiff.Processor
 
proxy(Path) - Method in interface com.rpl.rama.PState
Reactive query of PState with Path that must navigate to exactly one value.
proxy(Object, Path) - Method in interface com.rpl.rama.PState
Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
proxy(Path, ProxyState.Callback<T>) - Method in interface com.rpl.rama.PState
Reactive query of PState with Path that must navigate to exactly one value.
proxy(Object, Path, ProxyState.Callback<T>) - Method in interface com.rpl.rama.PState
Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
proxyAsync(Path) - Method in interface com.rpl.rama.PState
Reactive query of PState with Path that must navigate to exactly one value.
proxyAsync(Object, Path) - Method in interface com.rpl.rama.PState
Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
proxyAsync(Path, ProxyState.Callback<T>) - Method in interface com.rpl.rama.PState
Reactive query of PState with Path that must navigate to exactly one value.
proxyAsync(Object, Path, ProxyState.Callback<T>) - Method in interface com.rpl.rama.PState
Reactive query of PState using explicit partitioning key with Path that must navigate to exactly one value.
ProxyState<T> - Interface in com.rpl.rama
Reactive result of one of PState proxy methods.
ProxyState.Callback<T> - Interface in com.rpl.rama
Interface for specifying callbacks for fine-grained diffs as data changes
pstate(String, Class) - Method in interface com.rpl.rama.module.ETLTopologyBase
Declares a PState owned by this topology.
pstate(String, PState.Schema) - Method in interface com.rpl.rama.module.ETLTopologyBase
Declares a PState owned by this topology.
PState - Interface in com.rpl.rama
Interface for thread-safe PState clients.
PState.Declaration - Interface in com.rpl.rama
Builder-style interface for specifying options when declaring a PState in a module
PState.Schema - Interface in com.rpl.rama
Builder-style interface for declaring options on PState schemas
putCollected(Object) - Method in interface com.rpl.rama.Path.Impl
Adds given value to collected values.
putCollected(Object) - Static method in interface com.rpl.rama.Path
Adds given value to collected values.

Q

query(String, String...) - Method in interface com.rpl.rama.RamaModule.Topologies
Defines a query topology.
QueryTopologyClient<T> - Interface in com.rpl.rama
Client for invoking a query topology.

R

RamaAccumulatorAgg<V> - Interface in com.rpl.rama.ops
Base interface for custom accumulator implementations.
RamaAccumulatorAgg0<V> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of zero arguments.
RamaAccumulatorAgg1<V,T0> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of one argument.
RamaAccumulatorAgg2<V,T0,T1> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of two arguments.
RamaAccumulatorAgg3<V,T0,T1,T2> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of three arguments.
RamaAccumulatorAgg4<V,T0,T1,T2,T3> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of four arguments.
RamaAccumulatorAgg5<V,T0,T1,T2,T3,T4> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of five arguments.
RamaAccumulatorAgg6<V,T0,T1,T2,T3,T4,T5> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of six arguments.
RamaAccumulatorAgg7<V,T0,T1,T2,T3,T4,T5,T6> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of seven arguments.
RamaAccumulatorAgg8<V,T0,T1,T2,T3,T4,T5,T6,T7> - Interface in com.rpl.rama.ops
Interface for custom accumulator implementations of eight arguments.
RamaClusterManager - Interface in com.rpl.rama
API for connecting to a Rama cluster and getting clients for depots, PStates, and query topologies.
RamaCombinerAgg<T> - Interface in com.rpl.rama.ops
Base interface for custom combiner implementations.
RamaCompileException - Exception in com.rpl.rama
 
RamaCompileException(String) - Constructor for exception com.rpl.rama.RamaCompileException
 
RamaCompileException(String, Exception) - Constructor for exception com.rpl.rama.RamaCompileException
 
RamaCustomSerialization<T> - Interface in com.rpl.rama
Interface for implementing serialization for custom types.
RamaFunction - Interface in com.rpl.rama.ops
Base interface for custom function implementations.
RamaFunction0<R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of zero arguments
RamaFunction1<T0,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of one argument
RamaFunction2<T0,T1,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of two arguments
RamaFunction3<T0,T1,T2,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of three arguments
RamaFunction4<T0,T1,T2,T3,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of four arguments
RamaFunction5<T0,T1,T2,T3,T4,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of five arguments
RamaFunction6<T0,T1,T2,T3,T4,T5,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of six arguments
RamaFunction7<T0,T1,T2,T3,T4,T5,T6,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of seven arguments
RamaFunction8<T0,T1,T2,T3,T4,T5,T6,T7,R> - Interface in com.rpl.rama.ops
Interface for custom function implementations of eight arguments
RamaModule - Interface in com.rpl.rama
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 - Interface in com.rpl.rama
Used to define depots, global objects, and module dependencies in a module definition.
RamaModule.Topologies - Interface in com.rpl.rama
Used to define ETL and query topologies in a module definition.
RamaOperation - Interface in com.rpl.rama.ops
Base interface for custom operation implementations.
RamaOperation0 - Interface in com.rpl.rama.ops
Interface for custom operation implementation of zero arguments.
RamaOperation1<T0> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of one argument.
RamaOperation2<T0,T1> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of two arguments.
RamaOperation3<T0,T1,T2> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of three arguments.
RamaOperation4<T0,T1,T2,T3> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of four arguments.
RamaOperation5<T0,T1,T2,T3,T4> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of five arguments.
RamaOperation6<T0,T1,T2,T3,T4,T5> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of six arguments.
RamaOperation7<T0,T1,T2,T3,T4,T5,T6> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of seven arguments.
RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7> - Interface in com.rpl.rama.ops
Interface for custom operation implementation of eight arguments.
RamaSerializable - Interface in com.rpl.rama
Objects implementing this interface will be serialized by Rama across disk or network boundaries using Java serialization.
random() - Static method in interface com.rpl.rama.Depot
Depot partitioning where each append goes to a random partition
RANGE - Static variable in class com.rpl.rama.ops.Ops
Arguments are a starting integer (inclusive) and an end integer (exclusive) and emits each integer between than range individually Example: Block.each(Ops.RANGE, 10, 20).out("*i")
resumeMicrobatchTopology(String, String) - Method in interface com.rpl.rama.test.InProcessCluster
Resumes a paused microbatch topology so it starts processing again.
ResyncDiff - Class in com.rpl.rama.diffs
Represents value being re-queried from scratch.
ResyncDiff() - Constructor for class com.rpl.rama.diffs.ResyncDiff
 
ResyncDiff.Processor - Interface in com.rpl.rama.diffs
 
retryAllAfter() - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Retry failed records and all records after in the same depot partition
retryAllAfter() - Static method in interface com.rpl.rama.module.StreamSourceOptions
Retry failed records and all records after in the same depot partition
retryNone() - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Never retry a failed depot record
retryNone() - Static method in interface com.rpl.rama.module.StreamSourceOptions
Never retry a failed depot record
reverse() - Method in interface com.rpl.rama.ops.LimitAgg
Used in conjunction with LimitAgg.sort(java.lang.String...) to reverse the input
RocksDBOptionsBuilder - Interface in com.rpl.rama
Rama uses RocksDB in the underlying implementation for PStates that have a map in the top-level schema.

S

select(Object, Path) - Method in interface com.rpl.rama.Block.Impl
Changes to task for given PState containing data for given Path and then performs a localSelect.
select(Object, Path) - Static method in interface com.rpl.rama.Block
Changes to task for given PState containing data for given Path and then performs a localSelect.
select(Object, Path) - Method in interface com.rpl.rama.Case.Impl
Changes to task for given PState containing data for given Path and then performs a localSelect.
select(T, Navigator.Next) - Method in interface com.rpl.rama.Navigator
Implements codepath for select calls.
select(Path) - Method in interface com.rpl.rama.PState
Queries PState with Path.
select(Object, Path) - Method in interface com.rpl.rama.PState
Queries PState with Path using explicit partitioning key.
select(Object, Path) - Method in interface com.rpl.rama.SubSource.Impl
Changes to task for given PState containing data for given Path and then performs a localSelect.
select(Path) - Method in interface com.rpl.rama.test.TestPState
Queries PState with Path.
selectAsync(Path) - Method in interface com.rpl.rama.PState
Queries PState with Path.
selectAsync(Object, Path) - Method in interface com.rpl.rama.PState
Queries PState with Path using explicit partitioning key.
selectOne(Path) - Method in interface com.rpl.rama.PState
Queries PState with Path that must navigate to exactly one value.
selectOne(Object, Path) - Method in interface com.rpl.rama.PState
Queries PState using explicit partitioning key with Path that must navigate to exactly one value.
selectOne(Path) - Method in interface com.rpl.rama.test.TestPState
Queries PState with Path that must navigate to exactly one value.
selectOneAsync(Path) - Method in interface com.rpl.rama.PState
Queries PState with Path that must navigate to exactly one value.
selectOneAsync(Object, Path) - Method in interface com.rpl.rama.PState
Queries PState using explicit partitioning key with Path that must navigate to exactly one value.
SequenceChangeDiff - Class in com.rpl.rama.diffs
Represents unknown change to a sequence starting from a particular index.
SequenceChangeDiff(int, int, int) - Constructor for class com.rpl.rama.diffs.SequenceChangeDiff
 
SequenceChangeDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceIndexChangeDiff - Class in com.rpl.rama.diffs
Represents a value for an index of a sequence changing.
SequenceIndexChangeDiff(int, Diff) - Constructor for class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
SequenceIndexChangeDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceIndexChangesDiff - Class in com.rpl.rama.diffs
Represents changes for values for multiple indexes in a sequence.
SequenceIndexChangesDiff(Map<Integer, Diff>) - Constructor for class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
SequenceIndexChangesDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceIndexRemoveDiff - Class in com.rpl.rama.diffs
Represents one or more values being removed starting at some index in a sequence.
SequenceIndexRemoveDiff(int, int, int) - Constructor for class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
SequenceIndexRemoveDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceInsertDiff - Class in com.rpl.rama.diffs
Represents a value being inserted at some index in a sequence.
SequenceInsertDiff(int, Object, int) - Constructor for class com.rpl.rama.diffs.SequenceInsertDiff
 
SequenceInsertDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceInsertsDiff - Class in com.rpl.rama.diffs
Represents multiple values being inserted at some index in a sequence.
SequenceInsertsDiff(int, List<Object>, int) - Constructor for class com.rpl.rama.diffs.SequenceInsertsDiff
 
SequenceInsertsDiff.Processor - Interface in com.rpl.rama.diffs
 
SequenceReorderDiff - Class in com.rpl.rama.diffs
Represents a value in a sequence being moved from one index to another, shifting other values to new indexes in the process.
SequenceReorderDiff(int, int, int) - Constructor for class com.rpl.rama.diffs.SequenceReorderDiff
 
SequenceReorderDiff.Processor - Interface in com.rpl.rama.diffs
 
serialize(T, DataOutput) - Method in interface com.rpl.rama.RamaCustomSerialization
Serializes an object
set(Object) - Static method in interface com.rpl.rama.Agg
Aggregates all input to a java.util.Set data structure.
SetAddDiff - Class in com.rpl.rama.diffs
Represents a value being added to a set.
SetAddDiff(Object) - Constructor for class com.rpl.rama.diffs.SetAddDiff
 
SetAddDiff.Processor - Interface in com.rpl.rama.diffs
 
setElem(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to element of set if it exists.
setElem(Object) - Static method in interface com.rpl.rama.Path
Navigates to element of set if it exists.
setOptions(String, Options) - Method in interface com.rpl.rama.RocksDBOptionsBuilder
 
setRemove(Object) - Static method in interface com.rpl.rama.Agg
Aggregates to "void" value for the given java.util.Set element.
SetRemoveDiff - Class in com.rpl.rama.diffs
Represents a value being removed from a set.
SetRemoveDiff(Object) - Constructor for class com.rpl.rama.diffs.SetRemoveDiff
 
SetRemoveDiff.Processor - Interface in com.rpl.rama.diffs
 
setSchema(Class) - Static method in interface com.rpl.rama.PState
Declare a set schema
shufflePartition() - Method in interface com.rpl.rama.Block.Impl
Changes to a random task using random round-robin algorithm.
shufflePartition() - Static method in interface com.rpl.rama.Block
Changes to a random task using random round-robin algorithm.
shufflePartition() - Method in interface com.rpl.rama.Case.Impl
Changes to a random task using random round-robin algorithm.
shufflePartition() - Method in interface com.rpl.rama.SubSource.Impl
Changes to a random task using random round-robin algorithm.
SIZE - Static variable in class com.rpl.rama.ops.Ops
Emits size of input collection as an Integer
sort(String...) - Method in interface com.rpl.rama.ops.LimitAgg
Sort input for aggregation on values of given vars
sortedMapRange(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map of all elements in that map between a range of keys.
sortedMapRange(Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map of all elements in that map between a range of keys, with options to change inclusive/exclusive status of start and end keys.
sortedMapRange(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map of all elements in that map between a range of keys.
sortedMapRange(Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map of all elements in that map between a range of keys, with options to change inclusive/exclusive status of start and end keys.
sortedMapRangeFrom(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map of all elements in that map after a key.
sortedMapRangeFrom(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map starting from a specified key, with options to read a fixed number of elements or configure whether start key is inclusive or exclusive.
sortedMapRangeFrom(Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map of all elements in that map after a key.
sortedMapRangeFrom(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map starting from a specified key, with options to read a fixed number of elements or configure whether start key is inclusive or exclusive.
sortedMapRangeTo(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map of all values in that map up to a key.
sortedMapRangeTo(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted map to a sorted map up to a specified key, with options to read a fixed number of elements or configure whether end key is inclusive or exclusive.
sortedMapRangeTo(Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map of all values in that map up to a key.
sortedMapRangeTo(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted map to a sorted map up to a specified key, with options to read a fixed number of elements or configure whether end key is inclusive or exclusive.
SortedRangeFromOptions - Interface in com.rpl.rama
SortedRangeFromOptions.CapturedSortedRangeFromOptions - Class in com.rpl.rama
 
SortedRangeFromOptions.Impl - Interface in com.rpl.rama
 
SortedRangeOptions - Interface in com.rpl.rama
SortedRangeOptions.CapturedSortedRangeOptions - Class in com.rpl.rama
 
SortedRangeOptions.Impl - Interface in com.rpl.rama
 
SortedRangeToOptions - Interface in com.rpl.rama
SortedRangeToOptions.CapturedSortedRangeToOptions - Class in com.rpl.rama
 
SortedRangeToOptions.Impl - Interface in com.rpl.rama
 
sortedSetRange(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set of all values in that set between a range.
sortedSetRange(Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set of all values in that set between a range, with options to change inclusive/exclusive status of start and end elements.
sortedSetRange(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set of all values in that set between a range.
sortedSetRange(Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set of all values in that set between a range, with options to change inclusive/exclusive status of start and end elements.
sortedSetRangeFrom(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set of all values in that set after an element.
sortedSetRangeFrom(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set starting from a specified element, with options to read a fixed number of elements or configure whether start element is inclusive or exclusive.
sortedSetRangeFrom(Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set of all values in that set after an element.
sortedSetRangeFrom(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set starting from a specified element, with options to read a fixed number of elements or configure whether start element is inclusive or exclusive.
sortedSetRangeTo(Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set of all values in that set up to an element.
sortedSetRangeTo(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates on a sorted set to a sorted set up to a specified element, with options to read a fixed number of elements or configure whether end element is inclusive or exclusive.
sortedSetRangeTo(Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set of all values in that set up to an element.
sortedSetRangeTo(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates on a sorted set to a sorted set up to a specified element, with options to read a fixed number of elements or configure whether end element is inclusive or exclusive.
sortValFunction(RamaFunction1<T, R>) - Method in interface com.rpl.rama.ops.TopMonotonicAgg
Function to extract from data the value to sort with for aggregation
source(String) - Method in interface com.rpl.rama.module.ETLTopologyBase
Add depot source to topology
source(String, T) - Method in interface com.rpl.rama.module.ETLTopologyBase
Add depot source with specified options to topology
startFromBeginning() - Method in interface com.rpl.rama.module.MicrobatchSourceOptions.Impl
Start processing from beginning of depot partition.
startFromBeginning() - Static method in interface com.rpl.rama.module.MicrobatchSourceOptions
Start processing from beginning of depot partition.
startFromBeginning() - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Start processing from beginning of depot partition.
startFromBeginning() - Static method in interface com.rpl.rama.module.StreamSourceOptions
Start processing from beginning of depot partition.
startFromOffsetAfterTimestamp(long) - Method in interface com.rpl.rama.module.MicrobatchSourceOptions.Impl
Start processing each depot partition from a point in the past.
startFromOffsetAfterTimestamp(long) - Static method in interface com.rpl.rama.module.MicrobatchSourceOptions
Start processing each depot partition from a point in the past.
startFromOffsetAfterTimestamp(long) - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Start processing each depot partition from a point in the past.
startFromOffsetAfterTimestamp(long) - Static method in interface com.rpl.rama.module.StreamSourceOptions
Start processing each depot partition from a point in the past.
startFromOffsetAgo(long, OffsetAgo) - Method in interface com.rpl.rama.module.MicrobatchSourceOptions.Impl
Start processing each depot partition from a point in the past.
startFromOffsetAgo(long, OffsetAgo) - Static method in interface com.rpl.rama.module.MicrobatchSourceOptions
Start processing each depot partition from a point in the past.
startFromOffsetAgo(long, OffsetAgo) - Method in interface com.rpl.rama.module.StreamSourceOptions.Impl
Start processing each depot partition from a point in the past.
startFromOffsetAgo(long, OffsetAgo) - Static method in interface com.rpl.rama.module.StreamSourceOptions
Start processing each depot partition from a point in the past.
startOffset(int) - Method in interface com.rpl.rama.integration.ExternalDepot
Asynchronously returns the start offset of the given partition index (inclusive).
staticData(List<Object>) - Static method in class com.rpl.rama.SubBatch
Create a subbatch that emits the provided data.
stay() - Method in interface com.rpl.rama.Path.Impl
No-op that stays navigated at current point.
stay() - Static method in interface com.rpl.rama.Path
No-op that stays navigated at current point.
stop() - Method in interface com.rpl.rama.Path.Impl
Stops current branch of navigation.
stop() - Static method in interface com.rpl.rama.Path
Stops current branch of navigation.
stream(String) - Method in interface com.rpl.rama.RamaModule.Topologies
Defines a stream topology.
StreamSourceOptions - Interface in com.rpl.rama.module
Depot source options for stream topologies using builder pattern Stream topologies documentation
StreamSourceOptions.Impl - Interface in com.rpl.rama.module
 
StreamTopology - Interface in com.rpl.rama.module
 
subBatch(SubBatch) - Method in interface com.rpl.rama.Block.Impl
Use specified SubBatch as a batch source in a batch block.
subBatch(SubBatch) - Static method in interface com.rpl.rama.Block
Use specified SubBatch as a batch source in a batch block.
subBatch(SubBatch) - Method in interface com.rpl.rama.Case.Impl
Use specified SubBatch as a batch source in a batch block.
SubBatch - Class in com.rpl.rama
Represents a subbatch for use with subBatch in a batch block
SubBatch(Block, String...) - Constructor for class com.rpl.rama.SubBatch
Create a subbatch with the given code and specified output vars
subBatch(SubBatch) - Method in interface com.rpl.rama.SubSource.Impl
Use specified SubBatch as a batch source in a batch block.
subindexed() - Method in interface com.rpl.rama.PState.Schema
Declare this data structure as subindexed.
subindexed(SubindexOptions) - Method in interface com.rpl.rama.PState.Schema
Declare this data structure as subindexed with the given options.
SubindexOptions - Interface in com.rpl.rama
Interface for declaring options on a subindexed PState schema
SubindexOptions.CapturedSubindexOptions - Class in com.rpl.rama
 
SubindexOptions.Impl - Interface in com.rpl.rama
 
sublist(Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to sublist bounded by two indexes.
sublist(Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to sublist bounded by two indexes.
sublistDynamic(RamaFunction1<T0, R0>, RamaFunction2<T1, T2, R1>) - Method in interface com.rpl.rama.Path.Impl
Navigates to sublist bounded by indexes chosen by functions.
sublistDynamic(RamaFunction1<T0, R0>, RamaFunction2<T1, T2, R1>) - Static method in interface com.rpl.rama.Path
Navigates to sublist bounded by indexes chosen by functions.
subMap(Object...) - Method in interface com.rpl.rama.Path.Impl
Navigates to a map containing subset of keys/values of starting map.
subMap(Object...) - Static method in interface com.rpl.rama.Path
Navigates to a map containing subset of keys/values of starting map.
subselect(Path) - Method in interface com.rpl.rama.Path.Impl
Navigates to list of values navigated by provided path.
subselect(Path) - Static method in interface com.rpl.rama.Path
Navigates to list of values navigated by provided path.
subset(Object...) - Method in interface com.rpl.rama.Path.Impl
Navigates to subset of starting set with given elements.
subset(Object...) - Static method in interface com.rpl.rama.Path
Navigates to subset of starting set with given elements.
subSource(Object, SubSource...) - Method in interface com.rpl.rama.Block.Impl
Conditionally dispatch code based on type of input object
subSource(Object, SubSource...) - Static method in interface com.rpl.rama.Block
Conditionally dispatch code based on type of input object
subSource(Object, SubSource...) - Method in interface com.rpl.rama.Case.Impl
Conditionally dispatch code based on type of input object
SubSource - Interface in com.rpl.rama
subSource(Object, SubSource...) - Method in interface com.rpl.rama.SubSource.Impl
Conditionally dispatch code based on type of input object
SubSource.Impl - Interface in com.rpl.rama
 
SubSource.MultiOutImpl - Interface in com.rpl.rama
 
SubSource.Out - Interface in com.rpl.rama
 
SubSource.OutImpl - Interface in com.rpl.rama
 
sum(Object) - Static method in interface com.rpl.rama.Agg
Sums input values into a java.lang.Long
SUM - Static variable in class com.rpl.rama.ops.Ops
Emits sum of all numbers in input list as an Integer.
SUM_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits sum of all numbers in input list as a Long.

T

targetType() - Method in interface com.rpl.rama.RamaCustomSerialization
Base type targetted by this serializer.
TaskGlobalContext - Interface in com.rpl.rama.integration
Provides contextual information for TaskGlobalObject.prepareForTask(int, TaskGlobalContext).
TaskGlobalObject - Interface in com.rpl.rama.integration
Objects implementing this interface that are provided to RamaModule.Setup.declareObject(String, Object) can specialize their implementation per task.
TaskGlobalObjectWithTick - Interface in com.rpl.rama.integration
Defines a task global object that will have TaskGlobalObjectWithTick.tick() called at a regular frequency.
TaskThreadManagedResource<T> - Class in com.rpl.rama.integration
Used for sharing resources across tasks in a task thread
TaskThreadManagedResource(String, TaskGlobalContext, Callable<T>) - Constructor for class com.rpl.rama.integration.TaskThreadManagedResource
 
term(RamaFunction1<T0, R0>) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of one argument.
term(RamaFunction2<T0, T1, R0>, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of two arguments.
term(RamaFunction3<T0, T1, T2, R0>, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of three arguments.
term(RamaFunction4<T0, T1, T2, T3, R0>, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of four arguments.
term(RamaFunction5<T0, T1, T2, T3, T4, R0>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of five arguments.
term(RamaFunction6<T0, T1, T2, T3, T4, T5, R0>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of six arguments.
term(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R0>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of seven arguments.
term(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R0>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that updates navigated value with the provided function of eight arguments.
term(RamaFunction1<T0, R0>) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of one argument.
term(RamaFunction2<T0, T1, R0>, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of two arguments.
term(RamaFunction3<T0, T1, T2, R0>, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of three arguments.
term(RamaFunction4<T0, T1, T2, T3, R0>, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of four arguments.
term(RamaFunction5<T0, T1, T2, T3, T4, R0>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of five arguments.
term(RamaFunction6<T0, T1, T2, T3, T4, T5, R0>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of six arguments.
term(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R0>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of seven arguments.
term(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R0>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that updates navigated value with the provided function of eight arguments.
termVal(Object) - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that overrides navigated value to provided value
termVal(Object) - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that overrides navigated value to provided value
termVoid() - Method in interface com.rpl.rama.Path.Impl
Terminal point of a transform path that sets navigated value to void, causing it to be removed.
termVoid() - Static method in interface com.rpl.rama.Path
Terminal point of a transform path that sets navigated value to void, causing it to be removed.
TestPState - Interface in com.rpl.rama.test
tick() - Method in interface com.rpl.rama.integration.TaskGlobalObjectWithTick
Implement this method to define desired behavior on each tick.
TIMES - Static variable in class com.rpl.rama.ops.Ops
Emits result of multiplying all input numbers together as an Integer.
TIMES_LONG - Static variable in class com.rpl.rama.ops.Ops
Emits result of multiplying all input numbers together as a Long.
TO_STRING - Static variable in class com.rpl.rama.ops.Ops
Emits result of converting all input arguments to strings and concatenating them together
topMonotonic(int, String) - Static method in interface com.rpl.rama.Agg
Aggregates input into a list of top elements.
TopMonotonicAgg - Interface in com.rpl.rama.ops
Builder-style object for customizing options to a call to Agg.topMonotonic(int, java.lang.String)
toString() - Method in class com.rpl.rama.diffs.AppendDiff
 
toString() - Method in class com.rpl.rama.diffs.DestroyedDiff
 
toString() - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
toString() - Method in class com.rpl.rama.diffs.KeyDiff
 
toString() - Method in class com.rpl.rama.diffs.KeyRemoveDiff
 
toString() - Method in class com.rpl.rama.diffs.KeysDiff
 
toString() - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
toString() - Method in class com.rpl.rama.diffs.MultiDiff
 
toString() - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
toString() - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
toString() - Method in class com.rpl.rama.diffs.NewValueDiff
 
toString() - Method in class com.rpl.rama.diffs.ResyncDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
toString() - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
toString() - Method in class com.rpl.rama.diffs.SetAddDiff
 
toString() - Method in class com.rpl.rama.diffs.SetRemoveDiff
 
toString() - Method in class com.rpl.rama.diffs.UnknownDiff
 
transform(T, Navigator.Next) - Method in interface com.rpl.rama.Navigator
Implements codepath for transform calls.
transform(Path) - Method in interface com.rpl.rama.test.TestPState
Transforms PState with Path.
transformed(Path) - Method in interface com.rpl.rama.Path.Impl
Navigates to transformation of current value with given path.
transformed(Path) - Static method in interface com.rpl.rama.Path
Navigates to transformation of current value with given path.
TUPLE - Static variable in class com.rpl.rama.ops.Ops
Combines all input arguments into a List Example: Block.each(Ops.TUPLE, 1, 2, 3).out("*tuple")

U

unhandled() - Method in interface com.rpl.rama.diffs.Diff.Processor
 
unify(String, String, String...) - Method in interface com.rpl.rama.Block.Impl
Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes.
unify(String, String, String...) - Static method in interface com.rpl.rama.Block
Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes.
unify(String, String, String...) - Method in interface com.rpl.rama.Case.Impl
Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes.
unify(String, String, String...) - Method in interface com.rpl.rama.SubSource.Impl
Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes.
UnknownDiff - Class in com.rpl.rama.diffs
Change between old and new values is unknown.
UnknownDiff() - Constructor for class com.rpl.rama.diffs.UnknownDiff
 
UnknownDiff.Processor - Interface in com.rpl.rama.diffs
 
updateModule(RamaModule) - Method in interface com.rpl.rama.test.InProcessCluster
Update a module to a new version.
updateModule(RamaModule, UpdateOptions) - Method in interface com.rpl.rama.test.InProcessCluster
Update a module to a new version.
UpdateOptions - Interface in com.rpl.rama.test
UpdateOptions.Impl - Interface in com.rpl.rama.test
 

V

value - Variable in enum com.rpl.rama.module.OffsetAgo
 
valueOf(String) - Static method in enum com.rpl.rama.AckLevel
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.rpl.rama.module.OffsetAgo
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.rpl.rama.AckLevel
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.rpl.rama.module.OffsetAgo
Returns an array containing the constants of this enum type, in the order they are declared.
var(String, Object) - Method in interface com.rpl.rama.LoopVars.Impl
Declare a var with initial value for first iteration of loop
var - Variable in class com.rpl.rama.LoopVars.LoopVar
 
var(String, Object) - Method in class com.rpl.rama.LoopVars.LoopVarsCollector
 
var(String, Object) - Static method in interface com.rpl.rama.LoopVars
Declare a var with initial value for first iteration of loop
view(RamaFunction1<T0, R0>) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value.
view(RamaFunction2<T0, T1, R0>, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction3<T0, T1, T2, R0>, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction4<T0, T1, T2, T3, R0>, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction5<T0, T1, T2, T3, T4, R0>, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction6<T0, T1, T2, T3, T4, T5, R0>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R0>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R0>, Object, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama.Path.Impl
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction1<T0, R0>) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value.
view(RamaFunction2<T0, T1, R0>, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction3<T0, T1, T2, R0>, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction4<T0, T1, T2, T3, R0>, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction5<T0, T1, T2, T3, T4, R0>, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction6<T0, T1, T2, T3, T4, T5, R0>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction7<T0, T1, T2, T3, T4, T5, T6, R0>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
view(RamaFunction8<T0, T1, T2, T3, T4, T5, T6, T7, R0>, Object, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama.Path
Navigates to result of applying given function to current value and provided arguments.
VOID - Static variable in interface com.rpl.rama.Navigator
 
voided() - Static method in interface com.rpl.rama.Agg
Aggregates to "void" value.
voidSetElem() - Method in interface com.rpl.rama.Path.Impl
Navigates to void element of set.
voidSetElem() - Static method in interface com.rpl.rama.Path
Navigates to void element of set.

W

waitForMicrobatchProcessedCount(String, String, int) - Method in interface com.rpl.rama.test.InProcessCluster
Block until specified microbatch topology has finished processing at least the specified number of depot records.
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.Diff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.KeyChangeDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.KeysDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.KeysRemoveDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.MultiDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.MultiSetAddDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.MultiSetRemoveDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceChangeDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceIndexChangeDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceIndexChangesDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceIndexRemoveDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceInsertDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceInsertsDiff
 
walkExpanded(RamaFunction1) - Method in class com.rpl.rama.diffs.SequenceReorderDiff
 
withoutSizeTracking() - Method in class com.rpl.rama.SubindexOptions.CapturedSubindexOptions
 
withoutSizeTracking() - Method in interface com.rpl.rama.SubindexOptions.Impl
Disable automatic size tracking on this subindexed data structure.
withoutSizeTracking() - Static method in interface com.rpl.rama.SubindexOptions
Disable automatic size tracking on this subindexed data structure.
WorkerManagedResource<T> - Class in com.rpl.rama.integration
Used for sharing resources across tasks in a worker
WorkerManagedResource(String, TaskGlobalContext, Callable<T>) - Constructor for class com.rpl.rama.integration.WorkerManagedResource
 

Y

yieldIfOvertime() - Method in interface com.rpl.rama.Block.Impl
Yield the task thread if current event is using too much time.
yieldIfOvertime() - Static method in interface com.rpl.rama.Block
Yield the task thread if current event is using too much time.
yieldIfOvertime() - Method in interface com.rpl.rama.Case.Impl
Yield the task thread if current event is using too much time.
yieldIfOvertime() - Method in interface com.rpl.rama.SubSource.Impl
Yield the task thread if current event is using too much time.

Z

zeroVal() - Method in interface com.rpl.rama.ops.RamaCombinerAgg
Returns result value if there is no input
A B C D E F G H I K L M N O P Q R S T U V W Y Z 
Skip navigation links