Module org.elasticsearch.xcore
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
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classBuilder for collecting checkpointing information for the purpose of _statsNested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent
org.elasticsearch.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.xcontent.ToXContent.MapParams, org.elasticsearch.xcontent.ToXContent.ParamsNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final Stringstatic final TransformCheckpointingInfostatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final StringFields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY_PARAMS -
Constructor Summary
ConstructorsConstructorDescriptionTransformCheckpointingInfo(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. -
Method Summary
Modifier and TypeMethodDescriptionbooleangetLast()getNext()longinthashCode()toString()org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) voidwriteTo(StreamOutput out) Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragment
-
Field Details
-
EMPTY
-
LAST_CHECKPOINT
- See Also:
-
NEXT_CHECKPOINT
- See Also:
-
OPERATIONS_BEHIND
- See Also:
-
CHANGES_LAST_DETECTED_AT
- See Also:
-
CHANGES_LAST_DETECTED_AT_HUMAN
- See Also:
-
LAST_SEARCH_TIME
- See Also:
-
LAST_SEARCH_TIME_HUMAN
- See Also:
-
-
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 checkpointnext- stats of the next checkpointoperationsBehind- counter of operations the current checkpoint is behind sourcechangesLastDetectedAt- the last time the source indices changes have been foundlastSearchTime- the last time the source indices were searched
-
TransformCheckpointingInfo
- Throws:
IOException
-
-
Method Details
-
getLast
-
getNext
-
getOperationsBehind
public long getOperationsBehind() -
getChangesLastDetectedAt
-
getLastSearchTime
-
toXContent
public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException - Specified by:
toXContentin interfaceorg.elasticsearch.xcontent.ToXContent- Throws:
IOException
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
hashCode
public int hashCode() -
equals
-
toString
-