TopSpeedWindowing (flink 1.0-SNAPSHOT API)

```
public class TopSpeedWindowing
extends Object
```
An example of grouped stream windowing where different eviction and trigger policies can be used. A source fetches events from cars every 1 sec containing their id, their current speed (kmh), overall elapsed distance (m) and a timestamp. The streaming example triggers the top speed of each car every x meters elapsed for the last y seconds.

Nested Classes
Modifier and Type	Class and Description
`static class`	`TopSpeedWindowing.CarEvent`
`static class`	`TopSpeedWindowing.CarEvent$`

Constructors
Constructor and Description
`TopSpeedWindowing()`

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static int`	`evictionSec()`
`static scala.collection.immutable.Stream<TopSpeedWindowing.CarEvent>`	`genCarStream()`
`static void`	`main(String[] args)`
`static int`	`numOfCars()`
`static scala.Tuple4<Object,Object,Object,Object>`	`parseMap(String line)`
`static double`	`triggerMeters()`

public static void main(String[] args)

public static scala.collection.immutable.Stream<TopSpeedWindowing.CarEvent> genCarStream()

public static scala.Tuple4<Object,Object,Object,Object> parseMap(String line)

Back to Flink Website