org.apache.samza.operators.functions

Interface FilterFunction<M extends MessageEnvelope>

Type Parameters:

M - type of the input MessageEnvelope

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@InterfaceStability.Unstable
 @FunctionalInterface
public interface FilterFunction<M extends MessageEnvelope>

A function that specifies whether a MessageEnvelope should be retained for further processing or filtered out.

Method Summary

Modifier and Type	Method and Description
boolean	apply(M message) Returns a boolean indicating whether this MessageEnvelope should be retained or filtered out.

Method Detail

apply

boolean apply(M message)

Returns a boolean indicating whether this MessageEnvelope should be retained or filtered out.

Parameters:

message - the MessageEnvelope to be checked

Returns:

true if MessageEnvelope should be retained