Module org.elasticsearch.xcore
Class FlushJobAction.Request
java.lang.Object
org.elasticsearch.transport.TransportMessage
org.elasticsearch.transport.TransportRequest
org.elasticsearch.action.ActionRequest
org.elasticsearch.action.support.tasks.BaseTasksRequest<FlushJobAction.Request>
org.elasticsearch.xpack.core.ml.action.JobTaskRequest<FlushJobAction.Request>
org.elasticsearch.xpack.core.ml.action.FlushJobAction.Request
- All Implemented Interfaces:
Writeable,org.elasticsearch.core.RefCounted,TaskAwareRequest,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject
- Enclosing class:
FlushJobAction
public static class FlushJobAction.Request
extends JobTaskRequest<FlushJobAction.Request>
implements org.elasticsearch.xcontent.ToXContentObject
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent
org.elasticsearch.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.xcontent.ToXContent.MapParams, org.elasticsearch.xcontent.ToXContent.ParamsNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final org.elasticsearch.xcontent.ParseFieldstatic final org.elasticsearch.xcontent.ParseFieldstatic final org.elasticsearch.xcontent.ParseFieldstatic final org.elasticsearch.xcontent.ParseFieldstatic final org.elasticsearch.xcontent.ParseFieldFields inherited from class org.elasticsearch.action.support.tasks.BaseTasksRequest
ALL_ACTIONS, ALL_NODESFields inherited from interface org.elasticsearch.core.RefCounted
ALWAYS_REFERENCEDFields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY, EMPTY_PARAMS -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanbooleangetEnd()getStart()inthashCode()booleanbooleanstatic FlushJobAction.RequestparseRequest(String jobId, org.elasticsearch.xcontent.XContentParser parser) voidsetAdvanceTime(String advanceTime) voidsetCalcInterim(boolean calcInterim) voidvoidsetRefreshRequired(boolean refreshRequired) Used internally.voidsetSkipTime(String skipTime) voidvoidsetWaitForNormalization(boolean waitForNormalization) Used internally.org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) voidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.xpack.core.ml.action.JobTaskRequest
getJobId, matchMethods inherited from class org.elasticsearch.action.support.tasks.BaseTasksRequest
getActions, getNodes, getParentTaskId, getTargetParentTaskId, getTargetTaskId, getTaskId, getTimeout, setActions, setNodes, setParentTaskId, setTargetParentTaskId, setTargetTaskId, setTaskId, setTimeout, validateMethods inherited from class org.elasticsearch.action.ActionRequest
getShouldStoreResultMethods inherited from class org.elasticsearch.transport.TransportRequest
getParentTask, getRequestId, setParentTask, setRequestId, toStringMethods inherited from class org.elasticsearch.transport.TransportMessage
decRef, hasReferences, incRef, remoteAddress, remoteAddress, tryIncRefMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.core.RefCounted
mustIncRefMethods inherited from interface org.elasticsearch.tasks.TaskAwareRequest
createTask, getDescription, setParentTaskMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragment
-
Field Details
-
CALC_INTERIM
public static final org.elasticsearch.xcontent.ParseField CALC_INTERIM -
START
public static final org.elasticsearch.xcontent.ParseField START -
END
public static final org.elasticsearch.xcontent.ParseField END -
ADVANCE_TIME
public static final org.elasticsearch.xcontent.ParseField ADVANCE_TIME -
SKIP_TIME
public static final org.elasticsearch.xcontent.ParseField SKIP_TIME
-
-
Constructor Details
-
Request
public Request() -
Request
- Throws:
IOException
-
Request
-
-
Method Details
-
parseRequest
public static FlushJobAction.Request parseRequest(String jobId, org.elasticsearch.xcontent.XContentParser parser) -
writeTo
- Specified by:
writeToin interfaceWriteable- Overrides:
writeToin classJobTaskRequest<FlushJobAction.Request>- Throws:
IOException
-
getCalcInterim
public boolean getCalcInterim() -
setCalcInterim
public void setCalcInterim(boolean calcInterim) -
getStart
-
setStart
-
getEnd
-
setEnd
-
getAdvanceTime
-
setAdvanceTime
-
getSkipTime
-
setSkipTime
-
isWaitForNormalization
public boolean isWaitForNormalization() -
isRefreshRequired
public boolean isRefreshRequired() -
setWaitForNormalization
public void setWaitForNormalization(boolean waitForNormalization) Used internally. Datafeeds do not need to wait for renormalization to complete before continuing. For large jobs, renormalization can take minutes, causing datafeeds to needlessly pause execution. -
setRefreshRequired
public void setRefreshRequired(boolean refreshRequired) Used internally. For datafeeds, there is no need for the results to be searchable after the flush, as the datafeed itself does not search them immediately. Particularly for short bucket spans these refreshes could be a significant cost. -
hashCode
public int hashCode() -
equals
-
toXContent
public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException - Specified by:
toXContentin interfaceorg.elasticsearch.xcontent.ToXContent- Throws:
IOException
-