Package com.hazelcast.jet.core.processor

package com.hazelcast.jet.core.processor

Contains static utility classes with factories of Jet processors. The factories are organized into several categories according to the role of the vertex they implement:

• SourceProcessors (have no inbound edges)
• SinkProcessors (have no outbound edges)
• Internal vertices (have both inbound and outbound edges)
• Diagnostic helpers

Since:

Jet 3.0

Related Packages

Package	Description
com.hazelcast.jet.core	Jet's Core API.
com.hazelcast.jet.core.function	Functional interfaces used by Jet Core API
com.hazelcast.jet.core.metrics	Jet's Job Metric API.
com.hazelcast.jet.core.test	Utilities for writing tests of Core API Processors.

Classes

Class	Description
DiagnosticProcessors	Static utility class with factories of sinks and wrappers that log the data flowing through the DAG.
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).