Package org.apache.beam.runners.flink.translation.wrappers.streaming.io

Interface BeamStoppableFunction

All Known Implementing Classes:
UnboundedSourceWrapper
public interface BeamStoppableFunction
Custom StoppableFunction for backward compatibility.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    stop()
    Unused method for backward compatibility.

  • Method Details

    • stop

      void stop()
      Unused method for backward compatibility.