org.apache.beam.sdk.io.kafka

Class CheckStopReadingFnWrapper

java.lang.Object

org.apache.beam.sdk.io.kafka.CheckStopReadingFnWrapper

All Implemented Interfaces:

java.io.Serializable, CheckStopReadingFn, ProcessFunction<TopicPartition,java.lang.Boolean>, SerializableFunction<TopicPartition,java.lang.Boolean>

public class CheckStopReadingFnWrapper
extends java.lang.Object
implements CheckStopReadingFn

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
java.lang.Boolean	apply(TopicPartition input) Returns the result of invoking this function on the given input.
static @Nullable CheckStopReadingFnWrapper	of(@Nullable SerializableFunction<TopicPartition,java.lang.Boolean> serializableFunction)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.io.kafka.CheckStopReadingFn

setup, teardown

Method Detail

of

public static @Nullable CheckStopReadingFnWrapper of(@Nullable SerializableFunction<TopicPartition,java.lang.Boolean> serializableFunction)

apply

public java.lang.Boolean apply(TopicPartition input)

Description copied from interface: SerializableFunction

Returns the result of invoking this function on the given input.

Specified by:

apply in interface ProcessFunction<TopicPartition,java.lang.Boolean>

Specified by:

apply in interface SerializableFunction<TopicPartition,java.lang.Boolean>