Package com.hazelcast.jet.core.processor

Apache Kafka reader/writer support for Hazelcast Jet.

See: Description

Class Summary

Class	Description
DiagnosticProcessors	Static utility class with factories of sinks and wrappers that log the data flowing through the DAG.
HdfsProcessors	Static utility class with factories of Apache Hadoop HDFS source and sink processors.
KafkaProcessors	Static utility class with factories of Apache Kafka source and sink processors.
Processors	Static utility class with factory methods for Jet processors.
SinkProcessors	Static utility class with factories of sink processors (the terminators of the DAG data flow).
SourceProcessors	Static utility class with factories of source processors (the DAG entry points).

Package com.hazelcast.jet.core.processor Description

Apache Kafka reader/writer support for Hazelcast Jet.