MCPcopy Create free account

hub / github.com/cda-group/arcon / functions

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256
↓ 204 callersMethodclone
(&self)
arcon/src/index/hash_table/table.rs:186
↓ 198 callersMethodunwrap
(self)
arcon/src/data/mod.rs:74
↓ 74 callersMethodpush
(&self, value: T, len: usize)
arcon/src/buffer/event/mod.rs:63
↓ 52 callersMethodlen
(&self)
arcon/arcon_state/src/backend/handles.rs:392
↓ 49 callersMethodserialize_metakeys
(&self)
arcon/arcon_state/src/backend/handles.rs:154
↓ 44 callersMethodlen
(&self)
arcon/src/table/mod.rs:124
↓ 42 callersMethoditer
(&self)
arcon/src/index/hash_table/eager.rs:55
↓ 35 callersFunctionserialize
(payload: &impl Message)
arcon/arcon_state/src/backend/serialization.rs:8
↓ 30 callersFunctionserialize_into
(target: &mut impl BufMut, payload: &impl Message)
arcon/arcon_state/src/backend/serialization.rs:15
↓ 29 callersMethodmap
(self, f: F)
arcon/src/dataflow/stream/map.rs:59
↓ 29 callersMethodpush
( &mut self, event: ArconEvent<A>, )
arcon/src/stream/channel/strategy/mod.rs:44
↓ 28 callersMethodas_ptr
(&self)
arcon/src/index/hash_table/table.rs:205
↓ 28 callersMethodcreate
(live_path: &Path, name: String)
arcon/arcon_state/src/backend/sled/mod.rs:70
↓ 28 callersFunctiondeserialize
(bytes: &[u8])
arcon/arcon_state/src/backend/serialization.rs:19
↓ 28 callersFunctiondeserialize_from
(source: &mut impl Buf)
arcon/arcon_state/src/backend/serialization.rs:23
↓ 26 callersFunctionrecord_bytes_written
(handle_name: &str, total_bytes: u64, backend_name: &str)
arcon/arcon_state/src/backend/metrics_utils.rs:4
↓ 24 callersMethodbuild
Build an Arcon application Note that this method only builds the application. In order to start it, see the following [method](Application::run).
arcon/src/application/builder.rs:56
↓ 24 callersMethodget
(&self, id: &OperatorId)
arcon/src/dataflow/dfg.rs:47
↓ 23 callersMethodinto_iter
(self)
arcon/src/buffer/event/mod.rs:278
↓ 21 callersMethodas_ref
(&self)
arcon/src/index/hash_table/table.rs:237
↓ 20 callersMethoddata_system
(&self)
arcon/src/application/mod.rs:208
↓ 20 callersMethodmap
(id: impl Into<String>)
arcon/arcon_state/src/backend/handles.rs:82
↓ 20 callersFunctionwait
(time: u64)
arcon/src/stream/operator/window/assigner.rs:390
↓ 19 callersMethoddb
(&self)
arcon/arcon_state/src/backend/rocks/mod.rs:44
↓ 19 callersMethodname
(&self)
arcon/arcon_state/src/backend/sled/mod.rs:66
↓ 19 callersMethodname
(&self)
arcon/arcon_state/src/backend/rocks/mod.rs:140
↓ 19 callersMethodserialize_metakeys_and_key
(&self, key: &impl Key)
arcon/arcon_state/src/backend/handles.rs:173
↓ 19 callersMethodtree
(&self, tree_name: &str)
arcon/arcon_state/src/backend/sled/mod.rs:24
↓ 18 callersMethodnext
(&mut self)
arcon/src/buffer/event/mod.rs:256
↓ 17 callersMethodinsert
Inserts a [`DFGNode`] into the dataflow graph and returns a unique identifier of it.
arcon/src/dataflow/dfg.rs:39
↓ 16 callersFunctionelement
(data: i32, time: u64, sender: u32)
arcon/src/stream/node/mod.rs:728
↓ 16 callersMethodget_cf_handle
(&self, cf_name: impl AsRef<str>)
arcon/arcon_state/src/backend/rocks/mod.rs:49
↓ 16 callersFunctionserialize_check
(payload: &T)
arcon/arcon_state/src/backend/serialization.rs:80
↓ 16 callersFunctiontimestamped_event
(ts: u64)
arcon/src/stream/operator/window/assigner.rs:396
↓ 14 callersMethodget
( &self, cf_name: impl AsRef<str>, key: impl AsRef<[u8]>, )
arcon/arcon_state/src/backend/rocks/mod.rs:59
↓ 14 callersMethodoperator
( mut self, builder: OperatorBuilder<OP>, )
arcon/src/dataflow/stream/operator.rs:41
↓ 13 callersFunctionnow
()
arcon/src/stream/operator/window/assigner.rs:384
↓ 13 callersMethodreader
(&self)
arcon/src/buffer/event/mod.rs:150
↓ 12 callersMethodactivate
(self, backend: Arc<B>)
arcon/arcon_state/src/backend/handles.rs:237
↓ 12 callersMethodadd
(&self, acc: &mut Self::Accumulator, value: IN)
arcon/src/index/window/incremental.rs:40
↓ 12 callersMethodfinish
internal helper to finish last batch
arcon/src/table/mod.rs:66
↓ 12 callersFunctionrecord_bytes_read
(handle_name: &str, total_bytes: u64, backend_name: &str)
arcon/arcon_state/src/backend/metrics_utils.rs:9
↓ 12 callersMethodto_stream
(self, f: F)
arcon/src/dataflow/source/mod.rs:63
↓ 11 callersMethodas_ptr
Returns a const pointer to the underlying buffer
arcon/src/buffer/event/mod.rs:48
↓ 11 callersFunctionepoch
(epoch: u64, sender: u32)
arcon/src/stream/node/mod.rs:732
↓ 11 callersMethodput
(&mut self, key: K, value: V)
arcon/src/index/hash_table/mod.rs:275
↓ 11 callersMethodstate
(&mut self)
arcon/src/stream/operator/mod.rs:110
↓ 11 callersMethodwith_item_key
(self, item_key: NIK)
arcon/arcon_state/src/backend/handles.rs:117
↓ 10 callersMethodget_pool_info
Internal helper for creating PoolInfo for a ChannelStrategy
arcon/src/application/mod.rs:171
↓ 10 callersMethodmeta
(&self, index: usize)
arcon/src/index/hash_table/table.rs:410
↓ 10 callersMethodput
( &self, cf_name: impl AsRef<str>, key: impl AsRef<[u8]>, value: impl AsRef<[u
arcon/arcon_state/src/backend/rocks/mod.rs:69
↓ 10 callersMethodset_arcon_time
Set [ArconTime] to be used for a Source
arcon/src/dataflow/conf.rs:96
↓ 10 callersMethodset_item_key
(&self, item_key: IK)
arcon/arcon_state/src/backend/handles.rs:138
↓ 10 callersMethodwith_namespace
(self, namespace: NN)
arcon/arcon_state/src/backend/handles.rs:127
↓ 9 callersFunctiondefault_write_opts
we use epochs, so WAL is useless for us
arcon/arcon_state/src/backend/rocks/mod.rs:30
↓ 9 callersMethodinsert
(&self, key: K, value: V)
arcon/arcon_state/src/backend/handles.rs:343
↓ 9 callersMethodremove
(&mut self, k: &K)
arcon/src/index/hash_table/mod.rs:225
↓ 9 callersMethodset_namespace
(&self, namespace: N)
arcon/arcon_state/src/backend/handles.rs:141
↓ 9 callersFunctionsize_hint
(payload: &impl Message)
arcon/arcon_state/src/backend/serialization.rs:27
↓ 9 callersMethodstart
(&mut self)
arcon/src/application/mod.rs:246
↓ 9 callersFunctionwatermark
(time: u64)
arcon/src/stream/operator/window/assigner.rs:393
↓ 9 callersFunctionwatermark
(time: u64, sender: u32)
arcon/src/stream/node/mod.rs:724
↓ 8 callersMethodbuilder
(mut self)
arcon/src/dataflow/sink/mod.rs:141
↓ 8 callersMethodctrl_system
(&self)
arcon/src/application/mod.rs:212
↓ 8 callersFunctionh2
(hash: u64)
arcon/src/index/hash_table/table.rs:87
↓ 8 callersMethodmod_bucket
(&self, index: usize)
arcon/src/index/hash_table/table.rs:426
↓ 8 callersFunctionsend
( channel: &Channel<A>, message: ArconMessage<A>, source: &impl ComponentDefinition, )
arcon/src/stream/channel/strategy/mod.rs:78
↓ 8 callersMethodtake
(&mut self)
arcon/src/index/value/mod.rs:54
↓ 8 callersFunctionwindow_assigner_test_setup
helper functions
arcon/src/stream/operator/window/assigner.rs:258
↓ 7 callersMethodcurrent_time
(&self)
arcon/src/stream/node/timer.rs:135
↓ 7 callersMethodget
(&self, tree_name: &str, key: &[u8])
arcon/arcon_state/src/backend/sled/mod.rs:28
↓ 7 callersMethodget
(&self, key: &K)
arcon/src/index/hash_table/mod.rs:246
↓ 7 callersMethodis_empty
(&self)
arcon/arcon_state/src/backend/handles.rs:397
↓ 7 callersMethodis_empty
(&self)
arcon/src/table/mod.rs:127
↓ 7 callersMethodmatch_byte
(self, byte: u8)
arcon/src/index/hash_table/sse2.rs:52
↓ 7 callersMethodput
(&self, tree_name: &str, key: &[u8], value: &[u8])
arcon/arcon_state/src/backend/sled/mod.rs:34
↓ 7 callersMethodraw_table_mut
(&self)
arcon/src/index/hash_table/mod.rs:135
↓ 7 callersMethodremove
(&self, tree_name: &str, key: &[u8])
arcon/arcon_state/src/backend/sled/mod.rs:40
↓ 7 callersMethodremove
(&self, cf: impl AsRef<str>, key: impl AsRef<[u8]>)
arcon/arcon_state/src/backend/rocks/mod.rs:82
↓ 7 callersMethodrun
Run the application without blocking Note that if this method called more than once, it will panic!
arcon/src/application/mod.rs:242
↓ 7 callersMethodset
(mut self, key: &str, value: &str)
arcon/src/stream/source/kafka.rs:55
↓ 7 callersFunctionvalue
(c: &mut Criterion)
arcon/benches/value.rs:9
↓ 7 callersFunctionwait
(time: u64)
arcon/src/stream/node/mod.rs:739
↓ 7 callersMethodwrite
(&self, val: T)
arcon/src/index/hash_table/table.rs:233
↓ 6 callersMethodappend
(&mut self, _: V)
arcon/src/index/appender/mod.rs:88
↓ 6 callersMethodcontains
(&self, k: &K)
arcon/src/index/hash_table/eager.rs:51
↓ 6 callersMethodcreate_accumulator
(&self)
arcon/arcon_state/src/backend/test_common.rs:12
↓ 6 callersMethoddealloc
Deallocate memory through the given AllocId # Safety It is up to the caller to ensure that the given AllocId is active
arcon/arcon_allocator/src/lib.rs:138
↓ 6 callersMethoddebug
(mut self)
arcon/src/dataflow/sink/mod.rs:98
↓ 6 callersMethoditer
(&self)
arcon/arcon_state/src/backend/handles.rs:378
↓ 6 callersFunctionmap
(c: &mut Criterion)
arcon/benches/hash_table.rs:90
↓ 6 callersFunctionnode_test_setup
()
arcon/src/stream/node/mod.rs:625
↓ 6 callersMethodprobe_mod
(&self, hash: u64)
arcon/src/index/hash_table/table.rs:445
↓ 6 callersFunctionrepeat
(byte: u8)
arcon/src/index/hash_table/generic.rs:31
↓ 6 callersFunctiontimestamped_keyed_event
(ts: u64, id: u64)
arcon/src/stream/operator/window/assigner.rs:399
↓ 6 callersMethodtry_get
(&mut self)
arcon/src/buffer/event/mod.rs:364
↓ 5 callersMethodadd_outgoing_event
(&self, event: ArconEvent<OP::OUT>)
arcon/src/stream/node/mod.rs:456
↓ 5 callersMethodappend
(&mut self, elem: impl ToArrow, timestamp: Option<u64>)
arcon/src/table/mod.rs:44
↓ 5 callersMethodcreate_column_family
(&self, cf_name: &str, opts: Options)
arcon/arcon_state/src/backend/rocks/mod.rs:116
↓ 5 callersMethodeq
(&self, other: &Self)
arcon/src/data/mod.rs:349
next →1–100 of 948, ranked by callers