Class SubtypeCondition<T>

  • Type Parameters:
    T - Type of the elements to be filtered
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.FilterFunction<T>, org.apache.flink.api.common.functions.Function

    @Internal
    public class SubtypeCondition<T>
    extends SimpleCondition<T>
    A condition which filters elements of the given type. An element is filtered out iff it is not assignable to the given subtype of T.
    See Also:
    Serialized Form
    • Constructor Detail

      • SubtypeCondition

        public SubtypeCondition​(Class<? extends T> subtype)