Package org.elasticsearch.client

Class RollupClient

java.lang.Object

org.elasticsearch.client.RollupClient

public class RollupClient
extends java.lang.Object

A wrapper for the RestHighLevelClient that provides methods for accessing the Elastic Rollup-related methods

See the X-Pack Rollup APIs on elastic.co for more information.

Method Summary

Modifier and Type	Method	Description
AcknowledgedResponse	deleteRollupJob(DeleteRollupJobRequest request, RequestOptions options)	Delete a rollup job from the cluster See the docs for more.
Cancellable	deleteRollupJobAsync(DeleteRollupJobRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener)	Asynchronously delete a rollup job from the cluster See The docs for details.
GetRollupCapsResponse	getRollupCapabilities(GetRollupCapsRequest request, RequestOptions options)	Get the Rollup Capabilities of a target (non-rollup) index or pattern See the docs for more.
Cancellable	getRollupCapabilitiesAsync(GetRollupCapsRequest request, RequestOptions options, ActionListener<GetRollupCapsResponse> listener)	Asynchronously Get the Rollup Capabilities of a target (non-rollup) index or pattern See the docs for more.
GetRollupIndexCapsResponse	getRollupIndexCapabilities(GetRollupIndexCapsRequest request, RequestOptions options)	Get the Rollup Index Capabilities of a rollup index or pattern See the docs for more.
Cancellable	getRollupIndexCapabilitiesAsync(GetRollupIndexCapsRequest request, RequestOptions options, ActionListener<GetRollupIndexCapsResponse> listener)	Asynchronously Get the Rollup Index Capabilities of a rollup index or pattern See the docs for more.
GetRollupJobResponse	getRollupJob(GetRollupJobRequest request, RequestOptions options)	Get a rollup job from the cluster.
Cancellable	getRollupJobAsync(GetRollupJobRequest request, RequestOptions options, ActionListener<GetRollupJobResponse> listener)	Asynchronously get a rollup job from the cluster.
AcknowledgedResponse	putRollupJob(PutRollupJobRequest request, RequestOptions options)	Put a rollup job into the cluster See the docs for more.
Cancellable	putRollupJobAsync(PutRollupJobRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener)	Asynchronously put a rollup job into the cluster See the docs for more.
SearchResponse	search(SearchRequest request, RequestOptions options)	Perform a rollup search.
Cancellable	searchAsync(SearchRequest request, RequestOptions options, ActionListener<SearchResponse> listener)	Perform a rollup search.
StartRollupJobResponse	startRollupJob(StartRollupJobRequest request, RequestOptions options)	Start a rollup job See the docs for more.
Cancellable	startRollupJobAsync(StartRollupJobRequest request, RequestOptions options, ActionListener<StartRollupJobResponse> listener)	Asynchronously start a rollup job See the docs for more.
StopRollupJobResponse	stopRollupJob(StopRollupJobRequest request, RequestOptions options)	Stop a rollup job See the docs for more.
Cancellable	stopRollupJobAsync(StopRollupJobRequest request, RequestOptions options, ActionListener<StopRollupJobResponse> listener)	Asynchronously stop a rollup job See the docs for more.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

putRollupJob

public AcknowledgedResponse putRollupJob(PutRollupJobRequest request, RequestOptions options) throws java.io.IOException

Put a rollup job into the cluster See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

putRollupJobAsync

public Cancellable putRollupJobAsync(PutRollupJobRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener)

Asynchronously put a rollup job into the cluster See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

startRollupJob

public StartRollupJobResponse startRollupJob(StartRollupJobRequest request, RequestOptions options) throws java.io.IOException

Start a rollup job See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

startRollupJobAsync

public Cancellable startRollupJobAsync(StartRollupJobRequest request, RequestOptions options, ActionListener<StartRollupJobResponse> listener)

Asynchronously start a rollup job See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

stopRollupJob

public StopRollupJobResponse stopRollupJob(StopRollupJobRequest request, RequestOptions options) throws java.io.IOException

Stop a rollup job See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

stopRollupJobAsync

public Cancellable stopRollupJobAsync(StopRollupJobRequest request, RequestOptions options, ActionListener<StopRollupJobResponse> listener)

Asynchronously stop a rollup job See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

deleteRollupJob

public AcknowledgedResponse deleteRollupJob(DeleteRollupJobRequest request, RequestOptions options) throws java.io.IOException

Delete a rollup job from the cluster See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

deleteRollupJobAsync

public Cancellable deleteRollupJobAsync(DeleteRollupJobRequest request, RequestOptions options, ActionListener<AcknowledgedResponse> listener)

Asynchronously delete a rollup job from the cluster See The docs for details.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

getRollupJob

public GetRollupJobResponse getRollupJob(GetRollupJobRequest request, RequestOptions options) throws java.io.IOException

Get a rollup job from the cluster. See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

getRollupJobAsync

public Cancellable getRollupJobAsync(GetRollupJobRequest request, RequestOptions options, ActionListener<GetRollupJobResponse> listener)

Asynchronously get a rollup job from the cluster. See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

search

public SearchResponse search(SearchRequest request, RequestOptions options) throws java.io.IOException

Perform a rollup search. See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

searchAsync

public Cancellable searchAsync(SearchRequest request, RequestOptions options, ActionListener<SearchResponse> listener)

Perform a rollup search. See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

getRollupCapabilities

public GetRollupCapsResponse getRollupCapabilities(GetRollupCapsRequest request, RequestOptions options) throws java.io.IOException

Get the Rollup Capabilities of a target (non-rollup) index or pattern See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

getRollupCapabilitiesAsync

public Cancellable getRollupCapabilitiesAsync(GetRollupCapsRequest request, RequestOptions options, ActionListener<GetRollupCapsResponse> listener)

Asynchronously Get the Rollup Capabilities of a target (non-rollup) index or pattern See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request

getRollupIndexCapabilities

public GetRollupIndexCapsResponse getRollupIndexCapabilities(GetRollupIndexCapsRequest request, RequestOptions options) throws java.io.IOException

Get the Rollup Index Capabilities of a rollup index or pattern See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

Returns:

the response

Throws:

java.io.IOException - in case there is a problem sending the request or parsing back the response

getRollupIndexCapabilitiesAsync

public Cancellable getRollupIndexCapabilitiesAsync(GetRollupIndexCapsRequest request, RequestOptions options, ActionListener<GetRollupIndexCapsResponse> listener)

Asynchronously Get the Rollup Index Capabilities of a rollup index or pattern See the docs for more.

Parameters:

request - the request

options - the request options (e.g. headers), use RequestOptions.DEFAULT if nothing needs to be customized

listener - the listener to be notified upon request completion

Returns:

cancellable that may be used to cancel the request