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

(ctx: Context, source: Rc<dyn TypedSourceFactory<T>>)

arcon/src/dataflow/stream/mod.rs:65

(capacity: usize, allocator: Arc<Mutex<Allocator>>)

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

Creates a new EventBuffer

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

( extractor: F, sock_addr: SocketAddr, sock_kind: SocketKind, )

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

(backend: Arc<B>)

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

(file_path: String)

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

arcon/src/stream/source/schema.rs:34

( timer: Box<dyn ArconTimer<Value = TimerState>>, state: OperatorState, logger: ArconL

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

( udf: impl Fn(&IN) -> bool + ArconFnBounds, )

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

( udf: impl Fn(IN) -> OUTS + ArconFnBounds, )

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

( udf: impl Fn(&mut IN) + ArconFnBounds, )

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

( udf: impl Fn(IN) -> OUT + ArconFnBounds, )

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

(key: u64, index: u64)

arcon/src/stream/operator/window/mod.rs:17

(key: Key, index: Index, timestamp: Timestamp)

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

(bootstrap_server: String, topic: String, offset: u32)

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

Creates a MeasureSink that logs throughput

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

(file_path: impl AsRef<Path>)

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

(channels: Vec<Channel<A>>, sender_id: NodeID, pool_info: PoolInfo)

arcon/src/stream/channel/strategy/broadcast.rs:31

Creates a Keyed strategy

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

Creates a Forward strategy

arcon/src/stream/channel/strategy/forward.rs:31

(id: NodeID, in_channels: Vec<NodeID>, backend: Arc<B>)

arcon/src/stream/node/mod.rs:84

arcon/src/stream/node/debug.rs:29

( source_index: usize, source: S, conf: SourceConf<S::Item>, channel_strategy:

arcon/src/stream/node/source.rs:67

(time_when_scheduled: u64, timeout_millis: u64, payload: E)

arcon/src/stream/node/timer.rs:29

arcon/src/util/system_killer.rs:40

(sock_addr: SocketAddr, kind: IOKind)

arcon/src/util/io.rs:150

(backend_name: String, epoch: u64, snapshot_path: String)

arcon/src/manager/snapshot.rs:22

arcon/src/manager/state.rs:34

( state_id: StateID, arcon_time: ArconTime, watermark_interval: u64, epoch_man

arcon/src/manager/source.rs:56

( epoch_interval: u64, snapshot_manager: ActorRefStrong<EpochCommit>, logger: ArconLog

arcon/src/manager/epoch.rs:45

arcon/src/manager/node.rs:47

Creates a new Allocator with the given memory limit size

arcon/arcon_allocator/src/lib.rs:58

Methodnew_uninitialized

( mod_lane_buckets: usize, read_lane_buckets: usize, fallability: Fallibility, )

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

arcon/src/index/hash_table/bitmask.rs:101

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

Functionnode_epoch_block

arcon/src/stream/node/mod.rs:791

Functionnode_epoch_continue

arcon/src/stream/node/mod.rs:840

Functionnode_epoch_no_continue

arcon/src/stream/node/mod.rs:814

Functionnode_no_watermark

arcon/src/stream/node/mod.rs:744

Functionnode_one_watermark

arcon/src/stream/node/mod.rs:758

Functionnode_outoforder_watermarks

arcon/src/stream/node/mod.rs:774

Helper function to make place-holder GlobalNodeId (used in testing etc.)

arcon/src/dataflow/dfg.rs:18

Methodnum_channels

arcon/src/stream/channel/strategy/broadcast.rs:153

Methodnum_channels

arcon/src/stream/channel/strategy/mod.rs:63

Methodnum_channels

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

Methodon_element

(&mut self, element: Self::IN, ctx: WindowContext)

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

Methodon_element

(&mut self, element: Self::IN, ctx: WindowContext)

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

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

Determines what the `Operator` runs before beginning to process Elements

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

arcon/src/stream/node/mod.rs:515

arcon/src/stream/node/debug.rs:74

arcon/src/stream/node/source.rs:232

arcon/src/util/io.rs:185

arcon/src/manager/source.rs:108

arcon/src/manager/epoch.rs:143

arcon/src/manager/node.rs:172

arcon/src/manager/source.rs:112

arcon/src/manager/epoch.rs:149

Methodone_min_ewma

arcon/src/metrics/ewma.rs:37

Functionparquet_file_test

arcon/src/table/mod.rs:386

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

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

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

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

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

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

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

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

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

Methodpoll_next

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

Methodpoll_next

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

Functionpool_multi_threaded_large

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:65

Functionpool_multi_threaded_small

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:61

Functionpool_single_thread_large

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:57

Functionpool_single_thread_small

(b: &mut Bencher)

arcon/benches/buffer_pool.rs:53

(_: TokenStream, input: TokenStream)

arcon_macros/src/lib.rs:137

(&mut self, key: K, value: V)

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

(&mut self, value: V)

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

Methodreceive_local

(&mut self, msg: Self::Message)

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

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/stream/node/mod.rs:577

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/stream/node/debug.rs:86

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/stream/node/source.rs:296

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/util/system_killer.rs:15

Methodreceive_local

(&mut self, _msg: Self::Message)

arcon/src/util/io.rs:123

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/manager/snapshot.rs:98

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/manager/source.rs:123

Methodreceive_local

(&mut self, msg: Self::Message)

arcon/src/manager/epoch.rs:133

Methodreceive_local

(&mut self, _: Self::Message)

arcon/src/manager/node.rs:231

Methodreceive_network

(&mut self, _msg: NetMessage)

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

Methodreceive_network

(&mut self, msg: NetMessage)

arcon/src/stream/node/mod.rs:583

Methodreceive_network

(&mut self, msg: NetMessage)

arcon/src/stream/node/debug.rs:91

Methodreceive_network

(&mut self, _: NetMessage)

arcon/src/stream/node/source.rs:302

Methodreceive_network

(&mut self, _msg: NetMessage)

arcon/src/util/system_killer.rs:30

Methodreceive_network

(&mut self, _msg: NetMessage)

arcon/src/util/io.rs:126

Methodreceive_network

(&mut self, _: NetMessage)

arcon/src/manager/snapshot.rs:102

Methodreceive_network

(&mut self, _: NetMessage)

arcon/src/manager/source.rs:142

Methodreceive_network

(&mut self, _: NetMessage)

arcon/src/manager/epoch.rs:137

Methodreceive_network

(&mut self, _: NetMessage)

arcon/src/manager/node.rs:234

Methodrecord_histogram

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

arcon/src/metrics/log_recorder.rs:45

(&self, value: T)

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

← previous next →701–800 of 948, ranked by callers