Serialized Form

Package com.rpl.rama

Class com.rpl.rama.aggs$fn__534585

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

Class com.rpl.rama.aggs$loading__6814__auto____534583

class aggs$loading__6814__auto____534583 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__532931

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

Serialized Fields

accum_op

Object accum_op

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

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

Serialized Fields

afn

Object afn

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

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

Serialized Fields

op

Object op

Class com.rpl.rama.ops$fn__532899

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

Class com.rpl.rama.ops$fn__532901

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

Class com.rpl.rama.ops$loading__6814__auto____532897

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

Class com.rpl.rama.ops$random_uuid7

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

Class com.rpl.rama.path$fn__511129

class path$fn__511129 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____511127

class path$loading__6814__auto____511127 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$eval547705

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

Class com.rpl.rama.test$eval547705$inlined_path_fn__21135__auto____547706

class test$eval547705$inlined_path_fn__21135__auto____547706 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__547704

Object G__547704

Class com.rpl.rama.test$eval547861

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

Class com.rpl.rama.test$eval547861$inlined_path_fn__21135__auto____547862

class test$eval547861$inlined_path_fn__21135__auto____547862 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__547860

Object G__547860

Class com.rpl.rama.test$fn__547657

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

Class com.rpl.rama.test$fn__547670

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

Class com.rpl.rama.test$fn__547840

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

Class com.rpl.rama.test$fn__547890

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

Class com.rpl.rama.test$fn__547890$__GT_TestPStateImpl__547920

class test$fn__547890$__GT_TestPStateImpl__547920 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__547890$map__GT_TestPStateImpl__547922

class test$fn__547890$map__GT_TestPStateImpl__547922 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__547936

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

Class com.rpl.rama.test$fn__547974

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

Class com.rpl.rama.test$fn__547976

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

Class com.rpl.rama.test$fn__548025

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

Class com.rpl.rama.test$fn__548027

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

Class com.rpl.rama.test$fn__548065

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

Class com.rpl.rama.test$fn__548067

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

Class com.rpl.rama.test$fn__548109

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

Class com.rpl.rama.test$fn__548111

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

Class com.rpl.rama.test$fn__548149

class test$fn__548149 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____547655

class test$loading__6814__auto____547655 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__547834

class test$test_pstate_select_one$fn__547834 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__532993

class throttled_logging$fn__532993 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____532991

class throttled_logging$loading__6814__auto____532991 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