Class ResizeRequest
org.elasticsearch.transport.TransportMessage
org.elasticsearch.transport.TransportRequest
org.elasticsearch.action.ActionRequest
org.elasticsearch.action.support.master.MasterNodeRequest<Request>
org.elasticsearch.action.support.master.AcknowledgedRequest<ResizeRequest>
org.elasticsearch.action.admin.indices.shrink.ResizeRequest
- All Implemented Interfaces:
IndicesRequest
,AckedRequest
,Writeable
,org.elasticsearch.common.xcontent.ToXContent
,org.elasticsearch.common.xcontent.ToXContentObject
,org.elasticsearch.core.RefCounted
,TaskAwareRequest
public class ResizeRequest
extends AcknowledgedRequest<ResizeRequest>
implements IndicesRequest, org.elasticsearch.common.xcontent.ToXContentObject
Request class to shrink an index into a single shard
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportRequest
TransportRequest.Empty
Nested classes/interfaces inherited from interface org.elasticsearch.action.IndicesRequest
IndicesRequest.Replaceable
Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent
org.elasticsearch.common.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.common.xcontent.ToXContent.MapParams, org.elasticsearch.common.xcontent.ToXContent.Params
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
Field Summary
Fields inherited from class org.elasticsearch.action.support.master.AcknowledgedRequest
DEFAULT_ACK_TIMEOUT, timeout
Fields inherited from class org.elasticsearch.action.support.master.MasterNodeRequest
DEFAULT_MASTER_NODE_TIMEOUT, masterNodeTimeout
Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent
EMPTY_PARAMS
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
obj)
void
fromXContent(org.elasticsearch.common.xcontent.XContentParser parser)
Returns the max primary shard size of the target indexReturns the type of the resize operationReturns the source index nameReturns theCreateIndexRequest
for the shrink indexint
hashCode()
[]
indices()
Returns the array of indices that the action relates toReturns the indices options used to resolve indices.void
copySettings)
void
setMaxPrimaryShardSize(ByteSizeValue maxPrimaryShardSize)
Sets the max primary shard size of the target index.void
setResizeType(ResizeType type)
The type of the resize operationvoid
index)
void
setTargetIndex(CreateIndexRequest targetIndexRequest)
void
setWaitForActiveShards(int waitForActiveShards)
A shortcut forsetWaitForActiveShards(ActiveShardCount)
where the numerical shard count is passed in, instead of having to first callActiveShardCount.from(int)
to get the ActiveShardCount.void
setWaitForActiveShards(ActiveShardCount waitForActiveShards)
Sets the number of shard copies that should be active for creation of the new shrunken index to return.org.elasticsearch.common.xcontent.XContentBuilder
toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params)
validate()
void
writeTo(StreamOutput out)
Write this into the StreamOutput.Methods inherited from class org.elasticsearch.action.support.master.AcknowledgedRequest
ackTimeout, timeout, timeout, timeout
Methods inherited from class org.elasticsearch.action.support.master.MasterNodeRequest
masterNodeTimeout, masterNodeTimeout, masterNodeTimeout
Methods inherited from class org.elasticsearch.action.ActionRequest
getShouldStoreResult
Methods inherited from class org.elasticsearch.transport.TransportRequest
getParentTask, setParentTask, toString
Methods inherited from class org.elasticsearch.transport.TransportMessage
decRef, incRef, remoteAddress, remoteAddress, tryIncRef
Methods inherited from class java.lang.
, , , , , , ,
Methods inherited from interface org.elasticsearch.cluster.ack.AckedRequest
masterNodeTimeout
Methods inherited from interface org.elasticsearch.action.IndicesRequest
allowsRemoteIndices, includeDataStreams
Methods inherited from interface org.elasticsearch.tasks.TaskAwareRequest
createTask, getDescription, setParentTask
Methods inherited from interface org.elasticsearch.common.xcontent.ToXContentObject
isFragment
-
Field Details
-
PARSER
public static final org.elasticsearch.common.xcontent.ObjectParser<> PARSER
-
-
Constructor Details
-
ResizeRequest
- Throws:
-
ResizeRequest
public ResizeRequest( targetIndex, sourceIndex)
-
-
Method Details
-
validate
- Specified by:
validate
in classActionRequest
-
setSourceIndex
public void setSourceIndex( index) -
writeTo
Description copied from interface:Writeable
Write this into the StreamOutput.- Specified by:
writeTo
in interfaceWriteable
- Overrides:
writeTo
in classAcknowledgedRequest<ResizeRequest>
- Throws:
-
indices
public [] indices()Description copied from interface:IndicesRequest
Returns the array of indices that the action relates to- Specified by:
indices
in interfaceIndicesRequest
-
indicesOptions
Description copied from interface:IndicesRequest
Returns the indices options used to resolve indices. They tell for instance whether a single index is accepted, whether an empty array will be converted to _all, and how wildcards will be expanded if needed.- Specified by:
indicesOptions
in interfaceIndicesRequest
-
setTargetIndex
-
getTargetIndexRequest
Returns theCreateIndexRequest
for the shrink index -
getSourceIndex
public getSourceIndex()Returns the source index name -
setWaitForActiveShards
Sets the number of shard copies that should be active for creation of the new shrunken index to return. Defaults toActiveShardCount.DEFAULT
, which will wait for one shard copy (the primary) to become active. Set this value toActiveShardCount.ALL
to wait for all shards (primary and all replicas) to be active before returning. Otherwise, useActiveShardCount.from(int)
to set this value to any non-negative integer, up to the number of copies per shard (number of replicas + 1), to wait for the desired amount of shard copies to become active before returning. Index creation will only wait up until the timeout value for the number of shard copies to be active before returning. CheckShardsAcknowledgedResponse.isShardsAcknowledged()
to determine if the requisite shard copies were all started before returning or timing out.- Parameters:
waitForActiveShards
- number of active shard copies to wait on
-
setWaitForActiveShards
public void setWaitForActiveShards(int waitForActiveShards)A shortcut forsetWaitForActiveShards(ActiveShardCount)
where the numerical shard count is passed in, instead of having to first callActiveShardCount.from(int)
to get the ActiveShardCount. -
setResizeType
The type of the resize operation -
getResizeType
Returns the type of the resize operation -
setCopySettings
public void setCopySettings( copySettings) -
getCopySettings
public getCopySettings() -
setMaxPrimaryShardSize
Sets the max primary shard size of the target index. It's used to calculate an optimum shards number of the target index according to storage of the source index, each shard's storage of the target index will not be greater than this parameter, while the shards number of the target index still be a factor of the source index's shards number.- Parameters:
maxPrimaryShardSize
- the max primary shard size of the target index
-
getMaxPrimaryShardSize
Returns the max primary shard size of the target index -
toXContent
public org.elasticsearch.common.xcontent.XContentBuilder toXContent(org.elasticsearch.common.xcontent.XContentBuilder builder, org.elasticsearch.common.xcontent.ToXContent.Params params) throws- Specified by:
toXContent
in interfaceorg.elasticsearch.common.xcontent.ToXContent
- Throws:
-
fromXContent
public void fromXContent(org.elasticsearch.common.xcontent.XContentParser parser) throws- Throws:
-
equals
public boolean equals( obj)- Overrides:
in class
-
hashCode
public int hashCode()- Overrides:
in class
-