A

accumulate(V) - Method in interface com.rpl.rama.ops. [RamaAccumulatorAgg0](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg0.html "interface in com.rpl.rama.ops"/index.html)

Combine current aggregated value with new input to produce new aggregated value

accumulate(V, T0) - Method in interface com.rpl.rama.ops. [RamaAccumulatorAgg1](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg1.html "interface in com.rpl.rama.ops"/index.html)

Combine current aggregated value with new input to produce new aggregated value

accumulate(V, T0, T1) - Method in interface com.rpl.rama.ops. [RamaAccumulatorAgg2](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg2.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg3.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg4.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg5.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg6.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg7.html "interface in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg8.html "interface in com.rpl.rama.ops"/index.html)

Combine current aggregated value with new input to produce new aggregated value

accumulator(RamaAccumulatorAgg0) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom accumulator of zero arguments as an aggregator.

accumulator(RamaAccumulatorAgg1, Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom accumulator of one argument as an aggregator.

accumulator(RamaAccumulatorAgg2, Object, Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom accumulator of two arguments as an aggregator.

accumulator(RamaAccumulatorAgg3, Object, Object, Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom accumulator of three arguments as an aggregator.

accumulator(RamaAccumulatorAgg4, Object, Object, Object, Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom accumulator of eight arguments as an aggregator.

ACK - Enum constant in enum class com.rpl.rama. [AckLevel](/content/javadoc/com/rpl/rama/AckLevel.html "enum class in com.rpl.rama"/index.html)

Waits for confirmation the append has been received and replicated on the target depot partition and that all colocated stream topologies have processed the append.

[AckLevel](/content/javadoc/com/rpl/rama/AckLevel.html "enum class in com.rpl.rama"/index.html) - Enum Class in com.rpl.rama

Ack levels for use with [depot clients](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html).

ackReturn(Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.html "interface in com.rpl.rama.module"/index.html)

Specifies aggregator to use for ack returns for processing off of this depot.

ackReturnAgg(RamaAccumulatorAgg1) - Method in interface com.rpl.rama.module. [StreamSourceOptions.Impl](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.Impl.html "interface in com.rpl.rama.module"/index.html)

Specifies aggregator to use for ack returns for processing off of this depot.

ackReturnAgg(RamaCombinerAgg) - Static method in interface com.rpl.rama.module. [StreamSourceOptions](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.html "interface in com.rpl.rama.module"/index.html)

Specifies aggregator to use for ack returns for processing off of this depot.

ackReturnAgg(RamaCombinerAgg) - Method in interface com.rpl.rama.module. [StreamSourceOptions.Impl](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.Impl.html "interface in com.rpl.rama.module"/index.html)

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](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.html "interface in com.rpl.rama.module"/index.html)

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](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.Impl.html "interface in com.rpl.rama.module"/index.html)

Specifies aggregator to use for ack returns for processing off of this depot.

ACTIVE - Enum constant in enum class com.rpl.rama. [ProxyState.Status](/content/javadoc/com/rpl/rama/ProxyState.Status.html "enum class in com.rpl.rama"/index.html)addFixedKeys(Object...) - Method in interface com.rpl.rama. [PState.MigratedSchema](/content/javadoc/com/rpl/rama/PState.MigratedSchema.html "interface in com.rpl.rama"/index.html)

Migration option to specify keys being added to a fixedKeysSchema.

afterElem() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on a list to void element at end.

afterElem() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on a list to void element at end.

agg(Agg) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

agg(Agg) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

agg(Agg) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

agg(Agg) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

agg(String, Agg) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregator.

agg(String, Agg) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregator.

agg(String, Agg) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregator.

agg(String, Agg) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregator.

[Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Used for specifying aggregators in Rama topologies in conjunction with agg or compoundAgg methods

[AggOrCompoundAgg](/content/javadoc/com/rpl/rama/ops/AggOrCompoundAgg.html "interface in com.rpl.rama.ops"/index.html) - Interface in com.rpl.rama.opsall() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates to every element of a collection.

all() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates to every element of a collection.

allowYield() - Static method in interface com.rpl.rama. [SelectOptions](/content/javadoc/com/rpl/rama/SelectOptions.html "interface in com.rpl.rama"/index.html)

Allow the select call to yield during execution in order to not run for too long at a time on the task thread.

allowYield() - Method in class com.rpl.rama. [SelectOptions.CaptureSelectOptions](/content/javadoc/com/rpl/rama/SelectOptions.CaptureSelectOptions.html "class in com.rpl.rama"/index.html)allowYield() - Method in interface com.rpl.rama. [SelectOptions.Impl](/content/javadoc/com/rpl/rama/SelectOptions.Impl.html "interface in com.rpl.rama"/index.html)allPartition() - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all tasks in module

allPartition() - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all tasks in module

allPartition() - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all tasks in module

allPartition() - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all tasks in module

allPartition(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all partitions of given depot or PState

allPartition(String) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all partitions of given depot or PState

allPartition(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all partitions of given depot or PState

allPartition(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Executes subsequent code on all partitions of given depot or PState

anchor(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Attaches a no-op node with the given anchor

anchor(String) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Attaches a no-op node with the given anchor

anchor(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Attaches a no-op node with the given anchor

anchor(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Attaches a no-op node with the given anchor

and(Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Applies "and" operator to all input.

AND - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

"and" operator based on values being "truthy" (not null or false).

append(Object) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Append data to depot using AckLevel.ACK.

append(Object, AckLevel) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Append data to depot using specified [AckLevel](/content/javadoc/com/rpl/rama/AckLevel.html "enum class in com.rpl.rama"/index.html).

APPEND_ACK - Enum constant in enum class com.rpl.rama. [AckLevel](/content/javadoc/com/rpl/rama/AckLevel.html "enum class in com.rpl.rama"/index.html)

Waits for confirmation the append has been received and replicated on the target depot partition.

appendAsync(Object) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Append data to depot using AckLevel.ACK.

appendAsync(Object, AckLevel) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Append data to depot using specified [AckLevel](/content/javadoc/com/rpl/rama/AckLevel.html "enum class in com.rpl.rama"/index.html).

[AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html) - 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](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)[AppendDiff.Processor](/content/javadoc/com/rpl/rama/diffs/AppendDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffsascending() - Method in interface com.rpl.rama.ops. [TopMonotonicAgg](/content/javadoc/com/rpl/rama/ops/TopMonotonicAgg.html "interface in com.rpl.rama.ops"/index.html)

Sort results in ascending order rather than descending order

atomicBlock(Block) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Runs subblock until it completes synchronously.

atomicBlock(Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Runs subblock until it completes synchronously.

atomicBlock(Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Runs subblock until it completes synchronously.

atomicBlock(Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Runs subblock until it completes synchronously.

average(Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Averages input into a java.lang.Long.

B

[BackupProvider](/content/javadoc/com/rpl/rama/backup/BackupProvider.html "interface in com.rpl.rama.backup"/index.html) - Interface in com.rpl.rama.backup

This interface defines the functionality required in order to create, store and manage Rama cluster backups.

[BackupProvider.KeysPage](/content/javadoc/com/rpl/rama/backup/BackupProvider.KeysPage.html "class in com.rpl.rama.backup"/index.html) - Class in com.rpl.rama.backup[BackupProviderTester](/content/javadoc/com/rpl/rama/backup/BackupProviderTester.html "class in com.rpl.rama.backup"/index.html) - Class in com.rpl.rama.backup

Provide a test implementation for a backup provider implementation.

BackupProviderTester() - Constructor for class com.rpl.rama.backup. [BackupProviderTester](/content/javadoc/com/rpl/rama/backup/BackupProviderTester.html "class in com.rpl.rama.backup"/index.html)batchBlock(Block) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Specifies a batch block.

batchBlock(Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Specifies a batch block.

batchBlock(Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Specifies a batch block.

batchBlock(Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Specifies a batch block.

beforeElem() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on a list to void element at beginning.

beforeElem() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on a list to void element at beginning.

beforeIndex(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on list to void element before an index.

beforeIndex(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on list to void element before an index.

beginning() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on a list to empty subsequence at beginning.

beginning() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on a list to empty subsequence at beginning.

[Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Core API for specifying dataflow code using the builder pattern.

[Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Block.MultiOutImpl](/content/javadoc/com/rpl/rama/Block.MultiOutImpl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Block.Out](/content/javadoc/com/rpl/rama/Block.Out.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Block.OutImpl](/content/javadoc/com/rpl/rama/Block.OutImpl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.ramabranch(String, Block) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)branch(String, Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)branch(String, Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)branch(String, Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

C

canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [DestroyedDiff](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [Diff](/content/javadoc/com/rpl/rama/diffs/Diff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiDiff](/content/javadoc/com/rpl/rama/diffs/MultiDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [NewValueDiff](/content/javadoc/com/rpl/rama/diffs/NewValueDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [ResyncDiff](/content/javadoc/com/rpl/rama/diffs/ResyncDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexChangesDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangesDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SetAddDiff](/content/javadoc/com/rpl/rama/diffs/SetAddDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [UngracefulTerminationDiff](/content/javadoc/com/rpl/rama/diffs/UngracefulTerminationDiff.html "class in com.rpl.rama.diffs"/index.html)canProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [UnknownDiff](/content/javadoc/com/rpl/rama/diffs/UnknownDiff.html "class in com.rpl.rama.diffs"/index.html)CapturedEmit(String, Object...) - Constructor for class com.rpl.rama.test. [MockOutputCollector.CapturedEmit](/content/javadoc/com/rpl/rama/test/MockOutputCollector.CapturedEmit.html "class in com.rpl.rama.test"/index.html)CapturedSortedRangeFromOptions() - Constructor for class com.rpl.rama. [SortedRangeFromOptions.CapturedSortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.CapturedSortedRangeFromOptions.html "class in com.rpl.rama"/index.html)CapturedSortedRangeOptions() - Constructor for class com.rpl.rama. [SortedRangeOptions.CapturedSortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.CapturedSortedRangeOptions.html "class in com.rpl.rama"/index.html)CapturedSortedRangeToOptions() - Constructor for class com.rpl.rama. [SortedRangeToOptions.CapturedSortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.CapturedSortedRangeToOptions.html "class in com.rpl.rama"/index.html)CapturedSubindexOptions() - Constructor for class com.rpl.rama. [SubindexOptions.CapturedSubindexOptions](/content/javadoc/com/rpl/rama/SubindexOptions.CapturedSubindexOptions.html "class in com.rpl.rama"/index.html)captureNewValInto(String) - Method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Captures updated value of aggregated location into var for post-agg phase of a batch block.

CaptureSelectOptions() - Constructor for class com.rpl.rama. [SelectOptions.CaptureSelectOptions](/content/javadoc/com/rpl/rama/SelectOptions.CaptureSelectOptions.html "class in com.rpl.rama"/index.html)[Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Used to create cases for Block.cond(com.rpl.rama.Case...)

[Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Case.MultiOutImpl](/content/javadoc/com/rpl/rama/Case.MultiOutImpl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Case.Out](/content/javadoc/com/rpl/rama/Case.Out.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama[Case.OutImpl](/content/javadoc/com/rpl/rama/Case.OutImpl.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.ramachange(T, Diff, T) - Method in interface com.rpl.rama. [ProxyState.Callback](/content/javadoc/com/rpl/rama/ProxyState.Callback.html "interface in com.rpl.rama"/index.html)

Callback method for changes to this value

choosePartitionIndex(T, int) - Method in interface com.rpl.rama. [Depot.Partitioning](/content/javadoc/com/rpl/rama/Depot.Partitioning.html "interface in com.rpl.rama"/index.html)

Computes partition number for append based on data and number of partitions in depot

CLASS - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits Class of argument.

close() - Method in class com.rpl.rama.integration. [ManagedResource](/content/javadoc/com/rpl/rama/integration/ManagedResource.html "class in com.rpl.rama.integration"/index.html)

Closes the resource if it's an instance of java.io.Closeable.

clusterDepot(String, String) - Method in interface com.rpl.rama.cluster. [ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html)

Retrieve client for a Depot

clusterDepot(String, String, String) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a mirror depot that accesses a depot on another module.

[ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html) - Interface in com.rpl.rama.cluster

Interface for retrieving depots, PStates, and query topology clients from a real cluster or [InProcessCluster](/content/javadoc/com/rpl/rama/test/InProcessCluster.html "interface in com.rpl.rama.test"/index.html)

clusterPState(String, String) - Method in interface com.rpl.rama.cluster. [ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html)

Retrieve client for a PState

clusterPState(String, String, String) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a mirror PState that accesses a PState on another module.

clusterQuery(String, String) - Method in interface com.rpl.rama.cluster. [ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html)

Retrieve client for a query topology

clusterQuery(String, String, String) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a query topology reference for invoking a query topology on another module.

collect(Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Collects a list of values selected with given path from current point.

collect(Path) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Collects a list of values selected with given path from current point.

collectOne(Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Collects a single value selected with given path from current point.

collectOne(Path) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Collects a single value selected with given path from current point.

com.rpl.rama - package com.rpl.ramacom.rpl.rama.backup - package com.rpl.rama.backupcom.rpl.rama.cluster - package com.rpl.rama.clustercom.rpl.rama.diffs - package com.rpl.rama.diffscom.rpl.rama.integration - package com.rpl.rama.integrationcom.rpl.rama.module - package com.rpl.rama.modulecom.rpl.rama.object - package com.rpl.rama.objectcom.rpl.rama.ops - package com.rpl.rama.opscom.rpl.rama.test - package com.rpl.rama.testcombine(T, T) - Method in interface com.rpl.rama.ops. [RamaCombinerAgg](/content/javadoc/com/rpl/rama/ops/RamaCombinerAgg.html "interface in com.rpl.rama.ops"/index.html)

Combine two values into an aggregated value

combiner(RamaCombinerAgg, Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Use a custom combiner as an aggregator

compoundAgg(CompoundAgg) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

compoundAgg(CompoundAgg) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

compoundAgg(CompoundAgg) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

compoundAgg(CompoundAgg) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Aggregates input in a batch block to a single value.

compoundAgg(String, CompoundAgg) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregation template.

compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregation template.

compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregation template.

compoundAgg(String, CompoundAgg) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Update PState partition on current task with given aggregation template.

[CompoundAgg](/content/javadoc/com/rpl/rama/CompoundAgg.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Static methods for making aggregation templates for Block.compoundAgg(com.rpl.rama.CompoundAgg).

cond(Case...) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Evaluates condition for each [Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html) in order.

cond(Case...) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Evaluates condition for each [Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html) in order.

cond(Case...) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Evaluates condition for each [Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html) in order.

cond(Case...) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Evaluates condition for each [Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html) in order.

[Constant](/content/javadoc/com/rpl/rama/Constant.html "class in com.rpl.rama"/index.html) - 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](/content/javadoc/com/rpl/rama/Constant.html "class in com.rpl.rama"/index.html)CONTAINS - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Executes another iteration of the loop.

continueLoop(Object...) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Executes another iteration of the loop.

continueLoop(Object...) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Executes another iteration of the loop.

continueLoop(Object...) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Executes another iteration of the loop.

count() - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Counts input into a java.lang.Long

create() - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Creates an empty Block that can have additional code attached.

create() - Static method in interface com.rpl.rama. [LoopVars](/content/javadoc/com/rpl/rama/LoopVars.html "interface in com.rpl.rama"/index.html)

Creates an empty LoopVars.

create() - Static method in interface com.rpl.rama.module. [MicrobatchSourceOptions](/content/javadoc/com/rpl/rama/module/MicrobatchSourceOptions.html "interface in com.rpl.rama.module"/index.html)

Creates an empty MicrobatchSourceOptions.

create() - Static method in interface com.rpl.rama.module. [StreamSourceOptions](/content/javadoc/com/rpl/rama/module/StreamSourceOptions.html "interface in com.rpl.rama.module"/index.html)

Creates an empty StreamSourceOptions.

create() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Creates an empty Path.

create() - Static method in interface com.rpl.rama. [SelectOptions](/content/javadoc/com/rpl/rama/SelectOptions.html "interface in com.rpl.rama"/index.html)

Creates an empty SubiSelectOptionsndexOptions.

create() - Static method in interface com.rpl.rama. [SortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.html "interface in com.rpl.rama"/index.html)

Creates an empty SortedRangeFromOptions.

create() - Static method in interface com.rpl.rama. [SortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.html "interface in com.rpl.rama"/index.html)

Creates an empty SortedRangeOptions.

create() - Static method in interface com.rpl.rama. [SortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.html "interface in com.rpl.rama"/index.html)

Creates an empty SortedRangeToOptions.

create() - Static method in interface com.rpl.rama. [SubindexOptions](/content/javadoc/com/rpl/rama/SubindexOptions.html "interface in com.rpl.rama"/index.html)

Creates an empty SubindexOptions.

create() - Static method in interface com.rpl.rama.test. [InProcessCluster](/content/javadoc/com/rpl/rama/test/InProcessCluster.html "interface in com.rpl.rama.test"/index.html)

Creates an InProcessCluster

create() - Static method in interface com.rpl.rama.test. [UpdateOptions](/content/javadoc/com/rpl/rama/test/UpdateOptions.html "interface in com.rpl.rama.test"/index.html)

Create empty instance

create(int, String...) - Static method in interface com.rpl.rama.ops. [LimitAgg](/content/javadoc/com/rpl/rama/ops/LimitAgg.html "interface in com.rpl.rama.ops"/index.html)

Creates a limit aggregator specification

create(PState.Schema) - Static method in interface com.rpl.rama.test. [TestPState](/content/javadoc/com/rpl/rama/test/TestPState.html "interface in com.rpl.rama.test"/index.html)

Creates a TestPState with the given schema.

create(Class) - Static method in interface com.rpl.rama. [SubSource](/content/javadoc/com/rpl/rama/SubSource.html "interface in com.rpl.rama"/index.html)

Create a subSource case matching on the given type exactly.

create(Class) - Static method in interface com.rpl.rama.test. [TestPState](/content/javadoc/com/rpl/rama/test/TestPState.html "interface in com.rpl.rama.test"/index.html)

Creates a TestPState with the given schema.

create(Object) - Static method in interface com.rpl.rama. [Case](/content/javadoc/com/rpl/rama/Case.html "interface in com.rpl.rama"/index.html)

Create a case matching on the given condition.

create(List) - Static method in interface com.rpl.rama.test. [InProcessCluster](/content/javadoc/com/rpl/rama/test/InProcessCluster.html "interface in com.rpl.rama.test"/index.html)

Creates an InProcessCluster with the specified [RamaCustomSerialization](/content/javadoc/com/rpl/rama/RamaCustomSerialization.html "interface in com.rpl.rama"/index.html) implementations registered for all launched modules

CURRENT_MICROBATCH_ID - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Returns ID of current microbatch attempt.

CURRENT_TASK_ID - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits task ID where event is running

CURRENT_TOPOLOGY_TYPE - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Returns the type of the current topology ("stream", "microbatch", or "query"), or else null.

customNav(Navigator) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds custom navigator implementation to Path

customNav(Navigator) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Adds custom navigator implementation to Path

customNavBuilder(RamaFunction0) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of zero arguments.

customNavBuilder(RamaFunction0) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of one argument.

customNavBuilder(RamaFunction1<T0, Navigator>, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of two arguments.

customNavBuilder(RamaFunction2<T0, T1, Navigator>, Object, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of three arguments.

customNavBuilder(RamaFunction3<T0, T1, T2, Navigator>, Object, Object, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of four arguments.

customNavBuilder(RamaFunction4<T0, T1, T2, T3, Navigator>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of five arguments.

customNavBuilder(RamaFunction5<T0, T1, T2, T3, T4, Navigator>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of six arguments.

customNavBuilder(RamaFunction6<T0, T1, T2, T3, T4, T5, Navigator>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of seven 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](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Adds a custom navigator built dynamically with the provided function of eight 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](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with one argument.

customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with one argument.

customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with one argument.

customPartition(RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with two arguments.

customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with two arguments.

customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with two arguments.

customPartition(RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with three arguments.

customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with three arguments.

customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with three arguments.

customPartition(RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with four arguments.

customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with four arguments.

customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with four arguments.

customPartition(RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with five arguments.

customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with five arguments.

customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with five arguments.

customPartition(RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with six arguments.

customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with six arguments.

customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with six arguments.

customPartition(RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes task to task ID specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with one argument.

customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with one argument.

customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with one argument.

customPartition(String, RamaFunction1<Integer, Integer>) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with two arguments.

customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with two arguments.

customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with two arguments.

customPartition(String, RamaFunction2<Integer, T0, Integer>, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with three arguments.

customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with three arguments.

customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with three arguments.

customPartition(String, RamaFunction3<Integer, T0, T1, Integer>, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with four arguments.

customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with four arguments.

customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with four arguments.

customPartition(String, RamaFunction4<Integer, T0, T1, T2, Integer>, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with five arguments.

customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with five arguments.

customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with five arguments.

customPartition(String, RamaFunction5<Integer, T0, T1, T2, T3, Integer>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with six arguments.

customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with six arguments.

customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with six arguments.

customPartition(String, RamaFunction6<Integer, T0, T1, T2, T3, T4, Integer>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with seven 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with eight 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task containing PState partition specified by custom partitioner function with eight arguments.

D

DAYS - Enum constant in enum class com.rpl.rama.module. [OffsetAgo](/content/javadoc/com/rpl/rama/module/OffsetAgo.html "enum class in com.rpl.rama.module"/index.html)

Start from first record added after this many days in the past

DEC - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits one less than input value as an Integer

DEC_LONG - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits one less than input value as a Long

declareDepot(String, NativeDepotPartitioning) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a depot with the given partitioning scheme.

declareDepot(String, Class) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a depot with the given partitioning scheme.

declareObject(String, Object) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines an object to be copied to all tasks.

declareTickDepot(String, long) - Method in interface com.rpl.rama. [RamaModule.Setup](/content/javadoc/com/rpl/rama/RamaModule.Setup.html "interface in com.rpl.rama"/index.html)

Defines a depot that emits at the given frequency of time.

define(RamaModule.Setup, RamaModule.Topologies) - Method in interface com.rpl.rama. [RamaModule](/content/javadoc/com/rpl/rama/RamaModule.html "interface in com.rpl.rama"/index.html)

Specifies all depots, PStates, ETLs, and query topologies for this module.

deleteObject(String) - Method in interface com.rpl.rama.backup. [BackupProvider](/content/javadoc/com/rpl/rama/backup/BackupProvider.html "interface in com.rpl.rama.backup"/index.html)

Delete the object at the given key in the backup provider.

[Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Interface for thread-safe depot clients.

[Depot.Declaration](/content/javadoc/com/rpl/rama/Depot.Declaration.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Builder-style object to specify options when declaring a depot in a module

[Depot.Partitioning](/content/javadoc/com/rpl/rama/Depot.Partitioning.html "interface in com.rpl.rama"/index.html) - Interface in com.rpl.rama

Interface for implementing custom depot partitioners

depotPartitionAppend(String, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object, AckLevel) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

depotPartitionAppend(String, Object, AckLevel) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Append data to the partition of the depot represented by current task.

[DepotPartitionInfo](/content/javadoc/com/rpl/rama/object/DepotPartitionInfo.html "class in com.rpl.rama.object"/index.html) - Class in com.rpl.rama.object

Information about a depot partition.

DepotPartitionInfo(long, long) - Constructor for class com.rpl.rama.object. [DepotPartitionInfo](/content/javadoc/com/rpl/rama/object/DepotPartitionInfo.html "class in com.rpl.rama.object"/index.html)deserialize(DataInput) - Method in interface com.rpl.rama. [RamaCustomSerialization](/content/javadoc/com/rpl/rama/RamaCustomSerialization.html "interface in com.rpl.rama"/index.html)

Deserialize object

[DestroyedDiff](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html) - 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](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html)[DestroyedDiff.Processor](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffsdestroyModule(String) - Method in interface com.rpl.rama.test. [InProcessCluster](/content/javadoc/com/rpl/rama/test/InProcessCluster.html "interface in com.rpl.rama.test"/index.html)

Destroy a module

[Diff](/content/javadoc/com/rpl/rama/diffs/Diff.html "class in com.rpl.rama.diffs"/index.html) - 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](/content/javadoc/com/rpl/rama/diffs/Diff.html "class in com.rpl.rama.diffs"/index.html)[Diff.Processor](/content/javadoc/com/rpl/rama/diffs/Diff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffsdirectPartition(Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to specified task ID

directPartition(Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified task ID

directPartition(Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified task ID

directPartition(Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified task ID

directPartition(String, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to specified partition of the given depot or PState

directPartition(String, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified partition of the given depot or PState

directPartition(String, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified partition of the given depot or PState

directPartition(String, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes to specified partition of the given depot or PState

disallow() - Static method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Disallows depot clients from appending to this depot.

dispenseCollected() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Drops all collected values from subsequent navigation

dispenseCollected() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Drops all collected values from subsequent navigation

DIV - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Divides first argument by second argument and emits a Double

doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [DestroyedDiff](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [Diff](/content/javadoc/com/rpl/rama/diffs/Diff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiDiff](/content/javadoc/com/rpl/rama/diffs/MultiDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [NewValueDiff](/content/javadoc/com/rpl/rama/diffs/NewValueDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [ResyncDiff](/content/javadoc/com/rpl/rama/diffs/ResyncDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexChangesDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangesDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SetAddDiff](/content/javadoc/com/rpl/rama/diffs/SetAddDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [SetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [UngracefulTerminationDiff](/content/javadoc/com/rpl/rama/diffs/UngracefulTerminationDiff.html "class in com.rpl.rama.diffs"/index.html)doProcess(Diff.Processor) - Method in class com.rpl.rama.diffs. [UnknownDiff](/content/javadoc/com/rpl/rama/diffs/UnknownDiff.html "class in com.rpl.rama.diffs"/index.html)

E

each(RamaFunction0) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of zero arguments.

each(RamaFunction0) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of zero arguments.

each(RamaFunction0) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of zero arguments.

each(RamaFunction0) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of zero arguments.

each(RamaFunction1<T0, R>, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of one argument.

each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of one argument.

each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of one argument.

each(RamaFunction1<T0, R>, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of one argument.

each(RamaFunction2<T0, T1, R>, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of two arguments.

each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of two arguments.

each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of two arguments.

each(RamaFunction2<T0, T1, R>, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of two arguments.

each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of three arguments.

each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of three arguments.

each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of three arguments.

each(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of four arguments.

each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of four arguments.

each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of four arguments.

each(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of five arguments.

each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of five arguments.

each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of five arguments.

each(RamaFunction5<T0, T1, T2, T3, T4, R>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of six arguments.

each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of six arguments.

each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of six arguments.

each(RamaFunction6<T0, T1, T2, T3, T4, T5, R>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of seven 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of seven 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of seven 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of eight 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of eight 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of eight 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a function of eight arguments.

each(RamaOperation0) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of zero arguments.

each(RamaOperation0) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of zero arguments.

each(RamaOperation0) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of zero arguments.

each(RamaOperation0) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of zero arguments.

each(RamaOperation1, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of one argument.

each(RamaOperation1, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of one argument.

each(RamaOperation1, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of one argument.

each(RamaOperation1, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of one argument.

each(RamaOperation2<T0, T1>, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of two arguments.

each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of two arguments.

each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of two arguments.

each(RamaOperation2<T0, T1>, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of two arguments.

each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of three arguments.

each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of three arguments.

each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of three arguments.

each(RamaOperation3<T0, T1, T2>, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of three arguments.

each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of four arguments.

each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of four arguments.

each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of four arguments.

each(RamaOperation4<T0, T1, T2, T3>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of five arguments.

each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of five arguments.

each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of five arguments.

each(RamaOperation5<T0, T1, T2, T3, T4>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of six arguments.

each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of six arguments.

each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of six arguments.

each(RamaOperation6<T0, T1, T2, T3, T4, T5>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of seven 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of seven 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of seven 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes an operation of eight 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of eight 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of eight 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes an operation of eight arguments.

eachAsync(RamaFunction0) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.

eachAsync(RamaFunction0) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction0) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction0) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.

eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction1<T0, CompletableFuture>, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.

eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction2<T0, T1, CompletableFuture>, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of three 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction3<T0, T1, T2, CompletableFuture>, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of four 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction4<T0, T1, T2, T3, CompletableFuture>, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of five 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction5<T0, T1, T2, T3, T4, CompletableFuture>, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of six 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

eachAsync(RamaFunction6<T0, T1, T2, T3, T4, T5, CompletableFuture>, Object, Object, Object, Object, Object, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of seven 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a function of eight 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

emit(Object...) - Method in interface com.rpl.rama.ops. [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html)

Emit any number of fields to the default output stream.

emit(Object...) - Method in class com.rpl.rama.test. [MockOutputCollector](/content/javadoc/com/rpl/rama/test/MockOutputCollector.html "class in com.rpl.rama.test"/index.html)emitLoop(Object...) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Emits from a loop.

emitLoop(Object...) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Emits from a loop.

emitLoop(Object...) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Emits from a loop.

emitLoop(Object...) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Emits from a loop.

emitStream(String, Object...) - Method in interface com.rpl.rama.ops. [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html)

Emit any number of fields to a named output stream.

emitStream(String, Object...) - Method in class com.rpl.rama.test. [MockOutputCollector](/content/javadoc/com/rpl/rama/test/MockOutputCollector.html "class in com.rpl.rama.test"/index.html)end() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on a list to empty subsequence at end.

end() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on a list to empty subsequence at end.

endOffset(int) - Method in interface com.rpl.rama.integration. [ExternalDepot](/content/javadoc/com/rpl/rama/integration/ExternalDepot.html "interface in com.rpl.rama.integration"/index.html)

Asynchronously returns the end offset of the given partition index (exclusive).

EQUAL - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Tests whether all arguments are equal and emits boolean true or false.

equals(Object) - Method in class com.rpl.rama.diffs. [AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [DestroyedDiff](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [MultiDiff](/content/javadoc/com/rpl/rama/diffs/MultiDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [NewValueDiff](/content/javadoc/com/rpl/rama/diffs/NewValueDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [ResyncDiff](/content/javadoc/com/rpl/rama/diffs/ResyncDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceIndexChangesDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangesDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SetAddDiff](/content/javadoc/com/rpl/rama/diffs/SetAddDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [SetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [UngracefulTerminationDiff](/content/javadoc/com/rpl/rama/diffs/UngracefulTerminationDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.diffs. [UnknownDiff](/content/javadoc/com/rpl/rama/diffs/UnknownDiff.html "class in com.rpl.rama.diffs"/index.html)equals(Object) - Method in class com.rpl.rama.test. [MockOutputCollector.CapturedEmit](/content/javadoc/com/rpl/rama/test/MockOutputCollector.CapturedEmit.html "class in com.rpl.rama.test"/index.html)[ETLTopologyBase](/content/javadoc/com/rpl/rama/module/ETLTopologyBase.html "interface in com.rpl.rama.module"/index.html) - Interface in com.rpl.rama.module

Base interface for stream and microbatch topologies

excludeStart() - Method in class com.rpl.rama. [SortedRangeFromOptions.CapturedSortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.CapturedSortedRangeFromOptions.html "class in com.rpl.rama"/index.html)excludeStart() - Static method in interface com.rpl.rama. [SortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.html "interface in com.rpl.rama"/index.html)

Excludes the start key from the results (by default it's included).

excludeStart() - Method in interface com.rpl.rama. [SortedRangeFromOptions.Impl](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.Impl.html "interface in com.rpl.rama"/index.html)

Excludes the start key from the results (by default it's included).

excludeStart() - Method in class com.rpl.rama. [SortedRangeOptions.CapturedSortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.CapturedSortedRangeOptions.html "class in com.rpl.rama"/index.html)excludeStart() - Static method in interface com.rpl.rama. [SortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.html "interface in com.rpl.rama"/index.html)

Excludes the start key from the results (by default it's included).

excludeStart() - Method in interface com.rpl.rama. [SortedRangeOptions.Impl](/content/javadoc/com/rpl/rama/SortedRangeOptions.Impl.html "interface in com.rpl.rama"/index.html)

Excludes the start key from the results (by default it's included).

execute() - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Execute the given Block on the current thread.

EXPAND - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits every element of input list as a separate field.

EXPLODE - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits every element of input list individually.

EXPLODE_INDEXED - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits every element of input list individually along with index of emit.

EXPLODE_MAP - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits every key/value pair of input map individually.

explodeMaterialized(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

explodeMaterialized(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

explodeMaterialized(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

explodeMicrobatch(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Emits all data for this microbatch source across all partitions of depot

explodeMicrobatch(String) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Emits all data for this microbatch source across all partitions of depot

explodeMicrobatch(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Emits all data for this microbatch source across all partitions of depot

explodeMicrobatch(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Emits all data for this microbatch source across all partitions of depot

[Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html) - Class in com.rpl.rama

Specifies an expression to be used in an argument position in dataflow code.

Expr(NativeAnyArityRamaOperation, Object...) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression for built-in operation that takes any number of arguments

Expr(RamaFunction0) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression with zero arguments

Expr(RamaFunction1<T0, R>, Object) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression with one argument

Expr(RamaFunction2<T0, T1, R>, Object, Object) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression with two arguments

Expr(RamaFunction3<T0, T1, T2, R>, Object, Object, Object) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression with three arguments

Expr(RamaFunction4<T0, T1, T2, T3, R>, Object, Object, Object, Object) - Constructor for class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)

Constructs an expression with eight arguments

[ExternalDepot](/content/javadoc/com/rpl/rama/integration/ExternalDepot.html "interface in com.rpl.rama.integration"/index.html) - 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](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Extracts contents of a PState as a value.

F

fetchFrom(int, long) - Method in interface com.rpl.rama.integration. [ExternalDepot](/content/javadoc/com/rpl/rama/integration/ExternalDepot.html "interface in com.rpl.rama.integration"/index.html)

Asynchronously returns a chunk of records starting at the given offset.

fetchFrom(int, long, long) - Method in interface com.rpl.rama.integration. [ExternalDepot](/content/javadoc/com/rpl/rama/integration/ExternalDepot.html "interface in com.rpl.rama.integration"/index.html)

Asynchronously returns the sequence of records between the given range of offsets.

filteredList(Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates to sublist of elements filtered based on given Path.

filteredList(Path) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates to sublist of elements filtered based on given Path.

filterEqual(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is equal to provided value.

filterEqual(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is equal to provided value.

filterGreaterThan(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is greater than provided value.

filterGreaterThan(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is greater than provided value.

filterGreaterThanOrEqual(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is greater than or equal to provided value.

filterGreaterThanOrEqual(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is greater than or equal to provided value.

filterLessThan(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is less than provided value.

filterLessThan(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is less than provided value.

filterLessThanOrEqual(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is less than or equal to provided value.

filterLessThanOrEqual(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is less than or equal to provided value.

filterNotEqual(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is not equal to provided value.

filterNotEqual(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if current value is not equal to provided value.

filterNotSelected(Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if provided path executed on current value navigates to zero values.

filterNotSelected(Path) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Continues navigation if provided function returns true on current value.

filterPred(RamaFunction1<T0, R0>) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if provided function returns true on current value.

filterSelected(Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Continues navigation if provided path executed on current value navigates to at least one value.

first() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates on list to first element if not empty.

first() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates on list to first element if not empty.

first(Object) - Static method in interface com.rpl.rama. [Agg](/content/javadoc/com/rpl/rama/Agg.html "interface in com.rpl.rama"/index.html)

Aggregates input to the first input seen

FIRST - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits first element of input collection or null if it is empty.

fixedKeysSchema(Object...) - Static method in interface com.rpl.rama. [PState](/content/javadoc/com/rpl/rama/PState.html "interface in com.rpl.rama"/index.html)

Declare schema for map with different schema for each key.

freshBatchSource() - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Declares a new batch source within pre-agg portion of a batch block

freshBatchSource() - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

freshBatchSource() - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

freshBatchSource() - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

G

gainedLeadership() - Method in interface com.rpl.rama.integration. [TaskGlobalObject](/content/javadoc/com/rpl/rama/integration/TaskGlobalObject.html "interface in com.rpl.rama.integration"/index.html)

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](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a key that hashes to each task in a range of tasks.

genHashingIndexKeys(String, int) - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a key starting with the given prefix that hashes to each task in a range of tasks.

genPStateVar() - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a unique PState var

genPStateVar(String) - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a unique PState var with the given prefix

genVar() - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a unique var

genVar(String) - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Generates a unique var with the given prefix

get() - Method in interface com.rpl.rama. [ProxyState](/content/javadoc/com/rpl/rama/ProxyState.html "interface in com.rpl.rama"/index.html)

Get current value of this object.

GET - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Arguments are a collection and a key and emits the value for the key in the collection.

getAllowYield() - Method in class com.rpl.rama. [SelectOptions.CaptureSelectOptions](/content/javadoc/com/rpl/rama/SelectOptions.CaptureSelectOptions.html "class in com.rpl.rama"/index.html)getAmt() - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Number of removed elements

getArgs() - Method in class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)getBeforeIndex() - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)

Index where element was inserted

getBeforeIndex() - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)

Index where elements were inserted

getBlock() - Method in class com.rpl.rama. [SubBatch](/content/javadoc/com/rpl/rama/SubBatch.html "class in com.rpl.rama"/index.html)getClusterRetriever() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Returns ClusterManagerBase instance for retrieving foreign clients.

getDeployedModuleNames() - Method in interface com.rpl.rama.cluster. [ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html)

Retrieves set of the names of all deployed modules on this cluster.

getDiffs() - Method in class com.rpl.rama.diffs. [MultiDiff](/content/javadoc/com/rpl/rama/diffs/MultiDiff.html "class in com.rpl.rama.diffs"/index.html)

Diffs in the order in which they happened

getElem() - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)

Value added to multi-set

getElem() - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Value removed to multi-set

getElem() - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)

Inserted value

getElem() - Method in class com.rpl.rama.diffs. [SetAddDiff](/content/javadoc/com/rpl/rama/diffs/SetAddDiff.html "class in com.rpl.rama.diffs"/index.html)

Value of object added to set

getElem() - Method in class com.rpl.rama.diffs. [SetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Value of object removed from set

getElems() - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)

Inserted elements

getEmits() - Method in class com.rpl.rama.test. [MockOutputCollector](/content/javadoc/com/rpl/rama/test/MockOutputCollector.html "class in com.rpl.rama.test"/index.html)

Retrieve captured emits in the order in which they happened

getEmitsByStream() - Method in class com.rpl.rama.test. [MockOutputCollector](/content/javadoc/com/rpl/rama/test/MockOutputCollector.html "class in com.rpl.rama.test"/index.html)

Retrieve captured emits split by stream name.

getEndOffset() - Method in class com.rpl.rama. [MicrobatchParams](/content/javadoc/com/rpl/rama/MicrobatchParams.html "class in com.rpl.rama"/index.html)getEndOffset() - Method in class com.rpl.rama.object. [DepotPartitionInfo](/content/javadoc/com/rpl/rama/object/DepotPartitionInfo.html "class in com.rpl.rama.object"/index.html)

Retrieves the end offset of the depot partition log.

getFrequencyMillis() - Method in interface com.rpl.rama.integration. [TaskGlobalObjectWithTick](/content/javadoc/com/rpl/rama/integration/TaskGlobalObjectWithTick.html "interface in com.rpl.rama.integration"/index.html)

Defines the frequency at which TaskGlobalObjectWithTick.tick() is called.

getFromIndex() - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Sequence changed for every index after this index

getFromIndex() - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)

Index of element before move

getFromKey() - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Original value of key

getGeneratedVarPrefix(String) - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Gets prefix string used to generate a var

getIndex() - Method in class com.rpl.rama.diffs. [AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)

Index of append, same as size of sequence before the append

getIndex() - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Index of changed value

getIndex() - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Starting index where elements were removed

getIndexToDiff() - Method in class com.rpl.rama.diffs. [SequenceIndexChangesDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangesDiff.html "class in com.rpl.rama.diffs"/index.html)

Map of index to diffs for their changed values

getKey() - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)

Key of changed value

getKey() - Method in class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Removed key

getKeys() - Method in class com.rpl.rama.diffs. [KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Removed keys

getKeyToDiff() - Method in class com.rpl.rama.diffs. [KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)

Map of keys to diffs for their values

getLogThrottler() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Return a log throttler instance for the current context.

getMaxAmt() - Method in class com.rpl.rama. [SortedRangeFromOptions.CapturedSortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.CapturedSortedRangeFromOptions.html "class in com.rpl.rama"/index.html)getMaxAmt() - Method in class com.rpl.rama. [SortedRangeToOptions.CapturedSortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.CapturedSortedRangeToOptions.html "class in com.rpl.rama"/index.html)getMicrobatchDepotInfo(String, String) - Method in interface com.rpl.rama.cluster. [ClusterManagerBase](/content/javadoc/com/rpl/rama/cluster/ClusterManagerBase.html "interface in com.rpl.rama.cluster"/index.html)

Retrieve information about a microbatch topology's latest processed offsets for all depots depended on by the topology.

getModuleInstanceId() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns module instance ID

getModuleInstanceInfo() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Returns information about current module.

getModuleName() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns name of module

getModuleName() - Method in class com.rpl.rama.object. [PartitionedObjectInfo](/content/javadoc/com/rpl/rama/object/PartitionedObjectInfo.html "class in com.rpl.rama.object"/index.html)

Get the name of the module that the object belongs to.

getModuleName() - Method in interface com.rpl.rama. [RamaModule](/content/javadoc/com/rpl/rama/RamaModule.html "interface in com.rpl.rama"/index.html)

Optional method to override the name of the module.

getModuleStatus(String) - Method in interface com.rpl.rama. [RamaClusterManager](/content/javadoc/com/rpl/rama/RamaClusterManager.html "interface in com.rpl.rama"/index.html)

Get status of a launched module

getName() - Method in class com.rpl.rama.object. [PartitionedObjectInfo](/content/javadoc/com/rpl/rama/object/PartitionedObjectInfo.html "class in com.rpl.rama.object"/index.html)

Get the name of the partitioned object.

getNewCount() - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)

Number of times element appears after adding it

getNewCount() - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Number of times element appears after removing it

getNewSize() - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence after change

getNumPartitions() - Method in interface com.rpl.rama.integration. [ExternalDepot](/content/javadoc/com/rpl/rama/integration/ExternalDepot.html "interface in com.rpl.rama.integration"/index.html)

Asynchronously returns the number of partitions in the external queue.

getNumPartitions() - Method in class com.rpl.rama.object. [PartitionedObjectInfo](/content/javadoc/com/rpl/rama/object/PartitionedObjectInfo.html "class in com.rpl.rama.object"/index.html)

Get the number of partitions of the partitioned object.

getNumTasks() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns number of tasks in module

getNumTasks() - Method in class com.rpl.rama.test. [LaunchConfig](/content/javadoc/com/rpl/rama/test/LaunchConfig.html "class in com.rpl.rama.test"/index.html)getNumThreads() - Method in class com.rpl.rama.test. [LaunchConfig](/content/javadoc/com/rpl/rama/test/LaunchConfig.html "class in com.rpl.rama.test"/index.html)getNumWorkers() - Method in class com.rpl.rama.test. [LaunchConfig](/content/javadoc/com/rpl/rama/test/LaunchConfig.html "class in com.rpl.rama.test"/index.html)getObject(String) - Method in interface com.rpl.rama.backup. [BackupProvider](/content/javadoc/com/rpl/rama/backup/BackupProvider.html "interface in com.rpl.rama.backup"/index.html)

Get the contents of the key stored in the backup provider.

getObjectInfo() - Method in interface com.rpl.rama. [PartitionedObject](/content/javadoc/com/rpl/rama/PartitionedObject.html "interface in com.rpl.rama"/index.html)

Retrieves information about the partitioned object - the name of the object, the module name, the number of partitions.

getOldCount() - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)

Number of times element appears before adding it

getOldCount() - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Number of times element appears before removing it

getOldSize() - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence before change

getOldSize() - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence before removes

getOldSize() - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence before the insert

getOldSize() - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence before inserts

getOp() - Method in class com.rpl.rama. [Expr](/content/javadoc/com/rpl/rama/Expr.html "class in com.rpl.rama"/index.html)getOutputs() - Method in class com.rpl.rama. [SubBatch](/content/javadoc/com/rpl/rama/SubBatch.html "class in com.rpl.rama"/index.html)getPartitionInfo(long) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Retrieves the start and end offsets of the log for the specified partition index of the depot.

getPartitionInfoAsync(long) - Method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Retrieves the start and end offsets of the log for the specified partition index of the depot.

getPort() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns port of worker where [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html) was fetched

getReplicaId() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Returns replica ID of this task thread.

getReplicationFactor() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns replication factor of module

getResource() - Method in class com.rpl.rama.integration. [ManagedResource](/content/javadoc/com/rpl/rama/integration/ManagedResource.html "class in com.rpl.rama.integration"/index.html)

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](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)

Size of sequence

getStartOffset() - Method in class com.rpl.rama. [MicrobatchParams](/content/javadoc/com/rpl/rama/MicrobatchParams.html "class in com.rpl.rama"/index.html)getStartOffset() - Method in class com.rpl.rama.object. [DepotPartitionInfo](/content/javadoc/com/rpl/rama/object/DepotPartitionInfo.html "class in com.rpl.rama.object"/index.html)

Retrieves the start offset of the depot partition log.

getStreamName() - Method in class com.rpl.rama.test. [MockOutputCollector.CapturedEmit](/content/javadoc/com/rpl/rama/test/MockOutputCollector.CapturedEmit.html "class in com.rpl.rama.test"/index.html)getSupervisorId() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Returns supervisor ID where [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html) was fetched

getTaskGroup() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Returns set of all task IDs in the task group where this task global is being prepared.

getTaskThreadIds() - Method in class com.rpl.rama. [ModuleInstanceInfo](/content/javadoc/com/rpl/rama/ModuleInstanceInfo.html "class in com.rpl.rama"/index.html)

Return lowest task ID for each task thread in the module.

getThrowable() - Method in class com.rpl.rama.diffs. [UngracefulTerminationDiff](/content/javadoc/com/rpl/rama/diffs/UngracefulTerminationDiff.html "class in com.rpl.rama.diffs"/index.html)

Last exception leading to ungraceful termination

getToIndex() - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)

New index for element after move

getToKey() - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

New value of key

getVal() - Method in class com.rpl.rama.diffs. [NewValueDiff](/content/javadoc/com/rpl/rama/diffs/NewValueDiff.html "class in com.rpl.rama.diffs"/index.html)

New value of object

getValDiff() - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)

Diff of changed value

getValDiff() - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)

Diff of changed value

getValue() - Method in class com.rpl.rama. [Constant](/content/javadoc/com/rpl/rama/Constant.html "class in com.rpl.rama"/index.html)getValues() - Method in class com.rpl.rama.test. [MockOutputCollector.CapturedEmit](/content/javadoc/com/rpl/rama/test/MockOutputCollector.CapturedEmit.html "class in com.rpl.rama.test"/index.html)getVarName() - Method in interface com.rpl.rama.integration. [TaskGlobalContext](/content/javadoc/com/rpl/rama/integration/TaskGlobalContext.html "interface in com.rpl.rama.integration"/index.html)

Returns the var name assigned to this object in the module definition.

getVars() - Method in class com.rpl.rama. [LoopVars.LoopVarsCollector](/content/javadoc/com/rpl/rama/LoopVars.LoopVarsCollector.html "class in com.rpl.rama"/index.html)global() - Method in interface com.rpl.rama. [Depot.Declaration](/content/javadoc/com/rpl/rama/Depot.Declaration.html "interface in com.rpl.rama"/index.html)

Configures depot to have a single partition.

global() - Method in interface com.rpl.rama. [PState.Declaration](/content/javadoc/com/rpl/rama/PState.Declaration.html "interface in com.rpl.rama"/index.html)

Configures PState to have a single partition.

globalPartition() - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to task 0

globalPartition() - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task 0

globalPartition() - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task 0

globalPartition() - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes to task 0

globalPartition(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes to partition 0 of given depot or PState.

globalPartition(String) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes to partition 0 of given depot or PState.

globalPartition(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes to partition 0 of given depot or PState.

globalPartition(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes to partition 0 of given depot or PState.

GREATER_THAN - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by one key and performs aggregations in the specified block on each group of data independently.

groupBy(String, Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by one key and performs aggregations in the specified block on each group of data independently.

groupBy(String, Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by one key and performs aggregations in the specified block on each group of data independently.

groupBy(String, Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by two keys 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by two keys 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by two keys 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by three 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by three 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by three 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by four 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by four 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by four 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by five 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by five 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by five 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Groups input by six 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](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by six 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](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Groups input by six 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](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Depot partitioning based on hashing a value from the data being appended.

hashBy(Class) - Static method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Depot partitioning based on hashing a value from the data being appended.

hashBy(String) - Static method in interface com.rpl.rama. [Depot](/content/javadoc/com/rpl/rama/Depot.html "interface in com.rpl.rama"/index.html)

Depot partitioning based on hashing a value from the data being appended.

hashCode() - Method in class com.rpl.rama.diffs. [AppendDiff](/content/javadoc/com/rpl/rama/diffs/AppendDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [DestroyedDiff](/content/javadoc/com/rpl/rama/diffs/DestroyedDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [MultiDiff](/content/javadoc/com/rpl/rama/diffs/MultiDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [MultiSetAddDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetAddDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [MultiSetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/MultiSetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [NewValueDiff](/content/javadoc/com/rpl/rama/diffs/NewValueDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [ResyncDiff](/content/javadoc/com/rpl/rama/diffs/ResyncDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceChangeDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceIndexChangeDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangeDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceIndexChangesDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexChangesDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceIndexRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SequenceIndexRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceInsertDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceInsertsDiff](/content/javadoc/com/rpl/rama/diffs/SequenceInsertsDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SequenceReorderDiff](/content/javadoc/com/rpl/rama/diffs/SequenceReorderDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SetAddDiff](/content/javadoc/com/rpl/rama/diffs/SetAddDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [SetRemoveDiff](/content/javadoc/com/rpl/rama/diffs/SetRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [UngracefulTerminationDiff](/content/javadoc/com/rpl/rama/diffs/UngracefulTerminationDiff.html "class in com.rpl.rama.diffs"/index.html)hashCode() - Method in class com.rpl.rama.diffs. [UnknownDiff](/content/javadoc/com/rpl/rama/diffs/UnknownDiff.html "class in com.rpl.rama.diffs"/index.html)hashPartition(Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of tasks in module.

hashPartition(Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of tasks in module.

hashPartition(Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of tasks in module.

hashPartition(Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of tasks in module.

hashPartition(String, Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of partitions of given depot or PState.

hashPartition(String, Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of partitions of given depot or PState.

hashPartition(String, Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of partitions of given depot or PState.

hashPartition(String, Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes tasks based on hash of argument modulo number of partitions of given depot or PState.

hasKey(String) - Method in interface com.rpl.rama.backup. [BackupProvider](/content/javadoc/com/rpl/rama/backup/BackupProvider.html "interface in com.rpl.rama.backup"/index.html)

Predicate for key existing in the provider.

[Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html) - Class in com.rpl.rama

Collection of static utility methods

Helpers() - Constructor for class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)hook(String) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Changes attachment point for subsequent code to node with given anchor

hook(String) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Changes attachment point for subsequent code to node with given anchor

hook(String) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Changes attachment point for subsequent code to node with given anchor

hook(String) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Changes attachment point for subsequent code to node with given anchor

HOURS - Enum constant in enum class com.rpl.rama.module. [OffsetAgo](/content/javadoc/com/rpl/rama/module/OffsetAgo.html "enum class in com.rpl.rama.module"/index.html)

Start from first record added after this many hours in the past

I

IDENTITY - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits input argument

idFunction(RamaFunction1<T, R>) - Method in interface com.rpl.rama.ops. [TopMonotonicAgg](/content/javadoc/com/rpl/rama/ops/TopMonotonicAgg.html "interface in com.rpl.rama.ops"/index.html)

Function to extract ID from data to de-duplicate results

idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration. [ManagedResource](/content/javadoc/com/rpl/rama/integration/ManagedResource.html "class in com.rpl.rama.integration"/index.html)idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration. [TaskThreadManagedResource](/content/javadoc/com/rpl/rama/integration/TaskThreadManagedResource.html "class in com.rpl.rama.integration"/index.html)idTuple(TaskGlobalContext) - Method in class com.rpl.rama.integration. [WorkerManagedResource](/content/javadoc/com/rpl/rama/integration/WorkerManagedResource.html "class in com.rpl.rama.integration"/index.html)ifPath(Path, Path) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Tests condition against current point and continues navigating with thenPath if condition passes.

ifPath(Path, Path) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

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](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Tests condition against current point and continues navigating with thenPath if condition passes.

ifTrue(Object, Block) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock.

ifTrue(Object, Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock.

ifTrue(Object, Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock.

ifTrue(Object, Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock.

ifTrue(Object, Block, Block) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock – otherwise, runs elseBlock.

ifTrue(Object, Block, Block) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock – otherwise, runs elseBlock.

ifTrue(Object, Block, Block) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock – otherwise, runs elseBlock.

ifTrue(Object, Block, Block) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

If argument is truthy (not null or boolean false), runs thenBlock – otherwise, runs elseBlock.

INC - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits one more than input value as an Integer

INC_LONG - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits one more than input value as a Long

includeEnd() - Method in class com.rpl.rama. [SortedRangeOptions.CapturedSortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.CapturedSortedRangeOptions.html "class in com.rpl.rama"/index.html)includeEnd() - Method in interface com.rpl.rama. [SortedRangeOptions.Impl](/content/javadoc/com/rpl/rama/SortedRangeOptions.Impl.html "interface in com.rpl.rama"/index.html)

Includes the end key in the results (by default it's excluded).

includeEnd() - Static method in interface com.rpl.rama. [SortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.html "interface in com.rpl.rama"/index.html)

Includes the end key in the results (by default it's excluded).

includeEnd() - Method in class com.rpl.rama. [SortedRangeToOptions.CapturedSortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.CapturedSortedRangeToOptions.html "class in com.rpl.rama"/index.html)includeEnd() - Method in interface com.rpl.rama. [SortedRangeToOptions.Impl](/content/javadoc/com/rpl/rama/SortedRangeToOptions.Impl.html "interface in com.rpl.rama"/index.html)

Includes the end key in the results (by default it's excluded).

includeEnd() - Static method in interface com.rpl.rama. [SortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.html "interface in com.rpl.rama"/index.html)

Includes the end key in the results (by default it's excluded).

index(Object) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates to the index of a list if it exists.

index(Object) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates to the index of a list if it exists.

indexedVals() - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates to pairs of [index, value] for every element of list.

indexedVals() - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates to pairs of [index, value] for every element of list.

indexVar(String) - Method in interface com.rpl.rama.ops. [LimitAgg](/content/javadoc/com/rpl/rama/ops/LimitAgg.html "interface in com.rpl.rama.ops"/index.html)

If set also emits the index of each emit to the specified var

init - Variable in class com.rpl.rama. [LoopVars.LoopVar](/content/javadoc/com/rpl/rama/LoopVars.LoopVar.html "class in com.rpl.rama"/index.html)initialValue(Object) - Method in interface com.rpl.rama. [PState.Declaration](/content/javadoc/com/rpl/rama/PState.Declaration.html "interface in com.rpl.rama"/index.html)

Specifies starting value for PState.

initVal() - Method in interface com.rpl.rama.ops. [RamaAccumulatorAgg](/content/javadoc/com/rpl/rama/ops/RamaAccumulatorAgg.html "interface in com.rpl.rama.ops"/index.html)

Initial value for aggregation

[InProcessCluster](/content/javadoc/com/rpl/rama/test/InProcessCluster.html "interface in com.rpl.rama.test"/index.html) - Interface in com.rpl.rama.test

Simulates a Rama cluster in a single process.

invoke() - Method in interface com.rpl.rama.ops. [RamaFunction0](/content/javadoc/com/rpl/rama/ops/RamaFunction0.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation0](/content/javadoc/com/rpl/rama/ops/RamaOperation0.html "interface in com.rpl.rama.ops"/index.html)

Executes operation and emits results by calling methods on the provided [OutputCollector](/content/javadoc/com/rpl/rama/ops/OutputCollector.html "interface in com.rpl.rama.ops"/index.html)

invoke(Object...) - Method in interface com.rpl.rama. [QueryTopologyClient](/content/javadoc/com/rpl/rama/QueryTopologyClient.html "interface in com.rpl.rama"/index.html)

Blocking invoke.

invoke(T0) - Method in interface com.rpl.rama.ops. [RamaFunction1](/content/javadoc/com/rpl/rama/ops/RamaFunction1.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation1](/content/javadoc/com/rpl/rama/ops/RamaOperation1.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1) - Method in interface com.rpl.rama.ops. [RamaFunction2](/content/javadoc/com/rpl/rama/ops/RamaFunction2.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation2](/content/javadoc/com/rpl/rama/ops/RamaOperation2.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2) - Method in interface com.rpl.rama.ops. [RamaFunction3](/content/javadoc/com/rpl/rama/ops/RamaFunction3.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation3](/content/javadoc/com/rpl/rama/ops/RamaOperation3.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2, T3) - Method in interface com.rpl.rama.ops. [RamaFunction4](/content/javadoc/com/rpl/rama/ops/RamaFunction4.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, T3, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation4](/content/javadoc/com/rpl/rama/ops/RamaOperation4.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2, T3, T4) - Method in interface com.rpl.rama.ops. [RamaFunction5](/content/javadoc/com/rpl/rama/ops/RamaFunction5.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, T3, T4, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation5](/content/javadoc/com/rpl/rama/ops/RamaOperation5.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2, T3, T4, T5) - Method in interface com.rpl.rama.ops. [RamaFunction6](/content/javadoc/com/rpl/rama/ops/RamaFunction6.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, T3, T4, T5, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation6](/content/javadoc/com/rpl/rama/ops/RamaOperation6.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2, T3, T4, T5, T6) - Method in interface com.rpl.rama.ops. [RamaFunction7](/content/javadoc/com/rpl/rama/ops/RamaFunction7.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, T3, T4, T5, T6, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation7](/content/javadoc/com/rpl/rama/ops/RamaOperation7.html "interface in com.rpl.rama.ops"/index.html)

invoke(T0, T1, T2, T3, T4, T5, T6, T7) - Method in interface com.rpl.rama.ops. [RamaFunction8](/content/javadoc/com/rpl/rama/ops/RamaFunction8.html "interface in com.rpl.rama.ops"/index.html)

Computes result of function from input arguments

invoke(T0, T1, T2, T3, T4, T5, T6, T7, OutputCollector) - Method in interface com.rpl.rama.ops. [RamaOperation8](/content/javadoc/com/rpl/rama/ops/RamaOperation8.html "interface in com.rpl.rama.ops"/index.html)

invokeAsync(Object...) - Method in interface com.rpl.rama. [QueryTopologyClient](/content/javadoc/com/rpl/rama/QueryTopologyClient.html "interface in com.rpl.rama"/index.html)

Non-blocking invoke.

invokeNext(Object) - Method in interface com.rpl.rama. [Navigator.Next](/content/javadoc/com/rpl/rama/Navigator.Next.html "interface in com.rpl.rama"/index.html)invokeQuery(String, Object...) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a colocated or mirror query topology

invokeQuery(String, Object...) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Invokes a colocated or mirror query topology

invokeQuery(String, Object...) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a colocated or mirror query topology

invokeQuery(String, Object...) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Invokes a colocated or mirror query topology

IS_EVEN - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits boolean true or false on whether input argument is not null

IS_NULL - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits boolean true or false on whether input argument is null

IS_NUMBER - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits boolean true or false on whether input argument is a number

IS_ODD - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

Emits boolean true or false on whether input argument is an odd number

IS_POSITIVE - Static variable in class com.rpl.rama.ops. [Ops](/content/javadoc/com/rpl/rama/ops/Ops.html "class in com.rpl.rama.ops"/index.html)

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](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Stops navigation if given function on collected values returns false.

isCollected(RamaFunction1<T0, R0>) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Stops navigation if given function on collected values returns false.

isEndIncluded() - Method in class com.rpl.rama. [SortedRangeOptions.CapturedSortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.CapturedSortedRangeOptions.html "class in com.rpl.rama"/index.html)isEndIncluded() - Method in class com.rpl.rama. [SortedRangeToOptions.CapturedSortedRangeToOptions](/content/javadoc/com/rpl/rama/SortedRangeToOptions.CapturedSortedRangeToOptions.html "class in com.rpl.rama"/index.html)isFlushRequired() - Method in interface com.rpl.rama.ops. [RamaCombinerAgg](/content/javadoc/com/rpl/rama/ops/RamaCombinerAgg.html "interface in com.rpl.rama.ops"/index.html)

Controls memory usage when Rama performs two-phase optimization for combiners.

isGeneratedVar(String) - Static method in class com.rpl.rama. [Helpers](/content/javadoc/com/rpl/rama/Helpers.html "class in com.rpl.rama"/index.html)

Tests if a string has the format of a regular var or PState var

isSizeTracked() - Method in class com.rpl.rama. [SubindexOptions.CapturedSubindexOptions](/content/javadoc/com/rpl/rama/SubindexOptions.CapturedSubindexOptions.html "class in com.rpl.rama"/index.html)isStartIncluded() - Method in class com.rpl.rama. [SortedRangeFromOptions.CapturedSortedRangeFromOptions](/content/javadoc/com/rpl/rama/SortedRangeFromOptions.CapturedSortedRangeFromOptions.html "class in com.rpl.rama"/index.html)isStartIncluded() - Method in class com.rpl.rama. [SortedRangeOptions.CapturedSortedRangeOptions](/content/javadoc/com/rpl/rama/SortedRangeOptions.CapturedSortedRangeOptions.html "class in com.rpl.rama"/index.html)

K

keepTrue(Object) - Method in interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

Continues dataflow execution only if arg is truthy (not null or boolean false).

keepTrue(Object) - Static method in interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

Continues dataflow execution only if arg is truthy (not null or boolean false).

keepTrue(Object) - Method in interface com.rpl.rama. [Case.Impl](/content/javadoc/com/rpl/rama/Case.Impl.html "interface in com.rpl.rama"/index.html)

Continues dataflow execution only if arg is truthy (not null or boolean false).

keepTrue(Object) - Method in interface com.rpl.rama. [SubSource.Impl](/content/javadoc/com/rpl/rama/SubSource.Impl.html "interface in com.rpl.rama"/index.html)

Continues dataflow execution only if arg is truthy (not null or boolean false).

key(Object...) - Method in interface com.rpl.rama. [Path.Impl](/content/javadoc/com/rpl/rama/Path.Impl.html "interface in com.rpl.rama"/index.html)

Navigates to value for a key in a map.

key(Object...) - Static method in interface com.rpl.rama. [Path](/content/javadoc/com/rpl/rama/Path.html "interface in com.rpl.rama"/index.html)

Navigates to value for a key in a map.

[KeyChangeDiff](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html) - 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](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.html "class in com.rpl.rama.diffs"/index.html)[KeyChangeDiff.Processor](/content/javadoc/com/rpl/rama/diffs/KeyChangeDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffs[KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html) - Class in com.rpl.rama.diffs

Represents a value for a key changing.

KeyDiff(Object, Diff) - Constructor for class com.rpl.rama.diffs. [KeyDiff](/content/javadoc/com/rpl/rama/diffs/KeyDiff.html "class in com.rpl.rama.diffs"/index.html)[KeyDiff.Processor](/content/javadoc/com/rpl/rama/diffs/KeyDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffskeyPartitioner(Class) - Method in interface com.rpl.rama. [PState.Declaration](/content/javadoc/com/rpl/rama/PState.Declaration.html "interface in com.rpl.rama"/index.html)

Changes the default key partitioner to a custom one.

[KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html) - Class in com.rpl.rama.diffs

Represents a key being removed from data structure.

KeyRemoveDiff(Object) - Constructor for class com.rpl.rama.diffs. [KeyRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.html "class in com.rpl.rama.diffs"/index.html)[KeyRemoveDiff.Processor](/content/javadoc/com/rpl/rama/diffs/KeyRemoveDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffskeys - Variable in class com.rpl.rama.backup. [BackupProvider.KeysPage](/content/javadoc/com/rpl/rama/backup/BackupProvider.KeysPage.html "class in com.rpl.rama.backup"/index.html)[KeysDiff](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html) - 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](/content/javadoc/com/rpl/rama/diffs/KeysDiff.html "class in com.rpl.rama.diffs"/index.html)[KeysDiff.Processor](/content/javadoc/com/rpl/rama/diffs/KeysDiff.Processor.html "interface in com.rpl.rama.diffs"/index.html) - Interface in com.rpl.rama.diffsKeysPage(List, String) - Constructor for class com.rpl.rama.backup. [BackupProvider.KeysPage](/content/javadoc/com/rpl/rama/backup/BackupProvider.KeysPage.html "class in com.rpl.rama.backup"/index.html)[KeysRemoveDiff](/content/javadoc/com/rpl/rama/diffs/KeysRemoveDiff.html "class in com.rpl.rama.diffs"/index.html) - Class in com.rpl.rama.diffs

Represents multiple keys being removed from map data structure.

KeysRemoveDiff(Set