Package org.apache.beam.runners.spark.io

Class EmptyCheckpointMark

java.lang.Object
org.apache.beam.runners.spark.io.EmptyCheckpointMark
All Implemented Interfaces:
Serializable, org.apache.beam.sdk.io.UnboundedSource.CheckpointMark
public class EmptyCheckpointMark extends Object implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark, Serializable
Passing null values to Spark's Java API may cause problems because of Guava preconditions. See: JavaUtils.optionToOptional(scala.Option<T>)
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

    org.apache.beam.sdk.io.UnboundedSource.CheckpointMark.NoopCheckpointMark

  • Field Summary

    Fields inherited from interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

    NOOP_CHECKPOINT_MARK

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    equals(@Nullable Object obj)
     
    void
    finalizeCheckpoint()
     
    static EmptyCheckpointMark
    get()
     
    int
    hashCode()
     

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

    getOffsetLimit

  • Method Details

    • get

      public static EmptyCheckpointMark get()

    • finalizeCheckpoint

      public void finalizeCheckpoint() throws IOException
      Specified by:
      finalizeCheckpoint in interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark
      Throws:
      IOException

    • equals

      public boolean equals(@Nullable Object obj)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object