MCPcopy Create free account

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

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256
↓ 1 callersFunctioncompile_protos
Compile Protobuf files with Arcon configured attributes
arcon_build/src/lib.rs:44
↓ 1 callersMethodcontains
(&self, tree_name: &str, key: &[u8])
arcon/arcon_state/src/backend/sled/mod.rs:59
↓ 1 callersMethodcopy_from_writer
Copy data from another BufferWriter
arcon/src/buffer/event/mod.rs:158
↓ 1 callersMethodcreate_backend
(&self, node_descriptor: String, mut state_dir: PathBuf)
arcon/src/dataflow/constructor.rs:307
↓ 1 callersMethodcreate_debug_node
(&self, application: &mut Application)
arcon/src/dataflow/constructor.rs:289
↓ 1 callersMethodcreate_node_component
( &self, application: &mut Application, node: Node<OP, B>, node_manager: &Arc<
arcon/src/dataflow/constructor.rs:263
↓ 1 callersMethodcreate_node_manager
Initializes things like state directory and NodeManager
arcon/src/dataflow/constructor.rs:314
↓ 1 callersMethodcreate_source_manager
Source Manager needs to be (re-)inserted after calling this function
arcon/src/dataflow/constructor.rs:370
↓ 1 callersMethodctrl_system_conf
(&self)
arcon/src/application/conf/mod.rs:167
↓ 1 callersFunctionctrl_system_host_default
()
arcon/src/application/conf/mod.rs:314
↓ 1 callersMethodcurrent_time
(&mut self)
arcon/src/stream/operator/mod.rs:125
↓ 1 callersMethoddata_end
(&self)
arcon/src/index/hash_table/table.rs:384
↓ 1 callersMethoddata_system_conf
Returns a KompactConfig based on loaded ApplicationConf
arcon/src/application/conf/mod.rs:197
↓ 1 callersMethoddb_mut
(&self)
arcon/arcon_state/src/backend/rocks/mod.rs:39
↓ 1 callersMethoddebug_node_enabled
(&self)
arcon/src/application/mod.rs:188
↓ 1 callersFunctionderive_arcon
(input: TokenStream)
arcon_macros/src/arcon.rs:8
↓ 1 callersFunctionderive_arrow
(input: TokenStream)
arcon_macros/src/arrow.rs:4
↓ 1 callersFunctionderive_decoder
Implements [FromStr](std::str::FromStr) for a struct using a delimiter If no delimiter is specified, then `,` is chosen as default. Note: All inner f
arcon_macros/src/decoder.rs:8
↓ 1 callersFunctionderive_proto
(item: pm::TokenStream)
arcon_macros/src/proto.rs:6
↓ 1 callersFunctionderive_state
(input: TokenStream)
arcon_macros/src/state.rs:4
↓ 1 callersMethoddrain_modified
(&self, iter: ProbeModIterator<K, V>)
arcon/src/index/hash_table/mod.rs:331
↓ 1 callersMethoddrop
(&self)
arcon/src/index/hash_table/table.rs:225
↓ 1 callersFunctionepoch_interval_default
()
arcon/src/application/conf/mod.rs:274
↓ 1 callersFunctionexecution_mode_default
()
arcon/src/application/conf/mod.rs:259
↓ 1 callersMethodfast_remove
(&self, key: &K)
arcon/arcon_state/src/backend/handles.rs:366
↓ 1 callersMethodfast_set
(&mut self, value: T)
arcon/arcon_state/src/backend/handles.rs:311
↓ 1 callersMethodfast_set_by_ref
(&mut self, value: &T)
arcon/arcon_state/src/backend/handles.rs:315
↓ 1 callersMethodfind
(&self, hash: u64, mut eq: impl FnMut((&K, &V)) -> bool)
arcon/src/index/hash_table/table.rs:669
↓ 1 callersMethodflush
(&mut self, source: &CD)
arcon/src/stream/channel/strategy/broadcast.rs:116
↓ 1 callersMethodfree_buckets
(&mut self)
arcon/src/index/hash_table/table.rs:371
↓ 1 callersMethodfull_iter
(&mut self)
arcon/src/index/hash_table/mod.rs:336
↓ 1 callersMethodget
(&self)
arcon/src/index/value/eager.rs:52
↓ 1 callersMethodget
(&self)
arcon/src/index/value/local.rs:66
↓ 1 callersMethodget_hardware_kind
(&self)
arcon/src/metrics/perf_event.rs:24
↓ 1 callersMethodget_in_key
(&self, e: &OP::IN)
arcon/src/stream/node/mod.rs:323
↓ 1 callersMethodget_input_channels
Returns a vector of NodeID's which this node will receive messages from
arcon/src/dataflow/dfg.rs:89
↓ 1 callersFunctionget_len
Utility to consume the first few bytes from the slice and interpret that as length. The passed slice will get shifted so it points right after the len
arcon/arcon_state/src/backend/sled/vec_ops.rs:210
↓ 1 callersFunctionget_len
Utility to consume the first few bytes from the slice and interpret that as length. The passed slice will get shifted so it points right after the len
arcon/arcon_state/src/backend/rocks/vec_ops.rs:214
↓ 1 callersFunctionget_systems
()
arcon/src/data/flight_serde.rs:147
↓ 1 callersFunctionget_table
( attr: &syn::Attribute, ident: &Option<syn::Ident>, )
arcon_macros/src/state.rs:133
↓ 1 callersFunctionget_table_id
(attr: &syn::Attribute)
arcon_macros/src/state.rs:120
↓ 1 callersMethodget_time
(&self)
arcon/src/stream/node/timer.rs:270
↓ 1 callersMethodhandle
(&mut self, _: ())
arcon/src/stream/node/mod.rs:554
↓ 1 callersMethodhandle
(&mut self, _: Never)
arcon/src/manager/node.rs:191
↓ 1 callersMethodhandle_element
(&mut self, e: ArconElement<OP::IN>)
arcon/src/stream/node/mod.rs:332
↓ 1 callersMethodhandle_epoch
(&mut self, e: Epoch, sender: NodeID)
arcon/src/stream/node/mod.rs:406
↓ 1 callersMethodhandle_epoch_commit
(&mut self, commit: EpochCommit)
arcon/src/manager/snapshot.rs:72
↓ 1 callersMethodhandle_epoch_event
(&mut self, event: EpochEvent)
arcon/src/manager/epoch.rs:82
↓ 1 callersMethodhandle_node_event
(&mut self, event: NodeManagerEvent)
arcon/src/manager/node.rs:150
↓ 1 callersMethodhandle_source_error
(&self, source_error: SourceError)
arcon/src/stream/node/source.rs:155
↓ 1 callersMethodhandle_source_event
(&mut self, event: SourceEvent)
arcon/src/stream/node/source.rs:194
↓ 1 callersMethodhandle_timeout
( &mut self, timeout: Self::TimerState, ctx: &mut OperatorContext<Self::TimerState, Se
arcon/src/stream/operator/window/assigner.rs:209
↓ 1 callersMethodhandle_watermark
(&mut self, w: Watermark, sender: NodeID)
arcon/src/stream/node/mod.rs:350
↓ 1 callersMethodhas_snapshot_state
(&self)
arcon/src/manager/node.rs:146
↓ 1 callersMethodindex_incr
(&mut self)
arcon/src/buffer/event/mod.rs:394
↓ 1 callersMethodinit_state_dir
(&self, path: &Path)
arcon/src/dataflow/constructor.rs:339
↓ 1 callersMethodinsert_read_lane
(&self, k: K, v: V, hash: u64)
arcon/src/index/hash_table/mod.rs:157
↓ 1 callersFunctionis_ephemeral
(attr: &syn::Attribute)
arcon_macros/src/state.rs:116
↓ 1 callersFunctionkompact_chunk_size_default
()
arcon/src/application/conf/mod.rs:330
↓ 1 callersFunctionkompact_encode_buf_min_free_space_default
()
arcon/src/application/conf/mod.rs:342
↓ 1 callersFunctionkompact_initial_chunk_count_default
()
arcon/src/application/conf/mod.rs:338
↓ 1 callersFunctionkompact_max_chunk_count_default
()
arcon/src/application/conf/mod.rs:334
↓ 1 callersFunctionkompact_msg_priority_default
()
arcon/src/application/conf/mod.rs:322
↓ 1 callersFunctionkompact_network_host_default
()
arcon/src/application/conf/mod.rs:326
↓ 1 callersFunctionkompact_threads_default
()
arcon/src/application/conf/mod.rs:310
↓ 1 callersFunctionkompact_throughput_default
()
arcon/src/application/conf/mod.rs:318
↓ 1 callersMethodlen
(&self)
arcon/src/index/appender/eager.rs:72
↓ 1 callersMethodlowest_set_bit_nonzero
(self)
arcon/src/index/hash_table/bitmask.rs:58
↓ 1 callersFunctionmain
(args: TokenStream, item: TokenStream)
arcon_macros/src/app.rs:117
↓ 1 callersFunctionmake_aggregator_merge
(aggregator: A)
arcon/arcon_state/src/backend/sled/aggregator_ops.rs:65
↓ 1 callersFunctionmake_aggregator_merge
(aggregator: A)
arcon/arcon_state/src/backend/rocks/aggregator_ops.rs:69
↓ 1 callersFunctionmake_reducer_merge
(reduce_fn: F)
arcon/arcon_state/src/backend/sled/reducer_ops.rs:58
↓ 1 callersFunctionmake_reducer_merge
(reduce_fn: F)
arcon/arcon_state/src/backend/rocks/reducer_ops.rs:57
↓ 1 callersMethodmap_clear
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:16
↓ 1 callersMethodmap_contains
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )
arcon/arcon_state/src/backend/sled/map_ops.rs:152
↓ 1 callersMethodmap_fast_insert
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: K, value: V, )
arcon/arcon_state/src/backend/sled/map_ops.rs:40
↓ 1 callersMethodmap_fast_insert_by_ref
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, value: &V, )
arcon/arcon_state/src/backend/sled/map_ops.rs:55
↓ 1 callersMethodmap_fast_remove
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )
arcon/arcon_state/src/backend/sled/map_ops.rs:141
↓ 1 callersMethodmap_get
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )
arcon/arcon_state/src/backend/sled/map_ops.rs:24
↓ 1 callersMethodmap_in_place
(self, f: F)
arcon/src/dataflow/stream/map.rs:67
↓ 1 callersMethodmap_insert
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: K, value: V, )
arcon/arcon_state/src/backend/sled/map_ops.rs:70
↓ 1 callersMethodmap_insert_all
( &self, handle: &Handle<MapState<K, V>, IK, N>, key_value_pairs: impl IntoIterator<It
arcon/arcon_state/src/backend/sled/map_ops.rs:89
↓ 1 callersMethodmap_insert_all_by_ref
( &self, handle: &Handle<MapState<K, V>, IK, N>, key_value_pairs: impl IntoIterator<It
arcon/arcon_state/src/backend/sled/map_ops.rs:108
↓ 1 callersMethodmap_is_empty
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:230
↓ 1 callersMethodmap_iter
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:161
↓ 1 callersMethodmap_keys
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:182
↓ 1 callersMethodmap_len
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:219
↓ 1 callersMethodmap_remove
( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )
arcon/arcon_state/src/backend/sled/map_ops.rs:127
↓ 1 callersMethodmap_values
( &self, handle: &Handle<MapState<K, V>, IK, N>, )
arcon/arcon_state/src/backend/sled/map_ops.rs:202
↓ 1 callersMethodmatch_full
(self)
arcon/src/index/hash_table/generic.rs:133
↓ 1 callersFunctionmax_key_default
()
arcon/src/application/conf/mod.rs:284
↓ 1 callersMethodmeasure
(self, log_freq: u64)
arcon/src/dataflow/sink/mod.rs:112
↓ 1 callersMethodmod_data_end
(&self)
arcon/src/index/hash_table/table.rs:390
↓ 1 callersMethodmod_lane_iter
(&self)
arcon/src/index/hash_table/table.rs:746
↓ 1 callersMethodmodified_iterator
(&mut self)
arcon/src/index/hash_table/mod.rs:346
↓ 1 callersMethodnew_window_trigger
( &mut self, window_ctx: WindowContext, ctx: &mut OperatorContext<WindowEvent, WindowS
arcon/src/stream/operator/window/assigner.rs:111
↓ 1 callersFunctionnode_metrics_interval_default
()
arcon/src/application/conf/mod.rs:288
↓ 1 callersFunctionoffset_from
(to: *const T, from: *const T)
arcon/src/index/hash_table/table.rs:27
↓ 1 callersMethodparallelism
(&self)
arcon/src/dataflow/builder.rs:74
↓ 1 callersFunctionparquet_arrow_reader
( path: impl AsRef<Path>, )
arcon/src/table/mod.rs:335
← previousnext →301–400 of 948, ranked by callers