org.apache.flink.cep.pattern

Class SubtypeFilterFunction<T>

java.lang.Object

org.apache.flink.cep.pattern.SubtypeFilterFunction<T>

Type Parameters:

T - Type of the elements to be filtered

All Implemented Interfaces:

Serializable, FilterFunction<T>, Function

Deprecated.

This is only used when migrating from an older Flink version. Use the SubtypeCondition instead.

@Deprecated
public class SubtypeFilterFunction<T>
extends Object
implements FilterFunction<T>

A filter function which filters elements of the given type. A element if filtered out iff it is not assignable to the given subtype of T.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SubtypeFilterFunction(Class<? extends T> subtype) Deprecated.

Method Summary

Modifier and Type	Method and Description
boolean	filter(T value) Deprecated. The filter function that evaluates the predicate.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubtypeFilterFunction

public SubtypeFilterFunction(Class<? extends T> subtype)

Deprecated.

Method Detail

filter

public boolean filter(T value)
               throws Exception

Deprecated.

Description copied from interface: FilterFunction

The filter function that evaluates the predicate.

IMPORTANT: The system assumes that the function does not modify the elements on which the predicate is applied. Violating this assumption can lead to incorrect results.

Specified by:

filter in interface FilterFunction<T>

Parameters:

value - The value to be filtered.

Returns:

True for values that should be retained, false for values to be filtered out.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.