Class FlushJobRequest
java.lang.Object
co.elastic.clients.elasticsearch._types.RequestBase
co.elastic.clients.elasticsearch.ml.FlushJobRequest
- All Implemented Interfaces:
JsonpSerializable
Forces any buffered data to be processed by the job. The flush jobs API is
only applicable when sending data for analysis using the post data API.
Depending on the content of the buffer, then it might additionally calculate
new results. Both flush and close operations are similar, however the flush
is more efficient if you are expecting to send more data for analysis. When
flushing, the job remains open and is available to continue analyzing data. A
close operation additionally prunes and persists the model state to disk and
the job must be opened again before analyzing further data.
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class co.elastic.clients.elasticsearch._types.RequestBase
RequestBase.AbstractBuilder<BuilderT extends RequestBase.AbstractBuilder<BuilderT>>
-
Field Summary
Modifier and TypeFieldDescriptionstatic final JsonpDeserializer<FlushJobRequest>
Json deserializer forFlushJobRequest
static final Endpoint<FlushJobRequest,
FlushJobResponse, ErrorResponse> Endpoint "ml.flush_job
". -
Method Summary
Modifier and TypeMethodDescriptionfinal String
Specifies to advance to a particular time value.final Boolean
If true, calculates the interim results for the most recent bucket or all buckets within the latency period.final String
end()
When used in conjunction withcalc_interim
, specifies the range of buckets on which to calculate interim results.final String
jobId()
Required - Identifier for the anomaly detection job.static FlushJobRequest
void
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
final String
skipTime()
Specifies to skip to a particular time value.final String
start()
When used in conjunction with calc_interim, specifies the range of buckets on which to calculate interim results.Methods inherited from class co.elastic.clients.elasticsearch._types.RequestBase
toString
-
Field Details
-
_DESERIALIZER
Json deserializer forFlushJobRequest
-
_ENDPOINT
Endpoint "ml.flush_job
".
-
-
Method Details
-
of
public static FlushJobRequest of(Function<FlushJobRequest.Builder, ObjectBuilder<FlushJobRequest>> fn) -
advanceTime
Specifies to advance to a particular time value. Results are generated and the model is updated for data from the specified time interval.API name:
advance_time
-
calcInterim
If true, calculates the interim results for the most recent bucket or all buckets within the latency period.API name:
calc_interim
-
end
When used in conjunction withcalc_interim
, specifies the range of buckets on which to calculate interim results.API name:
end
-
jobId
Required - Identifier for the anomaly detection job.API name:
job_id
-
skipTime
Specifies to skip to a particular time value. Results are not generated and the model is not updated for data from the specified time interval.API name:
skip_time
-
start
When used in conjunction with calc_interim, specifies the range of buckets on which to calculate interim results.API name:
start
-
serialize
Serialize this object to JSON.- Specified by:
serialize
in interfaceJsonpSerializable
-
serializeInternal
-
setupFlushJobRequestDeserializer
protected static void setupFlushJobRequestDeserializer(ObjectDeserializer<FlushJobRequest.Builder> op)
-