Package org.apache.beam.sdk.io.kafka

Class CheckStopReadingFnWrapper

java.lang.Object

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

All Implemented Interfaces:

Serializable, CheckStopReadingFn, ProcessFunction<TopicPartition,Boolean>, SerializableFunction<TopicPartition,Boolean>

public class CheckStopReadingFnWrapper
extends Object
implements CheckStopReadingFn

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
Boolean	apply(TopicPartition input)	Returns the result of invoking this function on the given input.
static @Nullable CheckStopReadingFnWrapper	of(@Nullable SerializableFunction<TopicPartition,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 Details

of

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

apply

public 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,Boolean>

Specified by:

apply in interface SerializableFunction<TopicPartition,Boolean>