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

Interface BufferedElement

public interface BufferedElement
An interface for elements buffered during a checkpoint when using @RequiresStableInput.

  • Method Summary

    Modifier and Type
    Method
    Description
    <InputT, OutputT>
    void
    processWith(org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> doFnRunner)
    Processes this element with the provided DoFnRunner.

  • Method Details

    • processWith

      <InputT, OutputT> void processWith(org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> doFnRunner)
      Processes this element with the provided DoFnRunner.