public class TopicSink extends Object
SinkBuilder
to
build a sink for the Jet pipeline. The pipeline reads text files, finds
the lines starting with "the" and publishes them to a Hazelcast ITopic
. The sample code subscribes itself to the ITopic
and
prints the job's output.Constructor and Description |
---|
TopicSink() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args)
Creates a Hazelcast Jet cluster, attaches a topic listener and runs the pipeline
|
public static void main(String[] args)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.