Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ml.inference.assignment

Class AssignmentStats.NodeStats

java.lang.Object

org.elasticsearch.xpack.core.ml.inference.assignment.AssignmentStats.NodeStats

All Implemented Interfaces:

Writeable, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject

Enclosing class:

AssignmentStats

public static class AssignmentStats.NodeStats
extends Object
implements org.elasticsearch.xcontent.ToXContentObject, Writeable

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.Params

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

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

Field Summary

Fields inherited from interface org.elasticsearch.xcontent.ToXContent

EMPTY, EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
NodeStats(DiscoveryNode node, Long inferenceCount, Double avgInferenceTime, Double avgInferenceTimeExcludingCacheHit, Instant lastAccess, Integer pendingCount, int errorCount, Long cacheHitCount, int rejectedExecutionCount, int timeoutCount, RoutingStateAndReason routingState, Instant startTime, Integer threadsPerAllocation, Integer numberOfAllocations, long peakThroughput, long throughputLastPeriod, Double avgInferenceTimeLastPeriod, Long cacheHitCountLastPeriod)
NodeStats(DiscoveryNode node, Long inferenceCount, Double avgInferenceTime, Double avgInferenceTimeExcludingCacheHit, Instant lastAccess, Integer pendingCount, int errorCount, Long cacheHitCount, int rejectedExecutionCount, int timeoutCount, RoutingStateAndReason routingState, Instant startTime, Integer threadsPerAllocation, Integer numberOfAllocations, long peakThroughput, long throughputLastPeriod, Double avgInferenceTimeLastPeriod, Long cacheHitCountLastPeriod, Long avgInferenceProcessMemoryRssBytes)
NodeStats(StreamInput in)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static AssignmentStats.NodeStats	forNotStartedState(DiscoveryNode node, RoutingState state, String reason)
static AssignmentStats.NodeStats	forStartedState(DiscoveryNode node, long inferenceCount, Double avgInferenceTime, Double avgInferenceTimeExcludingCacheHit, int pendingCount, int errorCount, long cacheHitCount, int rejectedExecutionCount, int timeoutCount, Instant lastAccess, Instant startTime, Integer threadsPerAllocation, Integer numberOfAllocations, long peakThroughput, long throughputLastPeriod, Double avgInferenceTimeLastPeriod, long cacheHitCountLastPeriod)
static AssignmentStats.NodeStats	forStartedState(DiscoveryNode node, long inferenceCount, Double avgInferenceTime, Double avgInferenceTimeExcludingCacheHit, int pendingCount, int errorCount, long cacheHitCount, int rejectedExecutionCount, int timeoutCount, Instant lastAccess, Instant startTime, Integer threadsPerAllocation, Integer numberOfAllocations, long peakThroughput, long throughputLastPeriod, Double avgInferenceTimeLastPeriod, long cacheHitCountLastPeriod, Long avgInferenceProcessMemoryRssBytes)
Optional<Double>	getAvgInferenceTime()
Optional<Double>	getAvgInferenceTimeExcludingCacheHit()
Double	getAvgInferenceTimeLastPeriod()
Optional<Long>	getCacheHitCount()
Optional<Long>	getCacheHitCountLastPeriod()
int	getErrorCount()
Optional<Long>	getInferenceCount()
Instant	getLastAccess()
DiscoveryNode	getNode()
Integer	getNumberOfAllocations()
long	getPeakThroughput()
Integer	getPendingCount()
int	getRejectedExecutionCount()
RoutingStateAndReason	getRoutingState()
Instant	getStartTime()
Integer	getThreadsPerAllocation()
long	getThroughputLastPeriod()
int	getTimeoutCount()
int	hashCode()
org.elasticsearch.xcontent.XContentBuilder	toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.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

Constructor Details

NodeStats

