public class WindowJoinSampleData extends Object
WindowJoin
example.Modifier and Type | Class and Description |
---|---|
static class |
WindowJoinSampleData.GradeSource |
static class |
WindowJoinSampleData.SalarySource |
Constructor and Description |
---|
WindowJoinSampleData() |
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Grade> |
getGradeSource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, grade).
|
static DataStream<WindowJoin.Salary> |
getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
static int |
GRADE_COUNT() |
static String[] |
NAMES() |
static int |
SALARY_MAX() |
public static String[] NAMES()
public static int GRADE_COUNT()
public static int SALARY_MAX()
public static DataStream<WindowJoin.Grade> getGradeSource(StreamExecutionEnvironment env, long rate)
env
- (undocumented)rate
- (undocumented)public static DataStream<WindowJoin.Salary> getSalarySource(StreamExecutionEnvironment env, long rate)
env
- (undocumented)rate
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.