Force buffered data to be processed

POST /_ml/anomaly_detectors/{job_id}/_flush

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.

Required authorization

Cluster privileges: manage_ml

Path Parameters

job_id string Id required: Identifier for the anomaly detection job.

An example body for a POST _ml/anomaly_detectors/low_request_rate/_flush request.

Request Console 1 / 8 languages

Console Kibana Dev Tools

POST _ml/anomaly_detectors/low_request_rate/_flush
{
  "calc_interim": true
}

JavaScript Elasticsearch JavaScript Client

const response = await client.ml.flushJob({
  job_id: "low_request_rate",
  calc_interim: true,
});

Python Elasticsearch Python Client

resp = client.ml.flush_job(
    job_id="low_request_rate",
    calc_interim=True,
)

curl Shell

curl -X POST "$ELASTICSEARCH_URL/_ml/anomaly_detectors/low_request_rate/_flush" \
  -H "Authorization: ApiKey $ELASTIC_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "calc_interim": true
  }'

Java Elasticsearch Java Client

client.ml().flushJob(f -> f
    .calcInterim(true)
    .jobId("low_request_rate")
);

C# Elasticsearch .NET Client

var response = await client.MachineLearning
    .FlushJobAsync(jobId: "low_request_rate", d1 => d1
        .CalcInterim(true)
    );

PHP Elasticsearch PHP Client

$resp = $client->ml()->flushJob([
    "job_id" => "low_request_rate",
    "body" => [
        "calc_interim" => true,
    ],
]);

Ruby Elasticsearch Ruby Client

response = client.ml.flush_job(
  job_id: "low_request_rate",
  body: {
    "calc_interim": true
  }
)

Response

No example

Required authorization

Path Parameters

Query Parameters { advance_time , calc_interim , end , skip_time , start , }

Request { advance_time , calc_interim , end , skip_time , start , }

Response

Query Parameters

Request