Package | Description |
---|---|
org.apache.flink.streaming.scala.examples.join |
Modifier and Type | Method and Description |
---|---|
WindowJoin.Salary |
WindowJoinSampleData.SalarySource.next() |
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Salary> |
WindowJoinSampleData.getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
DataStream<WindowJoin.Salary> |
WindowJoinSampleData$.getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Person> |
WindowJoin.joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
DataStream<WindowJoin.Person> |
WindowJoin$.joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.