public NodeStats(DiscoveryNode node,
 Long inferenceCount,
 Double avgInferenceTime,
 Double avgInferenceTimeExcludingCacheHit,
 @Nullable
 Instant lastAccess,
 Integer pendingCount,
 int errorCount,
 Long cacheHitCount,
 int rejectedExecutionCount,
 int timeoutCount,
 RoutingStateAndReason routingState,
 @Nullable
 Instant startTime,
 @Nullable
 Integer threadsPerAllocation,
 @Nullable
 Integer numberOfAllocations,
 long peakThroughput,
 long throughputLastPeriod,
 Double avgInferenceTimeLastPeriod,
 Long cacheHitCountLastPeriod,
 Long avgInferenceProcessMemoryRssBytes)

NodeStats

public NodeStats(DiscoveryNode node,
 Long inferenceCount,
 Double avgInferenceTime,
 Double avgInferenceTimeExcludingCacheHit,
 @Nullable
 Instant lastAccess,
 Integer pendingCount,
 int errorCount,
 Long cacheHitCount,
 int rejectedExecutionCount,
 int timeoutCount,
 RoutingStateAndReason routingState,
 @Nullable
 Instant startTime,
 @Nullable
 Integer threadsPerAllocation,
 @Nullable
 Integer numberOfAllocations,
 long peakThroughput,
 long throughputLastPeriod,
 Double avgInferenceTimeLastPeriod,
 Long cacheHitCountLastPeriod)

NodeStats

public NodeStats(StreamInput in)
          throws IOException

Throws:

IOException

Method Details

forStartedState

public static AssignmentStats.NodeStats forStartedState(DiscoveryNode node,
 long inferenceCount,
 Double avgInferenceTime,
 Double avgInferenceTimeExcludingCacheHit,
 int pendingCount,
 int errorCount,
 long cacheHitCount,
 int rejectedExecutionCount,
 int timeoutCount,
 Instant lastAccess,
 Instant startTime,
 Integer threadsPerAllocation,
 Integer numberOfAllocations,
 long peakThroughput,
 long throughputLastPeriod,
 Double avgInferenceTimeLastPeriod,
 long cacheHitCountLastPeriod)

forStartedState

public static AssignmentStats.NodeStats forStartedState(DiscoveryNode node,
 long inferenceCount,
 Double avgInferenceTime,
 Double avgInferenceTimeExcludingCacheHit,
 int pendingCount,
 int errorCount,
 long cacheHitCount,
 int rejectedExecutionCount,
 int timeoutCount,
 Instant lastAccess,
 Instant startTime,
 Integer threadsPerAllocation,
 Integer numberOfAllocations,
 long peakThroughput,
 long throughputLastPeriod,
 Double avgInferenceTimeLastPeriod,
 long cacheHitCountLastPeriod,
 Long avgInferenceProcessMemoryRssBytes)

forNotStartedState

public static AssignmentStats.NodeStats forNotStartedState(DiscoveryNode node,
 RoutingState state,
 String reason)

getNode

public DiscoveryNode getNode()

getRoutingState

public RoutingStateAndReason getRoutingState()

getInferenceCount

public Optional<Long> getInferenceCount()

getAvgInferenceTime

public Optional<Double> getAvgInferenceTime()

getAvgInferenceTimeExcludingCacheHit

public Optional<Double> getAvgInferenceTimeExcludingCacheHit()

getLastAccess

public Instant getLastAccess()

getPendingCount

public Integer getPendingCount()

getErrorCount

public int getErrorCount()

getCacheHitCount

public Optional<Long> getCacheHitCount()

getRejectedExecutionCount

public int getRejectedExecutionCount()

getTimeoutCount

public int getTimeoutCount()

getStartTime

public Instant getStartTime()

getThreadsPerAllocation

public Integer getThreadsPerAllocation()

getNumberOfAllocations

public Integer getNumberOfAllocations()

getPeakThroughput

public long getPeakThroughput()

getThroughputLastPeriod

public long getThroughputLastPeriod()

getAvgInferenceTimeLastPeriod

public Double getAvgInferenceTimeLastPeriod()

getCacheHitCountLastPeriod

public Optional<Long> getCacheHitCountLastPeriod()

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

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object