Struct OperatorBuilder 

pub struct OperatorBuilder<OP: Operator, Backend = DefaultBackend> {
    pub operator: Arc<dyn Fn() -> OP + Send + Sync + 'static>,
    pub state: Arc<dyn Fn(Arc<Backend>) -> OP::OperatorState + Send + Sync + 'static>,
    pub conf: OperatorConf,
}

Operator Builder

Defines everything needed in order for Arcon to instantiate and manage an Operator during runtime.

use arcon::prelude::*;
let builder = OperatorBuilder {
   operator: Arc::new(|| Map::new(|x: u64| x + 10)),
   state: Arc::new(|_backend: Arc<Sled>| EmptyState),
   conf: Default::default(),
};

Fields

operator: Arc<dyn Fn() -> OP + Send + Sync + 'static>

Operator Constructor

state: Arc<dyn Fn(Arc<Backend>) -> OP::OperatorState + Send + Sync + 'static>

State Constructor

conf: OperatorConf

Operator Config

Trait Implementations

impl<OP: Clone + Operator, Backend: Clone> Clone for OperatorBuilder<OP, Backend>

where OP::OperatorState: Clone,

fn clone(&self) -> OperatorBuilder<OP, Backend>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.