public class WindowJoin$ extends Object
The example works on two input streams with pairs (name, grade) and (name, salary) respectively. It joins the steams based on "name" within a configurable window.
The example uses a built-in sample data generator that generates the steams of pairs at a configurable rate.
Modifier and Type | Field and Description |
---|---|
static WindowJoin$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
WindowJoin$() |
Modifier and Type | Method and Description |
---|---|
DataStream<WindowJoin.Person> |
joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
void |
main(String[] args) |
public static final WindowJoin$ MODULE$
public void main(String[] args)
public DataStream<WindowJoin.Person> joinStreams(DataStream<WindowJoin.Grade> grades, DataStream<WindowJoin.Salary> salaries, long windowSize)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.