MCPcopy Create free account

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

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256
↓ 1 callersFunctionparse_config
(_: syn::ItemFn, args: AttributeArgs)
arcon_macros/src/app.rs:52
↓ 1 callersFunctionparse_dumped_sled_export
( dump_path: &Path, )
arcon/arcon_state/src/backend/sled/mod.rs:223
↓ 1 callersFunctionparse_field_kind
Figure out which FieldKind to apply (Required, Option, Repeated)
arcon_macros/src/proto.rs:134
↓ 1 callersFunctionparse_string
(int: syn::Lit, span: Span, field: &str)
arcon_macros/src/app.rs:31
↓ 1 callersMethodpersist
(&mut self)
arcon/src/index/hash_table/mod.rs:358
↓ 1 callersMethodpoll_timeout
(&self)
arcon/src/stream/source/kafka.rs:66
↓ 1 callersMethodraw
Consumes the container and returns a RawArconMessage
arcon/src/data/mod.rs:170
↓ 1 callersMethodraw_batches
(&mut self)
arcon/src/table/mod.rs:94
↓ 1 callersMethodread_ctrl_bytes
(&self)
arcon/src/index/hash_table/table.rs:723
↓ 1 callersMethodread_lane_iter
(&self)
arcon/src/index/hash_table/table.rs:755
↓ 1 callersMethodreducer_clear
( &self, handle: &Handle<ReducerState<T, F>, IK, N>, )
arcon/arcon_state/src/backend/sled/reducer_ops.rs:16
↓ 1 callersMethodreducer_get
( &self, handle: &Handle<ReducerState<T, F>, IK, N>, )
arcon/arcon_state/src/backend/sled/reducer_ops.rs:25
↓ 1 callersMethodreducer_reduce
( &self, handle: &Handle<ReducerState<T, F>, IK, N>, value: T, )
arcon/arcon_state/src/backend/sled/reducer_ops.rs:40
↓ 1 callersMethodregister_reducer_handle
( &self, handle: &mut Handle<ReducerState<T, F>, IK, N>, )
arcon/arcon_state/src/backend/sled/mod.rs:191
↓ 1 callersMethodrelease
(&self)
arcon/src/buffer/event/mod.rs:83
↓ 1 callersMethodremove
(&self, key: &K)
arcon/arcon_state/src/backend/handles.rs:361
↓ 1 callersMethodremove_prefix
(&self, tree_name: &str, prefix: Vec<u8>)
arcon/arcon_state/src/backend/sled/mod.rs:46
↓ 1 callersMethodremove_prefix
(&self, cf: impl AsRef<str>, prefix: impl AsRef<[u8]>)
arcon/arcon_state/src/backend/rocks/mod.rs:87
↓ 1 callersMethodreplay_events
(&mut self)
arcon/src/stream/node/timer.rs:114
↓ 1 callersFunctionrewrite_enum
Rewrites an enum into a `prost::Message` struct which wraps the enum (`prost::Oneof`).
arcon_macros/src/proto.rs:16
↓ 1 callersFunctionrewrite_struct
Rewrites a struct into a `prost::Message`.
arcon_macros/src/proto.rs:65
↓ 1 callersMethodrmw
(&mut self, key: &K, p: P, f: F)
arcon/src/index/hash_table/mod.rs:288
↓ 1 callersMethodrmw
(&mut self, f: F)
arcon/src/index/value/mod.rs:63
↓ 1 callersMethodschedule_after
(&mut self, id: TimeoutId, delay: u64, entry: V)
arcon/src/stream/node/timer.rs:201
↓ 1 callersMethodsender_blocked
(&mut self, sender: &NodeID)
arcon/src/stream/node/mod.rs:283
↓ 1 callersFunctionserialize_bytes_into
(target: &mut impl BufMut, payload: &[u8])
arcon/arcon_state/src/backend/serialization.rs:57
↓ 1 callersMethodserialize_id_metakeys_and_key_into
( &self, dest: &mut impl BufMut, key: &impl Key, )
arcon/arcon_state/src/backend/handles.rs:200
↓ 1 callersMethodserialize_metakeys_and_key_into
( &self, key: &impl Key, dest: &mut impl BufMut, )
arcon/arcon_state/src/backend/handles.rs:161
↓ 1 callersMethodset_name
(&mut self, name: syn::Lit, span: Span)
arcon_macros/src/app.rs:18
↓ 1 callersMethodset_outgoing_channels
Sets the number of outgoing channels from this node
arcon/src/dataflow/dfg.rs:101
↓ 1 callersMethodset_source_manager
(&mut self, source_manager: ErasedSourceManager)
arcon/src/application/mod.rs:191
↓ 1 callersMethodset_time
(&mut self, ts: u64)
arcon/src/stream/node/timer.rs:130
↓ 1 callersMethodsize_hint
(&self)
arcon/src/buffer/event/mod.rs:269
↓ 1 callersMethodsnapshot_manager
(&self)
arcon/src/application/mod.rs:216
↓ 1 callersMethodstart_source_manager
( &self, source_manager: &Arc<Component<SourceManager<B>>>, application: &mut Applicat
arcon/src/dataflow/constructor.rs:387
↓ 1 callersFunctionsum
(mut s: impl Source<Item = u32>)
arcon/src/stream/source/mod.rs:56
↓ 1 callersMethodtable_find_mod_lane
(&mut self, k: &Q, hash: u64)
arcon/src/index/hash_table/mod.rs:195
↓ 1 callersMethodtable_take_read_lane
(&mut self, k: &Q, hash: u64)
arcon/src/index/hash_table/mod.rs:205
↓ 1 callersMethodtake
(&mut self)
arcon/src/index/value/eager.rs:56
↓ 1 callersMethodtake
(&mut self)
arcon/src/index/value/local.rs:69
↓ 1 callersMethodtake_entry
(&mut self, id: TimeoutId)
arcon/src/stream/node/timer.rs:190
↓ 1 callersFunctionterm_logger
()
arcon/src/application/conf/logger.rs:26
↓ 1 callersMethodtime
(&self)
arcon/src/dataflow/builder.rs:80
↓ 1 callersFunctionto_raw_batches
(batches: Vec<RecordBatch>)
arcon/src/table/mod.rs:205
↓ 1 callersMethodtotal_events
(&self)
arcon/src/data/mod.rs:163
↓ 1 callersMethodtrailing_zeros
(self)
arcon/src/index/hash_table/bitmask.rs:69
↓ 1 callersMethodtry_reserve
(&self)
arcon/src/buffer/event/mod.rs:91
↓ 1 callersMethodunwrap_ref
(&self)
arcon/src/data/mod.rs:79
↓ 1 callersMethodvalue_clear
( &self, handle: &Handle<ValueState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/value_ops.rs:13
↓ 1 callersMethodvalue_fast_set
( &self, handle: &Handle<ValueState<T>, IK, N>, value: T, )
arcon/arcon_state/src/backend/sled/value_ops.rs:53
↓ 1 callersMethodvalue_fast_set_by_ref
( &self, handle: &Handle<ValueState<T>, IK, N>, value: &T, )
arcon/arcon_state/src/backend/sled/value_ops.rs:66
↓ 1 callersMethodvalue_get
( &self, handle: &Handle<ValueState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/value_ops.rs:22
↓ 1 callersMethodvalue_set
( &self, handle: &Handle<ValueState<T>, IK, N>, value: T, )
arcon/arcon_state/src/backend/sled/value_ops.rs:37
↓ 1 callersMethodvec_add_all
( &self, handle: &Handle<VecState<T>, IK, N>, values: impl IntoIterator<Item = T>,
arcon/arcon_state/src/backend/sled/vec_ops.rs:137
↓ 1 callersMethodvec_append
( &self, handle: &Handle<VecState<T>, IK, N>, value: T, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:25
↓ 1 callersMethodvec_clear
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:16
↓ 1 callersMethodvec_get
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:48
↓ 1 callersMethodvec_is_empty
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:187
↓ 1 callersMethodvec_iter
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:73
↓ 1 callersMethodvec_len
( &self, handle: &Handle<VecState<T>, IK, N>, )
arcon/arcon_state/src/backend/rocks/vec_ops.rs:166
↓ 1 callersMethodvec_set
( &self, handle: &Handle<VecState<T>, IK, N>, value: Vec<T>, )
arcon/arcon_state/src/backend/sled/vec_ops.rs:113
↓ 1 callersFunctionwait
Shared methods for test cases
arcon/src/stream/source/socket.rs:150
↓ 1 callersFunctionwatermark_interval_default
()
arcon/src/application/conf/mod.rs:279
↓ 1 callersMethodwith_debug_node
(&mut self)
arcon/src/application/mod.rs:184
↓ 1 callersMethodwith_topic
(mut self, topic: &str)
arcon/src/stream/source/kafka.rs:42
Function_parse_bool
(bool: syn::Lit, span: Span, field: &str)
arcon_macros/src/app.rs:42
Method_state_id
(&self)
arcon/src/dataflow/builder.rs:45
Methodaccumulator_into_result
(&self, acc: Self::Accumulator)
arcon/benches/value.rs:80
Methodaccumulator_into_result
(&self, acc: Self::Accumulator)
arcon/src/index/window/incremental.rs:57
Methodadd
(&self, acc: &mut Self::Accumulator, value: Self::Input)
arcon/benches/value.rs:67
Methodadd
(&mut self, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/broadcast.rs:84
Methodadd
(&mut self, event: ArconEvent<A>)
arcon/src/stream/channel/strategy/forward.rs:50
Methodadd_all
(&self, values: impl IntoIterator<Item = T>)
arcon/arcon_state/src/backend/handles.rs:424
Functionaggregation
(i: i32, agg: &u64)
arcon/src/index/window/mod.rs:42
Methodaggregator
(id: impl Into<String>, aggregator: A)
arcon/arcon_state/src/backend/handles.rs:104
Methodaggregator_aggregate
( &self, handle: &Handle<AggregatorState<A>, IK, N>, value: <A as Aggregator>::Input,
arcon/arcon_state/src/backend/rocks/aggregator_ops.rs:45
Methodaggregator_clear
( &self, handle: &Handle<AggregatorState<A>, IK, N>, )
arcon/arcon_state/src/backend/rocks/aggregator_ops.rs:14
Methodaggregator_get
( &self, handle: &Handle<AggregatorState<A>, IK, N>, )
arcon/arcon_state/src/backend/rocks/aggregator_ops.rs:23
Methodalloc
Allocate memory block of type T with given capacity # Safety It is up to the caller to ensure `dealloc` with the generated AllocId
arcon/arcon_allocator/src/lib.rs:81
Methodallocated_bytes
Returns amount of bytes that are currently allocated
arcon/arcon_allocator/src/lib.rs:145
Functionapp
(delimiter: TokenStream, input: TokenStream)
arcon_macros/src/lib.rs:76
Methodappend
(&mut self, data: V)
arcon/src/index/appender/eager.rs:62
Functionappender_fn
(u: &[u64])
arcon/src/stream/operator/window/assigner.rs:292
Functionarcon
(input: TokenStream)
arcon_macros/src/lib.rs:35
Functionarcon_alloc
(b: &mut Bencher)
arcon/benches/allocator.rs:14
Functionarcon_allocator
(c: &mut Criterion)
arcon/benches/allocator.rs:6
Functionarcon_buffer_pool
(c: &mut Criterion)
arcon/benches/buffer_pool.rs:15
Functionarrow
(input: TokenStream)
arcon_macros/src/lib.rs:107
Functionarrow_file_test
()
arcon/src/table/mod.rs:370
Methodas_mut_ptr
(&mut self)
arcon/src/buffer/network/mod.rs:61
Functionbasic_test
()
arcon/src/index/hash_table/mod.rs:379
Functionbroadcast_local_test
()
arcon/src/stream/channel/strategy/broadcast.rs:173
Functionbuffer_pool_test
()
arcon/src/buffer/event/mod.rs:452
Methodbuffer_size
(&self)
arcon/src/buffer/event/mod.rs:412
Functionbundle
()
arcon/arcon_state/src/backend/test_common.rs:43
Functioncalculate_layout
( mod_buckets: usize, read_buckets: usize, )
arcon/src/index/hash_table/table.rs:132
Methodcapacity
(&self)
arcon/src/buffer/network/mod.rs:45
Functioncheckpoint_restore_state_test
()
arcon/arcon_state/src/backend/rocks/mod.rs:435
Functioncheckpoint_rocksdb_raw_test
()
arcon/arcon_state/src/backend/rocks/mod.rs:383
Methodcheckpoints_dir
(&self)
arcon/src/application/conf/mod.rs:132
← previousnext →401–500 of 948, ranked by callers