Class TransformCheckpointingInfo

java.lang.Object
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo
All Implemented Interfaces:
Writeable, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject

public class TransformCheckpointingInfo extends Object implements Writeable, org.elasticsearch.xcontent.ToXContentObject
Holds information about checkpointing regarding - the current checkpoint - the in progress checkpoint - the current state of the source
  • Field Details

  • Constructor Details

    • TransformCheckpointingInfo

      public TransformCheckpointingInfo(TransformCheckpointStats last, TransformCheckpointStats next, long operationsBehind, Instant changesLastDetectedAt, Instant lastSearchTime)
      Create checkpoint stats object with checkpoint information about the last and next checkpoint as well as the current state of source.
      Parameters:
      last - stats of the last checkpoint
      next - stats of the next checkpoint
      operationsBehind - counter of operations the current checkpoint is behind source
      changesLastDetectedAt - the last time the source indices changes have been found
      lastSearchTime - the last time the source indices were searched
    • TransformCheckpointingInfo

      public TransformCheckpointingInfo(StreamInput in) throws IOException
      Throws:
      IOException
  • Method Details

    • getLast

      public TransformCheckpointStats getLast()
    • getNext

      public TransformCheckpointStats getNext()
    • getOperationsBehind

      public long getOperationsBehind()
    • getChangesLastDetectedAt

      public Instant getChangesLastDetectedAt()
    • getLastSearchTime

      public Instant getLastSearchTime()
    • toXContent

      public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.xcontent.ToXContent
      Throws:
      IOException
    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Specified by:
      writeTo in interface Writeable
      Throws:
      IOException
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object other)
      Overrides:
      equals in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object