Class TransformsRecord
- All Implemented Interfaces:
JsonpSerializable
@JsonpDeserializable public class TransformsRecord extends java.lang.Object implements JsonpSerializable
- See Also:
- API specification
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TransformsRecord.Builder
Builder forTransformsRecord
. -
Field Summary
Fields Modifier and Type Field Description static JsonpDeserializer<TransformsRecord>
_DESERIALIZER
Json deserializer forTransformsRecord
-
Method Summary
Modifier and Type Method Description java.lang.String
changesLastDetectionTime()
changes last detected timejava.lang.String
checkpoint()
checkpointjava.lang.String
checkpointDurationTimeExpAvg()
exponential average checkpoint processing time (milliseconds)java.lang.String
checkpointProgress()
progress of the checkpointjava.lang.String
createTime()
transform creation timejava.lang.String
deleteTime()
total time spent deleting documentsjava.lang.String
description()
descriptionjava.lang.String
destIndex()
destination indexjava.lang.String
docsPerSecond()
docs per secondjava.lang.String
documentsDeleted()
the number of documents deleted from the destination indexjava.lang.String
documentsIndexed()
the number of documents written to the destination indexjava.lang.String
documentsProcessed()
the number of documents read from source indices and processedjava.lang.String
frequency()
frequency of transformjava.lang.String
id()
the idjava.lang.String
indexedDocumentsExpAvg()
exponential average number of documents indexedjava.lang.String
indexFailure()
total number of index failuresjava.lang.String
indexTime()
total time spent indexing documentsjava.lang.String
indexTotal()
total number of index phases done by the transformjava.lang.String
lastSearchTime()
last time transform searched for updatesjava.lang.String
maxPageSearchSize()
max page search sizestatic TransformsRecord
of(java.util.function.Function<TransformsRecord.Builder,ObjectBuilder<TransformsRecord>> fn)
java.lang.String
pagesProcessed()
the number of pages processedjava.lang.String
pipeline()
transform pipelinejava.lang.String
processedDocumentsExpAvg()
exponential average number of documents processedjava.lang.String
processingTime()
the total time spent processing documentsjava.lang.String
reason()
reason for the current statejava.lang.String
searchFailure()
total number of search failuresjava.lang.String
searchTime()
total search timejava.lang.String
searchTotal()
total number of search phasesvoid
serialize(jakarta.json.stream.JsonGenerator generator, JsonpMapper mapper)
Serialize this object to JSON.protected void
serializeInternal(jakarta.json.stream.JsonGenerator generator, JsonpMapper mapper)
protected static void
setupTransformsRecordDeserializer(ObjectDeserializer<TransformsRecord.Builder> op)
java.lang.String
sourceIndex()
source indexjava.lang.String
state()
transform statejava.lang.String
toString()
java.lang.String
transformType()
batch or continuous transformjava.lang.String
triggerCount()
the number of times the transform has been triggeredjava.lang.String
version()
the version of Elasticsearch when the transform was createdMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Field Details
-
_DESERIALIZER
Json deserializer forTransformsRecord
-
-
Method Details
-
of
public static TransformsRecord of(java.util.function.Function<TransformsRecord.Builder,ObjectBuilder<TransformsRecord>> fn) -
id
@Nullable public final java.lang.String id()the idAPI name:
id
-
state
@Nullable public final java.lang.String state()transform stateAPI name:
state
-
checkpoint
@Nullable public final java.lang.String checkpoint()checkpointAPI name:
checkpoint
-
documentsProcessed
@Nullable public final java.lang.String documentsProcessed()the number of documents read from source indices and processedAPI name:
documents_processed
-
checkpointProgress
@Nullable public final java.lang.String checkpointProgress()progress of the checkpointAPI name:
checkpoint_progress
-
lastSearchTime
@Nullable public final java.lang.String lastSearchTime()last time transform searched for updatesAPI name:
last_search_time
-
changesLastDetectionTime
@Nullable public final java.lang.String changesLastDetectionTime()changes last detected timeAPI name:
changes_last_detection_time
-
createTime
@Nullable public final java.lang.String createTime()transform creation timeAPI name:
create_time
-
version
@Nullable public final java.lang.String version()the version of Elasticsearch when the transform was createdAPI name:
version
-
sourceIndex
@Nullable public final java.lang.String sourceIndex()source indexAPI name:
source_index
-
destIndex
@Nullable public final java.lang.String destIndex()destination indexAPI name:
dest_index
-
pipeline
@Nullable public final java.lang.String pipeline()transform pipelineAPI name:
pipeline
-
description
@Nullable public final java.lang.String description()descriptionAPI name:
description
-
transformType
@Nullable public final java.lang.String transformType()batch or continuous transformAPI name:
transform_type
-
frequency
@Nullable public final java.lang.String frequency()frequency of transformAPI name:
frequency
-
maxPageSearchSize
@Nullable public final java.lang.String maxPageSearchSize()max page search sizeAPI name:
max_page_search_size
-
docsPerSecond
@Nullable public final java.lang.String docsPerSecond()docs per secondAPI name:
docs_per_second
-
reason
@Nullable public final java.lang.String reason()reason for the current stateAPI name:
reason
-
searchTotal
@Nullable public final java.lang.String searchTotal()total number of search phasesAPI name:
search_total
-
searchFailure
@Nullable public final java.lang.String searchFailure()total number of search failuresAPI name:
search_failure
-
searchTime
@Nullable public final java.lang.String searchTime()total search timeAPI name:
search_time
-
indexTotal
@Nullable public final java.lang.String indexTotal()total number of index phases done by the transformAPI name:
index_total
-
indexFailure
@Nullable public final java.lang.String indexFailure()total number of index failuresAPI name:
index_failure
-
indexTime
@Nullable public final java.lang.String indexTime()total time spent indexing documentsAPI name:
index_time
-
documentsIndexed
@Nullable public final java.lang.String documentsIndexed()the number of documents written to the destination indexAPI name:
documents_indexed
-
deleteTime
@Nullable public final java.lang.String deleteTime()total time spent deleting documentsAPI name:
delete_time
-
documentsDeleted
@Nullable public final java.lang.String documentsDeleted()the number of documents deleted from the destination indexAPI name:
documents_deleted
-
triggerCount
@Nullable public final java.lang.String triggerCount()the number of times the transform has been triggeredAPI name:
trigger_count
-
pagesProcessed
@Nullable public final java.lang.String pagesProcessed()the number of pages processedAPI name:
pages_processed
-
processingTime
@Nullable public final java.lang.String processingTime()the total time spent processing documentsAPI name:
processing_time
-
checkpointDurationTimeExpAvg
@Nullable public final java.lang.String checkpointDurationTimeExpAvg()exponential average checkpoint processing time (milliseconds)API name:
checkpoint_duration_time_exp_avg
-
indexedDocumentsExpAvg
@Nullable public final java.lang.String indexedDocumentsExpAvg()exponential average number of documents indexedAPI name:
indexed_documents_exp_avg
-
processedDocumentsExpAvg
@Nullable public final java.lang.String processedDocumentsExpAvg()exponential average number of documents processedAPI name:
processed_documents_exp_avg
-
serialize
Serialize this object to JSON.- Specified by:
serialize
in interfaceJsonpSerializable
-
serializeInternal
-
toString
public java.lang.String toString()- Overrides:
toString
in classjava.lang.Object
-
setupTransformsRecordDeserializer
protected static void setupTransformsRecordDeserializer(ObjectDeserializer<TransformsRecord.Builder> op)
-