Packages

package function

Type Members

  1. abstract class CoProcessFunctionInterceptor[IN1, IN2, OUT] extends CoProcessFunction[IN1, IN2, OUT]

    This class wraps underlying CoProcessFunction and add possibility to add additional behaviour before and after processElement1/processElement2.

    This class wraps underlying CoProcessFunction and add possibility to add additional behaviour before and after processElement1/processElement2. It can be used in tests for some kind of synchronization or in production kind for some additional logging, reports and so on.

  2. abstract class ProcessFunctionInterceptor[IN, OUT] extends KeyedProcessFunction[String, IN, OUT]

Ungrouped