Serialized Form

Package com.rpl.rama

Class com.rpl.rama.aggs$fn__536383

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

Class com.rpl.rama.aggs$loading__6814__auto____536381

class aggs$loading__6814__auto____536381 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__534729

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

Serialized Fields

accum_op

Object accum_op

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

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

Serialized Fields

afn

Object afn

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

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

Serialized Fields

op

Object op

Class com.rpl.rama.ops$fn__534697

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

Class com.rpl.rama.ops$fn__534699

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

Class com.rpl.rama.ops$loading__6814__auto____534695

class ops$loading__6814__auto____534695 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__512923

class path$fn__512923 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____512921

class path$loading__6814__auto____512921 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$eval549503

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

Class com.rpl.rama.test$eval549503$inlined_path_fn__21138__auto____549504

class test$eval549503$inlined_path_fn__21138__auto____549504 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__549502

Object G__549502

Class com.rpl.rama.test$eval549659

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

Class com.rpl.rama.test$eval549659$inlined_path_fn__21138__auto____549660

class test$eval549659$inlined_path_fn__21138__auto____549660 extends clojure.lang.AFunction implements Serializable

Serialized Fields

G__549658

Object G__549658

Class com.rpl.rama.test$fn__549455

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

Class com.rpl.rama.test$fn__549468

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

Class com.rpl.rama.test$fn__549638

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

Class com.rpl.rama.test$fn__549688

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

Class com.rpl.rama.test$fn__549688$__GT_TestPStateImpl__549718

class test$fn__549688$__GT_TestPStateImpl__549718 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__549688$map__GT_TestPStateImpl__549720

class test$fn__549688$map__GT_TestPStateImpl__549720 extends clojure.lang.AFunction implements Serializable

Class com.rpl.rama.test$fn__549734

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

Class com.rpl.rama.test$fn__549772

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

Class com.rpl.rama.test$fn__549774

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

Class com.rpl.rama.test$fn__549823

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

Class com.rpl.rama.test$fn__549825

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

Class com.rpl.rama.test$fn__549863

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

Class com.rpl.rama.test$fn__549865

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

Class com.rpl.rama.test$fn__549907

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

Class com.rpl.rama.test$fn__549909

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

Class com.rpl.rama.test$fn__549947

class test$fn__549947 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____549453

class test$loading__6814__auto____549453 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__549632

class test$test_pstate_select_one$fn__549632 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__534791

class throttled_logging$fn__534791 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____534789

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