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 | Class and Description |
---|---|
static class |
WindowJoin.Grade |
static class |
WindowJoin.Grade$ |
static class |
WindowJoin.Person |
static class |
WindowJoin.Person$ |
static class |
WindowJoin.Salary |
static class |
WindowJoin.Salary$ |
Constructor and Description |
---|
WindowJoin() |
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Person> |
joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
static void |
main(String[] args) |
public static void main(String[] args)
public static DataStream<WindowJoin.Person> joinStreams(DataStream<WindowJoin.Grade> grades, DataStream<WindowJoin.Salary> salaries, long windowSize)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.