Module application

Module application 

Source
Expand description

The application module provides necessary utilties for creating an Arcon application.

§Application Configuration

Each Arcon application must have an ApplicationConf configured. If you don’t have any need to modify any parameter, then you can simply rely on the defaults.

§Application Builder

An ApplicationBuilder holds the logical plan of an Arcon application but also its configuration. You can use this struct to build an Application.

§Usage

use arcon::prelude::*;

let conf = ApplicationConf {
    watermark_interval: 2000,
    ..Default::default()
};

let mut builder: ApplicationBuilder = (0..100u64)
    .to_stream(|conf| conf.set_arcon_time(ArconTime::Process))
    .map(|x| x * 10)
    .print()
    .builder();

let mut app: Application = builder
    .config(conf)
    .build();

app.run_and_block();

Re-exports§

pub use builder::ApplicationBuilder;
pub use conf::ApplicationConf;

Modules§

builder
conf

Structs§

Application
An Arcon Application