Function create_executor

pub async fn create_executor(
    params: ExecutorParams,
    node: &StreamNode,
    store: impl StateStore,
) -> StreamResult<Executor>

Create an executor from protobuf StreamNode.