Class LatencymarkEmitTransform<I,​O>

    • Constructor Detail

      • LatencymarkEmitTransform

        public LatencymarkEmitTransform()
    • Method Detail

      • getOutputCollector

        public OutputCollector<O> getOutputCollector()
        get OutputCollector.
        Returns:
        the output collector.
      • onLatencymark

        public final void onLatencymark​(LatencyMark latencymark)
        Description copied from interface: Transform
        On latencymark received.
        Specified by:
        onLatencymark in interface Transform<I,​O>
        Parameters:
        latencymark - latencymark