Serialized Form

Package com.rpl.rama

Class com.rpl.rama.aggs$fn__517665

class aggs$fn__517665 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.aggs$loading__6814__auto____517663

class aggs$loading__6814__auto____517663 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.ModuleInstanceInfo

class ModuleInstanceInfo extends Object implements Serializable

Serialized Fields

_moduleInstanceId

String _moduleInstanceId

_moduleName

String _moduleName

_numTasks

int _numTasks

_port

int _port

_replicationFactor

int _replicationFactor

_supervisorId

String _supervisorId

_taskThreadIds

Set<Integer> _taskThreadIds

Class com.rpl.rama.ops$agg__GT_init_fn

class ops$agg__GT_init_fn extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.ops$agg__GT_update_fn

class ops$agg__GT_update_fn extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.ops$agg__GT_update_fn$fn__516084

class ops$agg__GT_update_fn$fn__516084 extends clojure.lang.RestFn implements Serializable

Serialized Fields

accum_op

Object accum_op

Class com.rpl.rama.ops$agg__GT_update_fn$fn__516086

class ops$agg__GT_update_fn$fn__516086 extends clojure.lang.RestFn implements Serializable

Serialized Fields

afn

Object afn

Class com.rpl.rama.ops$agg__GT_update_fn$fn__516088

class ops$agg__GT_update_fn$fn__516088 extends clojure.lang.RestFn implements Serializable

Serialized Fields

op

Object op

Class com.rpl.rama.ops$fn__516052

class ops$fn__516052 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.ops$fn__516054

class ops$fn__516054 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.ops$loading__6814__auto____516050

class ops$loading__6814__auto____516050 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.path$fn__494586

class path$fn__494586 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.path$java_path__GT_clojure_path

class path$java_path__GT_clojure_path extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.path$loading__6814__auto____494584

class path$loading__6814__auto____494584 extends clojure.lang.AFunction implements Serializable

Exception Class com.rpl.rama.RamaCompileException

class RamaCompileException extends RuntimeException implements Serializable

Class com.rpl.rama.SortedRangeFromOptions.CapturedSortedRangeFromOptions

class CapturedSortedRangeFromOptions extends Object implements Serializable

Serialized Fields

_include

boolean _include

_maxAmt

Integer _maxAmt

Class com.rpl.rama.SortedRangeOptions.CapturedSortedRangeOptions

class CapturedSortedRangeOptions extends Object implements Serializable

Serialized Fields

_includeEnd

boolean _includeEnd

_includeStart

boolean _includeStart

Class com.rpl.rama.SortedRangeToOptions.CapturedSortedRangeToOptions

class CapturedSortedRangeToOptions extends Object implements Serializable

Serialized Fields

_include

boolean _include

_maxAmt

Integer _maxAmt

Class com.rpl.rama.test$convert_launch_config

class test$convert_launch_config extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$convert_update_options

class test$convert_update_options extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$create_ipc

class test$create_ipc extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$create_test_pstate

class test$create_test_pstate extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$create_test_pstate_STAR_

class test$create_test_pstate_STAR_ extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.test$destroy_module_BANG_

class test$destroy_module_BANG_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$eval530705

class test$eval530705 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$eval530705$inlined_path_fn__14684__auto____530706

class test$eval530705$inlined_path_fn__14684__auto____530706 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__530704

Object G__530704

Class com.rpl.rama.test$eval530861

class test$eval530861 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$eval530861$inlined_path_fn__14684__auto____530862

class test$eval530861$inlined_path_fn__14684__auto____530862 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__530860

Object G__530860

Class com.rpl.rama.test$fn__530657

class test$fn__530657 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530670

class test$fn__530670 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530840

class test$fn__530840 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530890

class test$fn__530890 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530890$__GT_TestPStateImpl__530920

class test$fn__530890$__GT_TestPStateImpl__530920 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530890$map__GT_TestPStateImpl__530922

class test$fn__530890$map__GT_TestPStateImpl__530922 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530936

class test$fn__530936 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530985

class test$fn__530985 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__530987

class test$fn__530987 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__531025

class test$fn__531025 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__531027

class test$fn__531027 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__531069

class test$fn__531069 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__531071

class test$fn__531071 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__531109

class test$fn__531109 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$gen_hashing_index_keys

class test$gen_hashing_index_keys extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$hook_COLON_TestPStateImpl_local_transform_GT__STAR_

class test$hook_COLON_TestPStateImpl_local_transform_GT__STAR_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$launch_module_BANG_

class test$launch_module_BANG_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$loading__6814__auto____530655

class test$loading__6814__auto____530655 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$pause_microbatch_topology_BANG_

class test$pause_microbatch_topology_BANG_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$resume_microbatch_topology_BANG_

class test$resume_microbatch_topology_BANG_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$test_pstate_select_one

class test$test_pstate_select_one extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$test_pstate_select_one$fn__530834

class test$test_pstate_select_one$fn__530834 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$update_module_BANG_

class test$update_module_BANG_ extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$wait_for_microbatch_processed_count

class test$wait_for_microbatch_processed_count extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.throttled_logging$debug

class throttled_logging$debug extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.throttled_logging$error

class throttled_logging$error extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.throttled_logging$fatal

class throttled_logging$fatal extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.throttled_logging$fn__516145

class throttled_logging$fn__516145 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.throttled_logging$info

class throttled_logging$info extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.throttled_logging$loading__6814__auto____516143

class throttled_logging$loading__6814__auto____516143 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.throttled_logging$logp

class throttled_logging$logp extends clojure.lang.RestFn implements Serializable

Class com.rpl.rama.throttled_logging$warn

class throttled_logging$warn extends clojure.lang.RestFn implements Serializable

Package com.rpl.rama.integration

Package com.rpl.rama.object

Class com.rpl.rama.object.DepotPartitionInfo

class DepotPartitionInfo extends Object implements Serializable

Serialized Fields

endOffset

long endOffset

startOffset

long startOffset

Class com.rpl.rama.object.PartitionedObjectInfo

class PartitionedObjectInfo extends Object implements Serializable

Serialized Fields

moduleName

String moduleName

name

String name

numPartitions

long numPartitions

Package com.rpl.rama.ops

Package com.rpl.rama.test

Class com.rpl.rama.test.TestPStateImpl

class TestPStateImpl extends Object implements Serializable

Serialized Fields

__extmap

Object __extmap

__hash

int __hash

__hasheq

int __hasheq

__meta

Object __meta

clean_root_dir_QMARK_

Object clean_root_dir_QMARK_

resources

Object resources

root_dir

Object root_dir

state

Object state