public class BasicObservable extends Object
The concrete job we are observing produces a simple stream of random numbers, from which we compute the top N for each one second tumbling window.
The results observed are ordered lists of the top N numbers and are printed once for each window, as they become available.
|Modifier and Type||Field and Description|
|Constructor and Description|
Copyright © 2020 Hazelcast, Inc.. All rights reserved.