Class JobStateSnapshot


  • public final class JobStateSnapshot
    extends java.lang.Object
    A handle to an exported state snapshot created using Job.exportSnapshot(String).
    Since:
    Jet 3.0
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      long creationTime()
      Returns the time the snapshot was created.
      java.lang.String dagJsonString()
      Returns the JSON representation of the DAG of the job this snapshot was created from.
      void destroy()
      Destroy the underlying distributed object.
      long jobId()
      Returns the job ID of the job the snapshot was originally exported from.
      java.lang.String jobName()
      Returns the job name of the job the snapshot was originally exported from.
      java.lang.String name()
      Returns the snapshot name.
      long payloadSize()
      Returns the size in bytes of the payload data of the state snapshot.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • name

        @Nonnull
        public java.lang.String name()
        Returns the snapshot name. This is the name that was given to Job.exportSnapshot(String).
      • creationTime

        public long creationTime()
        Returns the time the snapshot was created.
      • jobId

        public long jobId()
        Returns the job ID of the job the snapshot was originally exported from.
      • jobName

        @Nullable
        public java.lang.String jobName()
        Returns the job name of the job the snapshot was originally exported from.
      • payloadSize

        public long payloadSize()
        Returns the size in bytes of the payload data of the state snapshot. Doesn't include storage overhead and especially doesn't account for backup copies.
      • dagJsonString

        @Nonnull
        public java.lang.String dagJsonString()
        Returns the JSON representation of the DAG of the job this snapshot was created from.
      • destroy

        public void destroy()
        Destroy the underlying distributed object.