MCPcopy Create free account

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

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256
↓ 2 callersFunctioncreate_source_node
helper function to create source node..
arcon/src/dataflow/constructor.rs:476
↓ 2 callersMethodencoded_len
(&self)
arcon/src/data/mod.rs:420
↓ 2 callersFunctionenriched_event_stream
Sets up a pipeline of iterator -> event -> key_by -> enriched_event
arcon/src/test/keyby_integration.rs:44
↓ 2 callersMethodepoch
Creates an ArconMessage with a single [ArconEvent::Epoch] event This function should only be used for development and test purposes.
arcon/src/data/mod.rs:222
↓ 2 callersMethodfast_insert
(&self, key: K, value: V)
arcon/arcon_state/src/backend/handles.rs:338
↓ 2 callersFunctionfile_logger
(log_path: &str)
arcon/src/application/conf/logger.rs:40
↓ 2 callersMethodfind_insert_slot
( &self, probe: impl Iterator<Item = usize>, mask: usize, ptr: *mut u8, )
arcon/src/index/hash_table/table.rs:501
↓ 2 callersMethodfind_mod_lane_mut
( &mut self, hash: u64, mut eq: impl FnMut((&K, &V)) -> bool, )
arcon/src/index/hash_table/table.rs:613
↓ 2 callersMethodget
(&self)
arcon/arcon_state/src/backend/handles.rs:301
↓ 2 callersMethodget
(&self)
arcon/src/index/value/mod.rs:49
↓ 2 callersMethodget_key
(&self, event: &T)
arcon/src/dataflow/builder.rs:116
↓ 2 callersMethodget_operator_id
(&self)
arcon/src/dataflow/dfg.rs:111
↓ 2 callersFunctionget_prost_field_attr
Synthesizes a prost field-attribute with an optional tag from a Rust type. For example: `ty = i32`, `tag = None` becomes `#[prost(int32)]`. `ty = i32
arcon_macros/src/proto.rs:94
↓ 2 callersFunctionh1
(hash: u64)
arcon/src/index/hash_table/table.rs:79
↓ 2 callersMethodhandle_events
(&mut self, events: I)
arcon/src/stream/node/debug.rs:39
↓ 2 callersMethodhandle_message
(&mut self, message: MessageContainer<OP::IN>)
arcon/src/stream/node/mod.rs:213
↓ 2 callersFunctionindex_rolling_counter
(backend: BackendType, b: &mut Bencher)
arcon/benches/value.rs:34
↓ 2 callersMethodinsert_all_by_ref
( &self, key_value_pairs: impl IntoIterator<Item = (&'a K, &'a V)>, )
arcon/arcon_state/src/backend/handles.rs:352
↓ 2 callersMethodinsert_mod_lane
( &mut self, hash: u64, value: (K, V), )
arcon/src/index/hash_table/table.rs:559
↓ 2 callersMethodinsert_read_lane
(&mut self, hash: u64, record: (K, V))
arcon/src/index/hash_table/table.rs:519
↓ 2 callersFunctionis_safe
(meta: u8)
arcon/src/index/hash_table/table.rs:72
↓ 2 callersMethoditer_modified
(&mut self)
arcon/src/index/hash_table/table.rs:737
↓ 2 callersMethodkey
(&self)
arcon/src/stream/node/timer.rs:52
↓ 2 callersMethodkey_by
( mut self, key_extractor: F, )
arcon/src/dataflow/stream/partition.rs:30
↓ 2 callersFunctionkey_hasher
()
arcon_util/src/lib.rs:10
↓ 2 callersMethodkeys
(&self)
arcon/arcon_state/src/backend/handles.rs:382
↓ 2 callersMethodkompact_logger
(&self)
arcon/src/application/conf/mod.rs:153
↓ 2 callersMethodlen
(&self)
arcon/src/index/hash_table/mod.rs:215
↓ 2 callersMethodload
unaligned load
arcon/src/index/hash_table/sse2.rs:35
↓ 2 callersMethodmatch_empty_or_deleted
(self)
arcon/src/index/hash_table/generic.rs:126
↓ 2 callersMethodmerge_accumulators
( &self, mut fst: Self::Accumulator, mut snd: Self::Accumulator, )
arcon/arcon_state/src/backend/test_common.rs:20
↓ 2 callersFunctionmeta_layout
Returns a Layout which describes the meta bytes of the hash table.
arcon/src/index/hash_table/table.rs:165
↓ 2 callersMethodmod_ctrl_bytes
(&self)
arcon/src/index/hash_table/table.rs:729
↓ 2 callersMethodmove_last_node
Move the optional last_node/source-Factory into the DFG struct, will no longer be mutable after this.
arcon/src/dataflow/stream/mod.rs:40
↓ 2 callersFunctionnaive_rolling_counter
(backend: BackendType, b: &mut Bencher)
arcon/benches/value.rs:94
↓ 2 callersMethodnext
(&mut self)
arcon/src/index/hash_table/table.rs:117
↓ 2 callersMethodnext_n
(&self, offset: usize)
arcon/src/index/hash_table/table.rs:214
↓ 2 callersMethodoutput
(&mut self, data: S::Item, timestamp: u64)
arcon/src/stream/node/source.rs:176
↓ 2 callersFunctionparse_knobs
(mut input: syn::ItemFn, config: ExecutionConfig)
arcon_macros/src/app.rs:133
↓ 2 callersMethodpersist
(&mut self)
arcon/src/index/mod.rs:80
↓ 2 callersMethodpoll_next
(&mut self)
arcon/src/stream/source/mod.rs:41
↓ 2 callersMethodprocess
(&mut self)
arcon/src/stream/node/source.rs:101
↓ 2 callersMethodpush_event
(&mut self, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/broadcast.rs:62
↓ 2 callersMethodpush_event
(&mut self, index: usize, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/keyed.rs:74
↓ 2 callersMethodpush_event
(&mut self, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/forward.rs:76
↓ 2 callersMethodput
(&mut self, value: V)
arcon/src/index/value/mod.rs:45
↓ 2 callersMethodput
(&mut self, value: V)
arcon/src/index/value/eager.rs:49
↓ 2 callersMethodrecord_batch
(&mut self)
arcon/src/table/mod.rs:133
↓ 2 callersMethodregister_aggregator_handle
( &self, handle: &mut Handle<AggregatorState<A>, IK, N>, )
arcon/arcon_state/src/backend/sled/mod.rs:202
↓ 2 callersMethodregister_value_handle
( &'s self, handle: &'s mut Handle<ValueState<T>, IK, N>, )
arcon/arcon_state/src/backend/rocks/mod.rs:236
↓ 2 callersMethodremove_lowest_bit
(self)
arcon/src/index/hash_table/bitmask.rs:34
↓ 2 callersFunctionrust_vec_multi_threaded
(buffer_size: usize)
arcon/benches/buffer_pool.rs:143
↓ 2 callersFunctionrust_vec_single_thread
(b: &mut Bencher, buffer_size: usize)
arcon/benches/buffer_pool.rs:123
↓ 2 callersMethodschedule_at
(&mut self, time: u64, entry: TimerState)
arcon/src/stream/operator/mod.rs:134
↓ 2 callersMethodschedule_at
(&mut self, time: u64, entry: Self::Value)
arcon/src/stream/node/timer.rs:233
↓ 2 callersMethodsender
(&self)
arcon/src/data/mod.rs:153
↓ 2 callersMethodser_id
(&self)
arcon/src/data/flight_serde.rs:34
↓ 2 callersMethodserialize_id_and_metakeys_into
(&self, dest: &mut impl BufMut)
arcon/arcon_state/src/backend/handles.rs:182
↓ 2 callersMethodset_context
(&mut self, key: u64)
arcon/src/stream/node/mod.rs:344
↓ 2 callersMethodset_key
(&mut self, key: u64)
arcon/src/index/appender/mod.rs:74
↓ 2 callersMethodset_key_builder
(&mut self, key_builder: KeyBuilder<T>)
arcon/src/dataflow/constructor.rs:120
↓ 2 callersFunctionshard_lookup_with_key
(hashed_key: u64, total_shards: u64)
arcon/src/data/partition.rs:34
↓ 2 callersMethodsource_shutdown
(&mut self, error: Error)
arcon/src/stream/node/source.rs:221
↓ 2 callersFunctionspecialised_rolling_counter
(backend: BackendType, b: &mut Bencher)
arcon/benches/value.rs:123
↓ 2 callersMethodstate_dir
(&self)
arcon/src/application/conf/mod.rs:127
↓ 2 callersMethodtable_get
(&self, k: &Q, hash: u64)
arcon/src/index/hash_table/mod.rs:185
↓ 2 callersMethodtake_read_lane
( &mut self, hash: u64, mut eq: impl FnMut((&K, &V)) -> bool, )
arcon/src/index/hash_table/table.rs:645
↓ 2 callersMethodtick_and_collect
( &mut self, mut time_left: u32, res: &mut Vec<TimerEntry<V>>, )
arcon/src/stream/node/timer.rs:148
↓ 2 callersFunctionto_record_batches
( schema: Arc<Schema>, raw_batches: Vec<RawRecordBatch>, )
arcon/src/table/mod.rs:171
↓ 2 callersFunctiontoken_stream_with_error
(mut tokens: TokenStream, error: syn::Error)
arcon_macros/src/app.rs:112
↓ 2 callersMethoduntype
(self: Rc<Self>)
arcon/src/dataflow/constructor.rs:127
↓ 2 callersMethodupdate_watermark
(&mut self, ts: u64)
arcon/src/stream/node/source.rs:190
↓ 2 callersMethodvec_len
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:169
↓ 2 callersMethodwatermark
Creates an ArconMessage with a single [ArconEvent::Watermark] event This function should only be used for development and test purposes.
arcon/src/data/mod.rs:213
↓ 1 callersMethodadd_source
(&mut self, source: Arc<dyn AbstractComponent<Message = SourceEvent>>)
arcon/src/manager/source.rs:82
↓ 1 callersMethodaggregate
(&self, value: A::Input)
arcon/arcon_state/src/backend/handles.rs:472
↓ 1 callersMethodaggregator_aggregate
( &self, handle: &Handle<AggregatorState<A>, IK, N>, value: <A as Aggregator>::Input,
arcon/arcon_state/src/backend/sled/aggregator_ops.rs:47
↓ 1 callersMethodaggregator_clear
( &self, handle: &Handle<AggregatorState<A>, IK, N>, )
arcon/arcon_state/src/backend/sled/aggregator_ops.rs:16
↓ 1 callersMethodaggregator_get
( &self, handle: &Handle<AggregatorState<A>, IK, N>, )
arcon/arcon_state/src/backend/sled/aggregator_ops.rs:25
↓ 1 callersFunctionallocator_capacity_default
()
arcon/src/application/conf/mod.rs:305
↓ 1 callersMethodany_bit_set
(self)
arcon/src/index/hash_table/bitmask.rs:40
↓ 1 callersMethodappend
(&self, value: T)
arcon/arcon_state/src/backend/handles.rs:408
↓ 1 callersFunctionarcon_attr_meta
Collect arcon attrs #[arcon(..)] meta list
arcon_macros/src/arcon.rs:73
↓ 1 callersFunctionarcon_doc_attr
Collect arcon attrs from doc comments
arcon_macros/src/arcon.rs:109
↓ 1 callersMethodarcon_logger
(&self)
arcon/src/application/conf/mod.rs:138
↓ 1 callersFunctionarrow_file_reader
(path: impl AsRef<Path>)
arcon/src/table/mod.rs:306
↓ 1 callersMethodawait_termination
Awaits termination from the application Note that this blocks the current thread
arcon/src/application/mod.rs:271
↓ 1 callersMethodbackend_remove
(&self, k: &K)
arcon/src/index/hash_table/mod.rs:172
↓ 1 callersMethodbackend_remove_fast
(&self, k: &K)
arcon/src/index/hash_table/mod.rs:180
↓ 1 callersFunctionbase_dir_default
()
arcon/src/application/conf/mod.rs:263
↓ 1 callersFunctionbuffer_pool_limit_default
()
arcon/src/application/conf/mod.rs:297
↓ 1 callersMethodbuild_nodes
( &self, node_ids: Vec<GlobalNodeId>, in_channels: Vec<NodeID>, mut components
arcon/src/dataflow/constructor.rs:174
↓ 1 callersMethodbuild_source
( &self, components: ErasedComponents, paths: Vec<ActorPath>, app: &mut Applic
arcon/src/dataflow/constructor.rs:410
↓ 1 callersMethodbytes_remaining
Returns how much bytes are available to allocate
arcon/arcon_allocator/src/lib.rs:160
↓ 1 callersMethodcapacity
(&self)
arcon/src/buffer/event/mod.rs:75
↓ 1 callersFunctionchannel_batch_size_default
()
arcon/src/application/conf/mod.rs:301
↓ 1 callersMethodcheckpoint
(&self, _checkpoint_path: &Path)
arcon/arcon_state/src/backend/sled/mod.rs:109
↓ 1 callersMethodcheckpoint
(&mut self)
arcon/src/stream/node/mod.rs:461
↓ 1 callersMethodclear
(&mut self)
arcon/src/index/value/local.rs:74
↓ 1 callersMethodclient_config
(&self)
arcon/src/stream/source/kafka.rs:60
← previousnext →201–300 of 948, ranked by callers