Class DiagnosticProcessors

java.lang.Object
com.hazelcast.jet.core.processor.DiagnosticProcessors

public final class DiagnosticProcessors extends Object
Static utility class with factories of sinks and wrappers that log the data flowing through the DAG. These processors are useful while diagnosing the execution of Jet jobs. For other kinds of processors refer to the package-level documentation.
Since:
Jet 3.0