Class RichCompositeIterativeCondition<T>

    • Method Detail

      • setRuntimeContext

        public void setRuntimeContext​(org.apache.flink.api.common.functions.RuntimeContext t)
        Specified by:
        setRuntimeContext in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        setRuntimeContext in class RichIterativeCondition<T>
      • open

        public void open​(org.apache.flink.api.common.functions.OpenContext openContext)
                  throws Exception
        Specified by:
        open in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        open in class RichIterativeCondition<T>
        Throws:
        Exception