package function
Type Members
-
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.