3 ms·
This is done using the Jet API programmatically from your Java application. Jet is meant to be used operationally with developed and deployed applications. We
by gregrluck 9y ago
This is done using the Jet API programmatically from your Java application. Jet is meant to be used operationally with developed and deployed applications.
We can use HDFS as a source or a sink.
See https://github.com/hazelcast/hazelcast-jet-code-samples/blob/0.6-maintenance/batch/wordcount-hadoop/src/main/java/HadoopWordCount.java https://github.com/hazelcast/hazelcast-jet-code-samples/blob... for a HDFS Wordcount example.
Jet jobs run in an isolated class loader, which is distributed to the cluster when the Job is started. You do this by adding classes/jars to JobConfig. See http://docs.hazelcast.org/docs/jet/0.6/manual/#practical- http://docs.hazelcast.org/docs/jet/0.6/manual/#practical- considerations for details.