springcloud

public class DataStreamDemo1 {

    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        try (env) {
            DataStreamSource<Person> dataStreamSource = env.fromElements(
                    new Person("Fred", 35),
                    new Person("Wilma", 35),
                    new Person("Pebbles", 2),
                    new Person("Jimmy", 5)
            );
            SingleOutputStreamOperator<Person> adults = dataStreamSource.filter(item -> item.age > 18);

            adults.print();
            System.out.println("开始执行");
            env.execute();
        }
    }

}

@RestController
public class TestController {

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private RepositoryService repositoryService;

    @GetMapping("get")
    public String get() {


        ProcessInstanceQuery processInstanceQuery = runtimeService.createProcessInstanceQuery();
        List<ProcessInstance> list = processInstanceQuery.list();
        return "helloworld" + list.size();
    }

    @GetMapping("deploy")
    public Result<List<Deployment>> list() {
        List<Deployment> list1 = repositoryService.createDeploymentQuery()
                .list();
        return new Result<>(list1);
    }
}
***