Class IterativeConditionRunner

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

    public class IterativeConditionRunner
    extends org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>
    A RichIterativeCondition wrapper to delegate invocation to the code generated RichIterativeCondition.
    See Also:
    Serialized Form
    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.flink.cep.pattern.conditions.IterativeCondition

        org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<T extends Object>
    • Constructor Summary

      Constructors 
      Constructor Description
      IterativeConditionRunner​(GeneratedFunction<org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>> generatedFunction)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      boolean filter​(org.apache.flink.table.data.RowData value, org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<org.apache.flink.table.data.RowData> ctx)  
      void open​(org.apache.flink.configuration.Configuration parameters)  
      • Methods inherited from class org.apache.flink.cep.pattern.conditions.RichIterativeCondition

        getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
    • Constructor Detail

      • IterativeConditionRunner

        public IterativeConditionRunner​(GeneratedFunction<org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>> generatedFunction)
    • Method Detail

      • open

        public void open​(org.apache.flink.configuration.Configuration parameters)
                  throws Exception
        Specified by:
        open in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        open in class org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>
        Throws:
        Exception
      • filter

        public boolean filter​(org.apache.flink.table.data.RowData value,
                              org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<org.apache.flink.table.data.RowData> ctx)
                       throws Exception
        Specified by:
        filter in class org.apache.flink.cep.pattern.conditions.IterativeCondition<org.apache.flink.table.data.RowData>
        Throws:
        Exception
      • close

        public void close()
                   throws Exception
        Specified by:
        close in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        close in class org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>
        Throws:
        Exception