org.apache.beam.sdk.io.kafka

Interface CheckStopReadingFn

All Superinterfaces:

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

All Known Implementing Classes:

CheckStopReadingFnWrapper

public interface CheckStopReadingFn
extends SerializableFunction<TopicPartition,java.lang.Boolean>

Method Summary

Modifier and Type	Method and Description
default void	setup()
default void	teardown()

Methods inherited from interface org.apache.beam.sdk.transforms.SerializableFunction

apply

Method Detail

setup

default void setup()

teardown

default void teardown()