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

Methodhandle_element

( &mut self, element: ArconElement<IN>, _ctx: OperatorContext<Self, impl Backend, impl

arcon/src/stream/operator/sink/kafka.rs:84

Methodhandle_element

( &mut self, _: ArconElement<Self::IN>, ctx: &mut OperatorContext<Self::TimerState, Se

arcon/src/stream/operator/sink/measure.rs:43

Methodhandle_element

( &mut self, element: ArconElement<IN>, _ctx: &mut OperatorContext<Self::TimerState, S

arcon/src/stream/operator/sink/local_file.rs:54

Methodhandle_timeout

( &mut self, timeout: Self::TimerState, ctx: &mut OperatorContext<Self::TimerState, Se

examples/custom_operator.rs:60

Methodhandle_timeout

(&mut self, timeout_id: ScheduledTimer)

arcon/src/manager/epoch.rs:63

Methodhandle_watermark_timeout

(&mut self, timeout_id: ScheduledTimer)

arcon/src/manager/source.rs:88

Methodhas_tables

arcon/src/index/mod.rs:93

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

Methodincrement_counter

(&self, key: &Key, value: u64)

arcon/src/metrics/log_recorder.rs:37

Methodincrement_counter

(&self, name: &str)

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

Functionindex_rocks_backed

(b: &mut Bencher)

arcon/benches/value.rs:30

Functionindex_sled_backed

(b: &mut Bencher)

arcon/benches/value.rs:25

Functionindex_test

(mut index: impl AppenderIndex<u64>)

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

Functionindex_test

(mut index: impl ValueIndex<u64>)

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

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

Methodinsert_all

(&self, key_value_pairs: impl IntoIterator<Item = (K, V)>)

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

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

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

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

arcon/src/buffer/event/mod.rs:175

Functioniterator_source_test

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

Functionkey_by_integration

arcon/src/test/keyby_integration.rs:94

Functionkey_by_to_forward_integration

arcon/src/test/keyby_integration.rs:121

Functionkeyby_test

arcon/src/stream/channel/strategy/keyed.rs:164

Functionlazy_value_index_test

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

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

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

arcon/src/buffer/network/mod.rs:64

( &mut self, elems: impl IntoIterator<Item = impl ToArrow>, )

arcon/src/table/mod.rs:55

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

Methodload_aligned

(ptr: *const u8)

arcon/src/index/hash_table/sse2.rs:43

Methodload_aligned

(ptr: *const u8)

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

(self: Box<Self>)

arcon/src/data/flight_serde.rs:47

Functionlocal_file_sink_test

arcon/src/stream/operator/sink/local_file.rs:75

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

arcon_tests/build.rs:1

examples/window.rs:6

examples/file.rs:2

examples/kafka_source.rs:2

examples/custom_operator.rs:71

examples/stateful.rs:17

Methodmap_clear

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:15

Methodmap_contains

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:159

Methodmap_fast_insert

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: K, value: V, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:39

Methodmap_fast_insert_by_ref

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, value: &V, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:54

Methodmap_fast_remove

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:148

just pass it on

arcon/src/stream/source/socket.rs:192

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )

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

Functionmap_in_place_test

arcon/src/stream/operator/function/mod.rs:34

Methodmap_insert

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: K, value: V, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:69

Methodmap_insert_all

( &self, handle: &Handle<MapState<K, V>, IK, N>, key_value_pairs: impl IntoIterator<It

arcon/arcon_state/src/backend/rocks/map_ops.rs:93

Methodmap_insert_all_by_ref

( &self, handle: &Handle<MapState<K, V>, IK, N>, key_value_pairs: impl IntoIterator<It

arcon/arcon_state/src/backend/rocks/map_ops.rs:111

Methodmap_is_empty

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:244

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:168

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:192

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:232

Methodmap_remove

( &self, handle: &Handle<MapState<K, V>, IK, N>, key: &K, )

arcon/arcon_state/src/backend/rocks/map_ops.rs:130

Functionmap_test

arcon/src/stream/operator/function/mod.rs:20

Methodmap_values

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

arcon/arcon_state/src/backend/rocks/map_ops.rs:214

arcon/src/metrics/meter.rs:38

Methodmatch_byte

(self, byte: u8)

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

Methodmatch_empty

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

Methodmatch_modified

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

Functionmaterializer

(buffer: &[i32])

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

Methodmerge_accumulators

( &self, mut fst: Self::Accumulator, snd: Self::Accumulator, )

arcon/benches/value.rs:71

Methodmerge_accumulators

( &self, _fst: Self::Accumulator, _snd: Self::Accumulator, )

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

Methodmerge_field

( &mut self, _: u32, _: prost::encoding::WireType, _: &mut B, _: prost

arcon/src/data/mod.rs:434

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

Functionmodified_test

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

Functionnaive_rolling_rocks

(b: &mut Bencher)

arcon/benches/value.rs:86

Functionnaive_rolling_sled

(b: &mut Bencher)

arcon/benches/value.rs:90

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

Sets the name of the application

arcon/src/application/builder.rs:41

Functionnetwork_buffer_test

arcon/src/buffer/network/mod.rs:74

arcon/benches/hash_table.rs:52

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

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

(alpha: f64, interval: f64)

arcon/src/metrics/ewma.rs:27

arcon/src/metrics/runtime_metrics.rs:9

arcon/src/metrics/perf_event.rs:64

arcon/src/metrics/meter.rs:25

(id: u64, range: KeyRange)

arcon/src/data/partition.rs:49

Creates an ArconElement without a timestamp

arcon/src/data/mod.rs:103

Creates a new MutableTable

arcon/src/table/mod.rs:35

Creates a new Application using the given ApplicationConf

arcon/src/application/mod.rs:96

(ctx: Context, debug: bool)

arcon/src/application/builder.rs:32

Creates an EagerAppender

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

(backend: Arc<B>, udf: F)

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

(backend: Arc<B>, materializer: F)

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

(backend: Arc<B>, init: INIT, agg: AGG)

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

Creates a HashTable with default settings

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

(id: impl Into<String>, backend: Arc<B>)

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

(table: &'a mut RawTable<K, V>, hash: u64)

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

Creates a LazyValue

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

Creates an EagerValue

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

Creates a LocalValue

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

( kind: DFGNodeKind, operator_id: OperatorId, paralellism: usize, ingoing: Vec

arcon/src/dataflow/dfg.rs:72

( descriptor: String, builder: Arc<OperatorBuilder<OP, B>>, in_key_builder: Option<Key

arcon/src/dataflow/constructor.rs:249

(path: impl Into<String>)

arcon/src/dataflow/source/mod.rs:90

(kafka_conf: KafkaConsumerConf, schema: S, parallelism: usize)

arcon/src/dataflow/source/kafka.rs:41

← previous next →601–700 of 948, ranked by callers