public class StockExchange extends Object
The sample starts a thread that randomly generates trade events and puts them into a Hazelcast Map. The Jet job receives these events and calculates for each stock the number of trades completed within the duration of a sliding window. It outputs the results to the console log.
Constructor and Description |
---|
StockExchange() |
public static void main(String[] args) throws InterruptedException
InterruptedException
Copyright © 2020 Hazelcast, Inc.. All rights reserved.