ClusterState.FeatureAware
, Diffable<MetaData.Custom>
, MetaData.Custom
, NamedDiffable<MetaData.Custom>
, NamedWriteable
, VersionedNamedWriteable
, Writeable
, ToXContent
, ToXContentFragment
public final class PersistentTasksCustomMetaData extends AbstractNamedDiffable<MetaData.Custom> implements MetaData.Custom
Modifier and Type | Class | Description |
---|---|---|
static class |
PersistentTasksCustomMetaData.Assignment |
|
static class |
PersistentTasksCustomMetaData.Builder |
|
static class |
PersistentTasksCustomMetaData.PersistentTask<P extends PersistentTaskParams> |
A record that represents a single running persistent task
|
ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params
Writeable.Reader<V>, Writeable.Writer<V>
Modifier and Type | Field | Description |
---|---|---|
static ConstructingObjectParser<PersistentTasksCustomMetaData.Assignment,java.lang.Void> |
ASSIGNMENT_PARSER |
|
static PersistentTasksCustomMetaData.Assignment |
INITIAL_ASSIGNMENT |
|
static java.lang.String |
TYPE |
EMPTY_PARAMS
Constructor | Description |
---|---|
PersistentTasksCustomMetaData(long lastAllocationId,
java.util.Map<java.lang.String,PersistentTasksCustomMetaData.PersistentTask<?>> tasks) |
|
PersistentTasksCustomMetaData(StreamInput in) |
diff, get, readDiffFrom
getRequiredFeature
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
isFragment
public static final java.lang.String TYPE
public static final ConstructingObjectParser<PersistentTasksCustomMetaData.Assignment,java.lang.Void> ASSIGNMENT_PARSER
public static final PersistentTasksCustomMetaData.Assignment INITIAL_ASSIGNMENT
public PersistentTasksCustomMetaData(long lastAllocationId, java.util.Map<java.lang.String,PersistentTasksCustomMetaData.PersistentTask<?>> tasks)
public PersistentTasksCustomMetaData(StreamInput in) throws java.io.IOException
java.io.IOException
public java.util.Collection<PersistentTasksCustomMetaData.PersistentTask<?>> tasks()
public java.util.Map<java.lang.String,PersistentTasksCustomMetaData.PersistentTask<?>> taskMap()
public PersistentTasksCustomMetaData.PersistentTask<?> getTask(java.lang.String id)
public java.util.Collection<PersistentTasksCustomMetaData.PersistentTask<?>> findTasks(java.lang.String taskName, java.util.function.Predicate<PersistentTasksCustomMetaData.PersistentTask<?>> predicate)
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public long getNumberOfTasksOnNode(java.lang.String nodeId, java.lang.String taskName)
public Version getMinimalSupportedVersion()
VersionedNamedWriteable
getMinimalSupportedVersion
in interface VersionedNamedWriteable
public java.util.EnumSet<MetaData.XContentContext> context()
context
in interface MetaData.Custom
public static PersistentTasksCustomMetaData fromXContent(XContentParser parser)
public static <Params extends PersistentTaskParams> PersistentTasksCustomMetaData.PersistentTask<Params> getTaskWithId(ClusterState clusterState, java.lang.String taskId)
public java.lang.String getWriteableName()
VersionedNamedWriteable
getWriteableName
in interface NamedWriteable
getWriteableName
in interface VersionedNamedWriteable
public void writeTo(StreamOutput out) throws java.io.IOException
Writeable
public static NamedDiff<MetaData.Custom> readDiffFrom(StreamInput in) throws java.io.IOException
java.io.IOException
public XContentBuilder toXContent(XContentBuilder builder, ToXContent.Params params) throws java.io.IOException
toXContent
in interface ToXContent
java.io.IOException
public static PersistentTasksCustomMetaData.Builder builder()
public static PersistentTasksCustomMetaData.Builder builder(PersistentTasksCustomMetaData tasks)