rlink 0.6.16

High performance Stream Processing Framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::Arc;

use crate::core::env::{StreamApp, StreamExecutionEnvironment};
use crate::deployment::TResourceManager;
use crate::runtime::context::Context;
use crate::runtime::coordinator::CoordinatorTask;

pub(crate) fn run<S, R>(
    context: Arc<Context>,
    stream_env: StreamExecutionEnvironment,
    stream_app: S,
    resource_manager: R,
) -> anyhow::Result<()>
where
    S: StreamApp + 'static,
    R: TResourceManager + 'static,
{
    let mut coordinator_task =
        CoordinatorTask::new(context, stream_app, resource_manager, stream_env);
    coordinator_task.run()
}