public class WindowJoin extends Object
This example will join two streams with a sliding window. One which emits grades and one which emits salaries of people. The input format for both sources has an additional timestamp as field 0. This is used to to event-time windowing. Time timestamps must be monotonically increasing. This example shows how to:
Modifier and Type | Class and Description |
---|---|
static class |
WindowJoin.GradeSource
Continuously emit tuples with random names and integers (grades).
|
static class |
WindowJoin.MyJoinFunction |
static class |
WindowJoin.MySourceMap |
static class |
WindowJoin.SalarySource
Continuously emit tuples with random names and integers (salaries).
|
Constructor and Description |
---|
WindowJoin() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.