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

Interface CheckStopReadingFn

All Superinterfaces:
ProcessFunction<TopicPartition,Boolean>, Serializable, SerializableFunction<TopicPartition,Boolean>
All Known Implementing Classes:
CheckStopReadingFnWrapper
public interface CheckStopReadingFn extends SerializableFunction<TopicPartition,Boolean>

  • Method Summary

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

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

    apply

  • Method Details

    • setup

      default void setup()

    • teardown

      default void teardown()