Class NumaflowLogger


  • public class NumaflowLogger
    extends AbstractNumaflowHandler
    Very basic example of logging a deserialized event and then passing it on to all subsequent vertexes, unchanged.
    • Constructor Detail

      • NumaflowLogger

        public NumaflowLogger()
        Default constructor - pass handler up to superclass.
    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                         throws java.lang.Exception
        Register the event processing function.
        Parameters:
        args - (unused)
        Throws:
        java.lang.Exception - on any errors starting the event processor