Functions — github.com/cda-group/arcon

CodeHub MCPcopy Create free account

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

Functions948 in github.com/cda-group/arcon

⨍ Functions 948◇ Types & classes 256

(id: impl Into<String>, reducer: F)

arcon/arcon_state/src/backend/handles.rs:92

Methodreducer_clear

( &self, handle: &Handle<ReducerState<T, F>, IK, N>, )

arcon/arcon_state/src/backend/rocks/reducer_ops.rs:14

Methodreducer_get

( &self, handle: &Handle<ReducerState<T, F>, IK, N>, )

arcon/arcon_state/src/backend/rocks/reducer_ops.rs:23

Methodreducer_reduce

( &self, handle: &Handle<ReducerState<T, F>, IK, N>, value: T, )

arcon/arcon_state/src/backend/rocks/reducer_ops.rs:38

(&mut self, backend: &mut B)

arcon/arcon_state/src/backend/handles.rs:257

Methodregister_aggregator_handle

( &'s self, handle: &'s mut Handle<AggregatorState<A>, IK, N>, )

arcon/arcon_state/src/backend/rocks/mod.rs:279

Methodregister_counter

(&self, key: &Key, unit: Option<Unit>, description: Option<&'static str>)

arcon/src/metrics/log_recorder.rs:10

Methodregister_counter

(&self, name: &str)

arcon/src/stream/operator/mod.rs:150

Methodregister_gauge

(&self, key: &Key, unit: Option<Unit>, description: Option<&'static str>)

arcon/src/metrics/log_recorder.rs:20

Methodregister_gauge

(&mut self, name: &str)

arcon/src/stream/operator/mod.rs:140

Methodregister_histogram

(&self, key: &Key, unit: Option<Unit>, description: Option<&'static str>)

arcon/src/metrics/log_recorder.rs:27

Methodregister_map_handle

( &'s self, handle: &'s mut Handle<MapState<K, V>, IK, N>, )

arcon/arcon_state/src/backend/rocks/mod.rs:246

Methodregister_reducer_handle

( &'s self, handle: &'s mut Handle<ReducerState<T, F>, IK, N>, )

arcon/arcon_state/src/backend/rocks/mod.rs:267

Methodregister_vec_handle

( &'s self, handle: &'s mut Handle<VecState<T>, IK, N>, )

arcon/arcon_state/src/backend/rocks/mod.rs:256

Functionreliable_added_field_test

arcon/src/data/flight_serde.rs:167

Functionreliable_rearranged_field_test

arcon/src/data/flight_serde.rs:179

Functionreliable_removed_field_test

arcon/src/data/flight_serde.rs:185

Functionreliable_serde_test

arcon/src/data/flight_serde.rs:157

arcon/src/index/hash_table/eager.rs:47

(&mut self, hash: u64, mut eq: impl FnMut((&K, &V)) -> bool)

arcon/src/index/hash_table/table.rs:589

(live_path: &Path, checkpoint_path: &Path, name: String)

arcon/arcon_state/src/backend/sled/mod.rs:83

(live_path: &Path, checkpoint_path: &Path, name: String)

arcon/arcon_state/src/backend/rocks/mod.rs:178

Restores an ArconState from a [Snapshot]

arcon/src/index/mod.rs:48

Methodrestore_or_create

(config: &Config, id: String)

arcon/arcon_state/src/backend/mod.rs:40

(&mut self, ctx: WindowContext)

arcon/src/index/window/appender.rs:61

(&mut self, ctx: WindowContext)

arcon/src/index/window/incremental.rs:129

(&mut self, mut f: F)

arcon/src/index/value/eager.rs:63

(&mut self, mut f: F)

arcon/src/index/value/local.rs:78

Methodrun_and_block

Run the application and block until it terminates

arcon/src/application/mod.rs:234

Functionrust_multi_threaded_large

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:139

Functionrust_multi_threaded_small

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:135

Functionrust_single_thread_large

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:119

Functionrust_single_thread_small

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:115

Functionrust_vec_alloc

(b: &mut Bencher)

arcon/benches/allocator.rs:23

arcon/src/stream/time/mod.rs:17

Functionsemicolon_test

arcon_macros/tests/decoder_test.rs:26

Methodserialise

(&self, mut buf: &mut dyn BufMut)

arcon/src/data/flight_serde.rs:40

Methodserialize

(_payload: &Self)

arcon/arcon_state/src/backend/serialization.rs:196

Methodserialize_check

(payload: &Self)

arcon/arcon_state/src/backend/serialization.rs:45

Methodserialize_id_and_metakeys

arcon/arcon_state/src/backend/handles.rs:190

Methodserialize_id_metakeys_and_key

(&self, key: &impl Key)

arcon/arcon_state/src/backend/handles.rs:212

Methodserialize_into

(_target: &mut impl BufMut, _payload: &Self)

arcon/arcon_state/src/backend/serialization.rs:200

Methodset_batch_size

Set batch size per process iteration

arcon/src/dataflow/conf.rs:104

Methodset_channel_kind

(&mut self, channel_kind: ChannelKind)

arcon/src/dataflow/constructor.rs:124

(&mut self, key: u64)

arcon/src/index/appender/eager.rs:48

(&mut self, _: u64)

arcon/src/index/window/arrow.rs:118

(&mut self, _: u64)

arcon/src/index/window/appender.rs:87

(&mut self, _: u64)

arcon/src/index/window/incremental.rs:156

(&mut self, _: u64)

arcon/src/index/hash_table/mod.rs:365

(&mut self, _: u64)

arcon/src/index/hash_table/eager.rs:69

(&mut self, key: u64)

arcon/src/index/value/eager.rs:86

(&mut self, _: u64)

arcon/src/index/value/local.rs:110

(&mut self, name: &str)

arcon/src/table/mod.rs:142

Methodset_offset

(&mut self, _: usize)

arcon/src/stream/source/mod.rs:47

Methodset_offset

(&mut self, _: usize)

arcon/src/stream/source/kafka.rs:188

Methodset_offset

(&mut self, _: usize)

arcon/src/stream/source/local_file.rs:61

Methodset_source_name

(&mut self, name: String)

arcon/src/dataflow/conf.rs:108

Setup method for both sliding and tumbling windows

arcon/src/stream/operator/window/assigner.rs:93

Functionshard_lookup_test

arcon/src/data/partition.rs:87

Functionshard_test

arcon/src/data/partition.rs:78

Functionsimple_allocator_test

arcon/arcon_allocator/src/lib.rs:185

Functionsimple_rocksdb_test

arcon/arcon_state/src/backend/rocks/mod.rs:362

Methodsize_hint

arcon/src/data/flight_serde.rs:37

Methodsize_hint

arcon/src/index/hash_table/table.rs:887

Functionspecialised_rocks

(b: &mut Bencher)

arcon/benches/value.rs:115

Functionspecialised_sled

(b: &mut Bencher)

arcon/benches/value.rs:119

(input: TokenStream)

arcon_macros/src/lib.rs:91

arcon/src/stream/operator/function/filter.rs:42

arcon/src/stream/operator/function/flatmap.rs:53

arcon/src/stream/operator/function/map_in_place.rs:49

arcon/src/stream/operator/function/map.rs:50

Methodstatic_empty

arcon/src/index/hash_table/generic.rs:57

Methodstore_aligned

(self, ptr: *mut u8)

arcon/src/index/hash_table/generic.rs:89

Functionstreaming_state_test

arcon/src/test/arcon_state.rs:16

Functionsum_appender_window_test

arcon/src/index/window/mod.rs:16

Functionsum_incremental_window_test

arcon/src/index/window/mod.rs:36

arcon/src/index/mod.rs:105

arcon/src/index/appender/mod.rs:77

arcon/src/index/appender/eager.rs:51

arcon/src/index/window/arrow.rs:119

arcon/src/index/window/appender.rs:88

arcon/src/index/window/incremental.rs:157

arcon/src/index/hash_table/mod.rs:366

arcon/src/index/hash_table/eager.rs:70

arcon/src/index/value/mod.rs:85

arcon/src/index/value/eager.rs:89

arcon/src/index/value/local.rs:111

Methodtable_ids

arcon/src/index/mod.rs:87

Functiontable_serde_test

arcon/src/table/mod.rs:410

arcon/src/index/mod.rs:84

Creates a TCP IO component

arcon/src/util/io.rs:65

Functiontcp_io_test

arcon/src/util/io.rs:202

arcon_tests/src/proto_derive_test.rs:18

Functiontest_errors

arcon/arcon_state/src/backend/serialization.rs:338

Functiontest_fixed_bytes

arcon/arcon_state/src/backend/serialization.rs:319

Functiontest_key_serialization

arcon/arcon_state/src/backend/handles.rs:482

Functiontest_primitives_fixed

arcon/arcon_state/src/backend/serialization.rs:279

Functiontest_protobuf_serialization

arcon/arcon_state/src/backend/serialization.rs:302

Functiontest_sled_checkpoints

arcon/arcon_state/src/backend/sled/mod.rs:317

Functiontest_unit_state_key_empty

arcon/arcon_state/src/backend/handles.rs:495

← previous next →801–900 of 948, ranked by callers