MCPcopy Create free account

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

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256
↓ 5 callersMethodimmutable
Converts the MutableTable into an ImmutableTable
arcon/src/table/mod.rs:75
↓ 5 callersMethodinto_iter
(self)
arcon/src/index/hash_table/bitmask.rs:88
↓ 5 callersMethodmod_buckets
(&self)
arcon/src/index/hash_table/table.rs:711
↓ 5 callersMethodread
(&self)
arcon/src/index/hash_table/table.rs:229
↓ 5 callersMethodread_bucket
(&self, index: usize)
arcon/src/index/hash_table/table.rs:417
↓ 5 callersMethodregister_map_handle
( &self, handle: &mut Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/mod.rs:173
↓ 5 callersMethodset
(&mut self, value: T)
arcon/arcon_state/src/backend/handles.rs:306
↓ 5 callersMethodset_meta
(&self, index: usize, meta: u8)
arcon/src/index/hash_table/table.rs:456
↓ 5 callersMethodset_timestamp_extractor
Set a Timestamp Extractor for a Source
arcon/src/dataflow/conf.rs:100
↓ 5 callersMethodshutdown
Shuts the application down and consumes the struct
arcon/src/application/mod.rs:277
↓ 4 callersMethodaccumulator_into_result
(&self, acc: Self::Accumulator)
arcon/arcon_state/src/backend/test_common.rs:29
↓ 4 callersMethodadd
(&self, acc: &mut Self::Accumulator, value: Self::Input)
arcon/arcon_state/src/backend/test_common.rs:16
↓ 4 callersMethodadd_time
(&mut self, by: u64)
arcon/src/stream/node/timer.rs:141
↓ 4 callersMethodepoch_manager
(&self)
arcon/src/application/mod.rs:195
↓ 4 callersMethodget_mut
(&mut self, id: &OperatorId)
arcon/src/dataflow/dfg.rs:53
↓ 4 callersMethodhash
(&self, state: &mut H)
arcon/src/data/mod.rs:321
↓ 4 callersMethodinsert
(&self, k: K, v: V, hash: u64)
arcon/src/index/hash_table/mod.rs:141
↓ 4 callersFunctionmake_hash
(hash_builder: &impl BuildHasher, val: &K)
arcon/src/index/hash_table/mod.rs:77
↓ 4 callersMethodmatch_modified
(&self)
arcon/src/index/hash_table/sse2.rs:92
↓ 4 callersMethodmetakey_size
(&self)
arcon/arcon_state/src/backend/handles.rs:225
↓ 4 callersMethodmod_ctrl
(&self, index: usize)
arcon/src/index/hash_table/table.rs:403
↓ 4 callersMethodname
(&self)
arcon/src/table/mod.rs:121
↓ 4 callersMethodon_element
(&mut self, element: Self::IN, ctx: WindowContext)
arcon/src/index/window/arrow.rs:65
↓ 4 callersMethodprobe_read
(&self, hash: u64)
arcon/src/index/hash_table/table.rs:434
↓ 4 callersFunctionread_length
(r: &mut impl Read)
arcon/arcon_state/src/backend/sled/mod.rs:230
↓ 4 callersMethodregister_vec_handle
( &self, handle: &mut Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/mod.rs:180
↓ 4 callersMethodresult
(&mut self, ctx: WindowContext)
arcon/src/index/window/arrow.rs:72
↓ 4 callersMethodschema
(&self)
arcon/src/table/mod.rs:130
↓ 4 callersMethodset_channel_kind
(&mut self, channel_kind: ChannelKind)
arcon/src/dataflow/stream/mod.rs:51
↓ 4 callersMethodset_mod_ctrl
(&self, index: usize, ctrl: u8)
arcon/src/index/hash_table/table.rs:461
↓ 4 callersMethodset_read_ctrl
(&self, index: usize, ctrl: u8)
arcon/src/index/hash_table/table.rs:467
↓ 4 callersFunctionshard_lookup
(data: &K, total_shards: u64)
arcon/src/data/partition.rs:23
↓ 4 callersMethodtick
(&mut self)
arcon/src/metrics/ewma.rs:57
↓ 4 callersMethodtick_if_necessary
(&mut self)
arcon/src/metrics/meter.rs:52
↓ 4 callersMethodto_vec
(&self)
arcon/src/buffer/event/mod.rs:218
↓ 3 callersMethodactive_key
(&mut self, key: u64)
arcon/src/stream/node/timer.rs:228
↓ 3 callersMethodadd
(&mut self, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/keyed.rs:94
↓ 3 callersMethodadvance_to
(&mut self, ts: u64)
arcon/src/stream/node/timer.rs:253
↓ 3 callersMethodarcon_conf
Give out a reference to the ApplicationConf of the application
arcon/src/application/mod.rs:180
↓ 3 callersMethodas_slice
(&self)
arcon/src/buffer/event/mod.rs:211
↓ 3 callersFunctionchannel_strategy
( mut components: ErasedComponents, paths: Vec<ActorPath>, node_id: NodeID, pool_info: PoolInf
arcon/src/dataflow/constructor.rs:48
↓ 3 callersMethodclear
(&mut self)
arcon/src/data/mod.rs:424
↓ 3 callersMethodctrl
(&self, index: usize)
arcon/src/index/hash_table/table.rs:396
↓ 3 callersFunctiondeath
(sender: u32)
arcon/src/stream/node/mod.rs:735
↓ 3 callersMethodfilter
(self, f: F)
arcon/src/dataflow/stream/filter.rs:31
↓ 3 callersMethodflat_map
(self, f: F)
arcon/src/dataflow/stream/map.rs:75
↓ 3 callersMethodget_node_ids
Returns a vector of NodeID's for this node
arcon/src/dataflow/dfg.rs:94
↓ 3 callersMethodget_rate
(&self)
arcon/src/metrics/ewma.rs:71
↓ 3 callersFunctionget_system_time
()
arcon/src/util/mod.rs:11
↓ 3 callersFunctionget_system_time_nano
()
arcon/src/util/mod.rs:22
↓ 3 callersMethodhandle_events
(&mut self, sender: NodeID, events: I)
arcon/src/stream/node/mod.rs:289
↓ 3 callersMethodignore
(mut self)
arcon/src/dataflow/sink/mod.rs:105
↓ 3 callersMethodinvert
(self)
arcon/src/index/hash_table/bitmask.rs:27
↓ 3 callersMethodlen
(&self)
arcon/src/buffer/event/mod.rs:170
↓ 3 callersMethodlowest_set_bit
(self)
arcon/src/index/hash_table/bitmask.rs:46
↓ 3 callersMethodmark_n
(&mut self, n: u64)
arcon/src/metrics/meter.rs:43
↓ 3 callersMethodmatch_empty
(self)
arcon/src/index/hash_table/sse2.rs:70
↓ 3 callersMethodmatch_full
(&self)
arcon/src/index/hash_table/sse2.rs:86
↓ 3 callersMethodmessage
(&mut self)
arcon/src/stream/channel/strategy/broadcast.rs:70
↓ 3 callersMethodmessage
(&mut self)
arcon/src/stream/channel/strategy/forward.rs:85
↓ 3 callersFunctionoperator_conf
()
arcon/src/test/keyby_integration.rs:36
↓ 3 callersMethodprint
(mut self)
arcon/src/dataflow/sink/mod.rs:91
↓ 3 callersMethodraw_table
(&self)
arcon/src/index/hash_table/mod.rs:128
↓ 3 callersMethodread_buckets
(&self)
arcon/src/index/hash_table/table.rs:717
↓ 3 callersFunctionread_bytes_starting_with_len
(r: &mut impl Read)
arcon/arcon_state/src/backend/sled/mod.rs:240
↓ 3 callersMethodregister_value_handle
( &self, handle: &mut Handle<ValueState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/mod.rs:166
↓ 3 callersMethodsend_event
(&mut self, event: ArconEvent<S::Item>)
arcon/src/stream/node/source.rs:184
↓ 3 callersMethodserialize_metakeys_into
(&self, dest: &mut impl BufMut)
arcon/arcon_state/src/backend/handles.rs:146
↓ 3 callersMethodset_key
(&mut self, _: u64)
arcon/src/index/mod.rs:83
↓ 3 callersMethodset_key
(&mut self, key: u64)
arcon/src/index/value/mod.rs:81
↓ 3 callersMethodset_lane_byte
(&self, index: usize, ctrl: u8, ptr: *mut u8, mask: usize)
arcon/src/index/hash_table/table.rs:475
↓ 3 callersFunctionsetup
( builder: OperatorBuilder<OP, B>, )
arcon/src/stream/node/mod.rs:636
↓ 3 callersFunctionsource_to_stream
(builder_type: SourceBuilderType<S, B>)
arcon/src/dataflow/source/mod.rs:40
↓ 3 callersFunctiontemp_backend
()
arcon/src/lib.rs:149
↓ 3 callersFunctiontest_table
()
arcon/src/table/mod.rs:356
↓ 3 callersMethodtopic
(&self)
arcon/src/stream/source/kafka.rs:63
↓ 3 callersMethodtotal_rows
(&self)
arcon/src/table/mod.rs:159
↓ 3 callersMethodupdate
(&mut self, n: u64)
arcon/src/metrics/ewma.rs:52
↓ 3 callersMethodvalue
(self)
arcon/src/stream/node/timer.rs:56
↓ 3 callersMethodvalues
(&self)
arcon/arcon_state/src/backend/handles.rs:386
↓ 3 callersFunctionwait
(millis: u64)
arcon/src/stream/operator/function/mod.rs:15
↓ 2 callersMethodadd
(&mut self, hardware_metric_kind: HardwareCounter)
arcon/src/metrics/perf_event.rs:68
↓ 2 callersFunctionadd_outgoing_event
( event: ArconEvent<OUT>, strategy: &mut ChannelStrategy<OUT>, cd: &impl ComponentDefinition, )
arcon/src/stream/node/common.rs:10
↓ 2 callersMethodalloc_err
(self, layout: Layout)
arcon/src/index/hash_table/table.rs:51
↓ 2 callersMethodas_mut
(&self)
arcon/src/index/hash_table/table.rs:241
↓ 2 callersMethodas_mut_ptr
Returns a mutable pointer to the underlying buffer
arcon/src/buffer/event/mod.rs:53
↓ 2 callersMethodbackend_get
(&self, k: &K)
arcon/src/index/hash_table/mod.rs:164
↓ 2 callersMethodbatches
(&mut self)
arcon/src/table/mod.rs:86
↓ 2 callersFunctionbuffer_pool_multi_threaded
(buffer_size: usize)
arcon/benches/buffer_pool.rs:88
↓ 2 callersFunctionbuffer_pool_single_thread
(b: &mut Bencher, buffer_size: usize)
arcon/benches/buffer_pool.rs:69
↓ 2 callersFunctionbuffer_pool_size_default
()
arcon/src/application/conf/mod.rs:293
↓ 2 callersMethodcapacity_overflow
(self)
arcon/src/index/hash_table/table.rs:42
↓ 2 callersFunctioncheck_map_result
helper to check common result between Map/MapInPlace
arcon/src/stream/operator/function/mod.rs:48
↓ 2 callersMethodcheckpoint
(&self, checkpoint_path: &Path)
arcon/arcon_state/src/backend/rocks/mod.rs:220
↓ 2 callersMethodclear
(&mut self)
arcon/src/index/value/mod.rs:58
↓ 2 callersMethodconfig
Sets the configuration that is used during the build phase
arcon/src/application/builder.rs:47
↓ 2 callersMethodconsume
(&mut self)
arcon/src/index/appender/mod.rs:92
↓ 2 callersMethodcontains
(&self, cf: impl AsRef<str>, key: impl AsRef<[u8]>)
arcon/arcon_state/src/backend/rocks/mod.rs:111
↓ 2 callersMethodconvert_mod_to_safe
(self, ptr: *mut u8)
arcon/src/index/hash_table/sse2.rs:103
↓ 2 callersFunctioncreate_shards
(total: u64)
arcon/src/data/partition.rs:7
← previousnext →101–200 of 948, ranked by callers