A repository of code samples for Hazelcast Jet. It covers the high-level APIs (pipelines and java.util.stream) as well as the lower-level Core API. This is the basic layout of the directories:
batch: batch jobs with high-level APIsstreaming: streaming jobs with high-level APIspcf: a sample application on the Pivotal Cloud Foundry infrastructurecore-api/batch: batch jobs with the Core APIcore-api/streaming: streaming jobs with the Core APIsample-data: a module containing the sample data shared by several samplesrefman: code snippets used in the Reference Manual
-
Analyzes access log files from an HTTP server. Demonstrates the usage of file sources and sinks.
-
Uses the co-group transform to perform a full outer join of three streams on a common join key (a many-to-many relationship).
-
Demonstrates the usage of Hazelcast
IMap,ICacheandIListas data sources and sinks. -
Several basic samples using the java.util.stream API.
-
Analyzes a set of documents and finds the number of occurrences of each word they contain.
-
A Word Count job with the Hadoop File System as both source and sink.
-
Data Enrichment Using Hash-Join
Uses the hash-join transform to enrich an infinite stream of trade events. Attaches to each event the associated product and broker objects.
-
Consumes and filters events generated from a Hazelcast
IMap's Event Journal. -
Demonstrates the usage of a Kafka topic as a Jet data source. Pours the data from a Kafka topic to a Hazelcast
IMap. -
Two code samples showing the usage of a TCP/IP socket as a source and a sink.
The directory pcf contains a sample Spring Boot application which shows how to use Hazelcast Jet in Pivotal Cloud Foundry environment.
Refer to the core-api readme for details on its contents.
Hazelcast is available under the Apache 2 License. Please see the Licensing section for more information.
Copyright (c) 2008-2017, Hazelcast, Inc. All Rights Reserved.
Visit www.hazelcast.com for more info.