Class FlushJobAction.Request

All Implemented Interfaces:
Writeable, org.elasticsearch.core.RefCounted, TaskAwareRequest, TransportRequest, 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
  • 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

  • Method Details

    • parseRequest

      public static FlushJobAction.Request parseRequest(String jobId, org.elasticsearch.xcontent.XContentParser parser)
    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Specified by:
      writeTo in interface Writeable
      Overrides:
      writeTo in class JobTaskRequest<FlushJobAction.Request>
      Throws:
      IOException
    • getCalcInterim

      public boolean getCalcInterim()
    • setCalcInterim

      public void setCalcInterim(boolean calcInterim)
    • getStart

      public String getStart()
    • setStart

      public void setStart(String start)
    • getEnd

      public String getEnd()
    • setEnd

      public void setEnd(String end)
    • getAdvanceTime

      public String getAdvanceTime()
    • setAdvanceTime

      public void setAdvanceTime(String advanceTime)
    • getSkipTime

      public String getSkipTime()
    • setSkipTime

      public void setSkipTime(String skipTime)
    • 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()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object
    • toXContent

      public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.xcontent.ToXContent
      Throws:
      IOException