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§
Structs§
- Application
- An Arcon Application