org.apache.samza.operators.functions

Interface FilterFunction<M>

Type Parameters:

M - type of the input message

All Superinterfaces:

ClosableFunction, InitableFunction, java.io.Serializable

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 InitableFunction, ClosableFunction, java.io.Serializable

Specifies whether a message should be retained for further processing.

Method Summary

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

Methods inherited from interface org.apache.samza.operators.functions.InitableFunction

init

Methods inherited from interface org.apache.samza.operators.functions.ClosableFunction

close

Method Detail

apply

boolean apply(M message)

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

Parameters:

message - the input message to be checked

Returns:

true if message should be retained