Package org.apache.flink.streaming.api.environment

Examples of org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource()

109
110
111
112
113
114
115
116
117
118
119
  // Example for connecting data streams
  public static void main(String[] args) throws Exception {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(
        PARALLELISM).setBufferTimeout(100);

    DataStream<Tuple3<Integer, Long, Integer>> querySource = env.addSource(new QuerySource(),
        SOURCE_PARALLELISM).partitionBy(0);

    DataStream<String> stream = env.addSource(new InfoSource(), SOURCE_PARALLELISM)
        .partitionBy(0).connect(querySource).map(new CellTask());
    stream.print();
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        PARALLELISM).setBufferTimeout(100);

    DataStream<Tuple3<Integer, Long, Integer>> querySource = env.addSource(new QuerySource(),
        SOURCE_PARALLELISM).partitionBy(0);

    DataStream<String> stream = env.addSource(new InfoSource(), SOURCE_PARALLELISM)
        .partitionBy(0).connect(querySource).map(new CellTask());
    stream.print();

    env.execute();
  }
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
  public static void main(String[] args) throws Exception {

    StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(
        PARALLELISM).setBufferTimeout(100);

    DataStream<Tuple3<String, Integer, Long>> grades = env.addSource(new GradeSource(),
        SOURCE_PARALLELISM);

    DataStream<Tuple3<String, Integer, Long>> salaries = env.addSource(new SalarySource(),
        SOURCE_PARALLELISM);
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
        PARALLELISM).setBufferTimeout(100);

    DataStream<Tuple3<String, Integer, Long>> grades = env.addSource(new GradeSource(),
        SOURCE_PARALLELISM);

    DataStream<Tuple3<String, Integer, Long>> salaries = env.addSource(new SalarySource(),
        SOURCE_PARALLELISM);

    DataStream<Tuple3<String, Integer, Integer>> joinedStream = grades.connect(salaries)
        .flatMap(new WindowJoinTask());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.