public class WindowJoinSampleData$ extends Object
WindowJoin
example.Modifier and Type | Field and Description |
---|---|
static WindowJoinSampleData$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
WindowJoinSampleData$() |
Modifier and Type | Method and Description |
---|---|
DataStream<WindowJoin.Grade> |
getGradeSource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, grade).
|
DataStream<WindowJoin.Salary> |
getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
int |
GRADE_COUNT() |
String[] |
NAMES() |
int |
SALARY_MAX() |
public static final WindowJoinSampleData$ MODULE$
public String[] NAMES()
public int GRADE_COUNT()
public int SALARY_MAX()
public DataStream<WindowJoin.Grade> getGradeSource(StreamExecutionEnvironment env, long rate)
env
- (undocumented)rate
- (undocumented)public DataStream<WindowJoin.Salary> getSalarySource(StreamExecutionEnvironment env, long rate)
env
- (undocumented)rate
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.