public class HttpSource extends Object
SourceBuilder
to 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 |
---|
HttpSource() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
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.