Functions — github.com/Veeupup/naive-pipeline-execution

CodeHub MCPcopy Create free account

hub / github.com/Veeupup/naive-pipeline-execution / functions

Functions62 in github.com/Veeupup/naive-pipeline-execution

⨍ Functions 62 ◇ Types & classes 13

↓ 10 callersMethodadd_source

(&mut self, processor: Arc<dyn Processor>)

src/pipeline.rs:102

↓ 9 callersMethodset_state

(&self, state: ProcessorState)

src/processor.rs:59

↓ 8 callersMethodcontext

src/processor.rs:143

↓ 4 callersMethodadd_transform

Add a normal processor to the pipeline. processor1 --> processor1_1 processor2 --> processor2_1 processor3 --> processor3_1

src/pipeline.rs:128

↓ 4 callersMethodcontext

src/transform/accumulate.rs:162

↓ 4 callersMethodcontext

src/transform/merge.rs:81

↓ 4 callersMethodget_state

src/processor.rs:64

↓ 4 callersMethodmerge_processor

Merge many(or one)-ways processors into one-way. processor1 -- \ processor2 --> processor / processor3 --

src/pipeline.rs:162

↓ 4 callersMethodset_next_processor_ready

src/processor.rs:95

↓ 3 callersMethodadd_processor

(&mut self, processor: Arc<dyn Processor>)

src/pipeline.rs:94

↓ 3 callersMethodcontext

src/transform/arithmetic.rs:157

↓ 3 callersMethodexecute

src/pipeline.rs:49

↓ 3 callersMethodget_prev_processors

(&self, index: NodeIndex)

src/graph.rs:33

↓ 3 callersMethodset_node_index

(&self, node_index: Index)

src/processor.rs:50

↓ 2 callersMethodconnect_from_input

(&mut self, _input: Vec<Arc<dyn Processor>>)

src/processor.rs:131

↓ 2 callersMethodconnect_processors

(&mut self, from: NodeIndex, to: NodeIndex)

src/pipeline.rs:98

↓ 2 callersMethodget_node_index

src/processor.rs:55

↓ 1 callersMethodadd_edges

(&mut self, from: NodeIndex, to: NodeIndex)

src/graph.rs:25

↓ 1 callersMethodcontext

src/source/memory_source.rs:65

↓ 1 callersMethodget_all_processors

src/graph.rs:49

↓ 1 callersMethodget_last_processor

get the output processor of the pipeline

src/graph.rs:54

↓ 1 callersMethodget_next_processors

src/processor.rs:76

↓ 1 callersMethodget_processor_by_index

(&self, index: NodeIndex)

src/graph.rs:29

↓ 1 callersMethodoutput_port

src/processor.rs:139

↓ 1 callersMethodoutput_port

src/transform/accumulate.rs:158

↓ 1 callersMethodoutput_port

src/transform/arithmetic.rs:153

↓ 1 callersMethodoutput_port

src/transform/merge.rs:77

Methodadd_processor

(&mut self, processor: Arc<dyn Processor>)

src/graph.rs:21

Methodconnect_from_input

(&mut self, _input: Vec<Arc<dyn Processor>>)

src/source/memory_source.rs:43

Methodconnect_from_input

(&mut self, input: Vec<Arc<dyn Processor>>)

src/transform/accumulate.rs:64

Methodconnect_from_input

(&mut self, input: Vec<Arc<dyn Processor>>)

src/transform/arithmetic.rs:68

Methodconnect_from_input

(&mut self, input: Vec<Arc<dyn Processor>>)

src/transform/merge.rs:45

src/processor.rs:135

src/source/memory_source.rs:47

src/transform/accumulate.rs:68

src/transform/arithmetic.rs:73

src/transform/merge.rs:49

Methodexpand_processor

src/pipeline.rs:187

(&self, f: &mut std::fmt::Formatter<'_>)

src/processor.rs:111

(&self, f: &mut std::fmt::Formatter<'_>)

src/source/memory_source.rs:22

(&self, f: &mut std::fmt::Formatter<'_>)

src/transform/accumulate.rs:36

(&self, f: &mut std::fmt::Formatter<'_>)

src/transform/arithmetic.rs:57

(&self, f: &mut std::fmt::Formatter<'_>)

src/transform/merge.rs:24

Methodget_next_processors

(&self, index: NodeIndex)

src/graph.rs:41

Methodget_prev_processors

src/processor.rs:69

* Construt a simple pipeline: * source1 -> Add('a', 'b') * * ----> Accumulate('a + b', Sum) * * s

src/processor.rs:127

src/source/memory_source.rs:39

src/transform/accumulate.rs:60

src/transform/arithmetic.rs:64

src/transform/merge.rs:41

src/graph.rs:17

(threads: usize)

src/pipeline.rs:37

(processor_type: ProcessorType, graph: Arc<Mutex<RunningGraph>>)

src/processor.rs:41

(data: Vec<RecordBatch>, graph: Arc<Mutex<RunningGraph>>)

src/source/memory_source.rs:28

( name: &'static str, accumulator: Accumulator, column_index: Option<usize>, g

src/transform/accumulate.rs:42

( name: &'static str, operator: Operator, l_column_index: usize, r_column_inde

src/transform/arithmetic.rs:37

(name: &'static str, graph: Arc<Mutex<RunningGraph>>)

src/transform/merge.rs:30

Methodoutput_port

src/source/memory_source.rs:61

Functiontest_acc

src/pipeline.rs:294

Functiontest_build_pipeline

src/pipeline.rs:207

Functiontest_execute_pipeline

src/pipeline.rs:238