Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ml.dataframe

Class DataFrameAnalyticsTaskState

java.lang.Object

org.elasticsearch.xpack.core.ml.dataframe.DataFrameAnalyticsTaskState

All Implemented Interfaces:

NamedWriteable, Writeable, PersistentTaskState, ToXContent, ToXContentObject, MlTaskState

public class DataFrameAnalyticsTaskState
extends Object
implements PersistentTaskState, MlTaskState

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent

ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME

Fields inherited from interface org.elasticsearch.xcontent.ToXContent

EMPTY, EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
DataFrameAnalyticsTaskState(StreamInput in)
DataFrameAnalyticsTaskState(DataFrameAnalyticsState state, long allocationId, String reason, Instant lastStateChangeTime)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static DataFrameAnalyticsTaskState	fromXContent(XContentParser parser)
long	getAllocationId()
Instant	getLastStateChangeTime()	The time of the last state change.
String	getReason()
DataFrameAnalyticsState	getState()
String	getWriteableName()
int	hashCode()
boolean	isFailed()
boolean	isStatusStale(PersistentTasksCustomMetadata.PersistentTask<?> task)
XContentBuilder	toXContent(XContentBuilder builder, ToXContent.Params params)
void	writeTo(StreamOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.xcontent.ToXContentObject

isFragment

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

Constructor Details

DataFrameAnalyticsTaskState

public DataFrameAnalyticsTaskState(DataFrameAnalyticsState state,
 long allocationId,
 @Nullable
 String reason,
 @Nullable
 Instant lastStateChangeTime)

DataFrameAnalyticsTaskState

public DataFrameAnalyticsTaskState(StreamInput in)
                            throws IOException

Throws:

IOException

Method Details

fromXContent

public static DataFrameAnalyticsTaskState fromXContent(XContentParser parser)

getState

public DataFrameAnalyticsState getState()

getAllocationId

public long getAllocationId()

getReason

@Nullable
public String getReason()

getLastStateChangeTime

@Nullable
public Instant getLastStateChangeTime()

Description copied from interface: MlTaskState

The time of the last state change.

Specified by:

getLastStateChangeTime in interface MlTaskState

isFailed

public boolean isFailed()

Specified by:

isFailed in interface MlTaskState

Returns:

Is the task in the failed state?

isStatusStale

public boolean isStatusStale(PersistentTasksCustomMetadata.PersistentTask<?> task)

getWriteableName

public String getWriteableName()

Specified by:

getWriteableName in interface NamedWriteable

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Throws:

IOException

toXContent

public XContentBuilder toXContent(XContentBuilder builder,
 ToXContent.Params params)
                           throws IOException

Specified by:

toXContent in interface ToXContent

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object