public class HttpSource extends Object
SourceBuilderto build a source connector for the Jet pipeline. It starts a simple system-monitoring HTTP service. The connector polls it for events that contain the measurement of the used JVM heap.
The pipeline finds the linear trend of used memory over a sliding window; in other words, the current allocation rate. It sends the output to a Hazelcast map.
The sample starts a GUI window that shows the allocation rate over time in a graph.
|Constructor and Description|
|Modifier and Type||Method and Description|
Starts the system-monitoring HTTP service, the GUI screen and Hazelcast Jet, and runs the stream job on it.
public static void main(String args)
Copyright © 2020 Hazelcast, Inc.. All rights reserved.