Package com.atlan.samples.events
Class NumaflowLogger
- java.lang.Object
-
- io.numaproj.numaflow.function.handlers.MapHandler
-
- com.atlan.samples.events.AbstractNumaflowHandler
-
- com.atlan.samples.events.NumaflowLogger
-
public class NumaflowLogger extends AbstractNumaflowHandler
Very basic example of logging a deserialized event and then passing it on to all subsequent vertexes, unchanged.
-
-
Field Summary
-
Fields inherited from class com.atlan.samples.events.AbstractNumaflowHandler
FAILURE, SUCCESS
-
-
Constructor Summary
Constructors Constructor Description NumaflowLogger()
Default constructor - pass handler up to superclass.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
main(java.lang.String[] args)
Register the event processing function.-
Methods inherited from class com.atlan.samples.events.AbstractNumaflowHandler
drop, failed, failed, forward, forward, getAtlanEvent, getHandler, processEvent, processMessage, succeeded, succeeded
-
-