Class StreamIntrospectionProcessor
- java.lang.Object
-
- org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionProcessor
-
- All Implemented Interfaces:
StreamProcessorTopology
public class StreamIntrospectionProcessor extends Object implements StreamProcessorTopology
A processor to introspect Nuxeo Stream activities at the cluster level.- Since:
- 11.5
-
-
Constructor Summary
Constructors Constructor Description StreamIntrospectionProcessor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Topology
getTopology(Map<String,String> options)
Returns a Stream computation topology.
-
-
-
Method Detail
-
getTopology
public Topology getTopology(Map<String,String> options)
Description copied from interface:StreamProcessorTopology
Returns a Stream computation topology.- Specified by:
getTopology
in interfaceStreamProcessorTopology
-
-