Module org.elasticsearch.xcore
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
-
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
Fields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY, EMPTY_PARAMS -
Constructor Summary
ConstructorsConstructorDescriptionNodeStats(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(StreamInput in) -
Method Summary
Modifier and TypeMethodDescriptionbooleanstatic AssignmentStats.NodeStatsforNotStartedState(DiscoveryNode node, RoutingState state, String reason) static AssignmentStats.NodeStatsforStartedState(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) intgetNode()longintlongintinthashCode()org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) voidwriteTo(StreamOutput out) Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods 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) -
NodeStats
- 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) -
forNotStartedState
public static AssignmentStats.NodeStats forNotStartedState(DiscoveryNode node, RoutingState state, String reason) -
getNode
-
getRoutingState
-
getInferenceCount
-
getAvgInferenceTime
-
getAvgInferenceTimeExcludingCacheHit
-
getLastAccess
-
getPendingCount
-
getErrorCount
public int getErrorCount() -
getCacheHitCount
-
getRejectedExecutionCount
public int getRejectedExecutionCount() -
getTimeoutCount
public int getTimeoutCount() -
getStartTime
-
getThreadsPerAllocation
-
getNumberOfAllocations
-
getPeakThroughput
public long getPeakThroughput() -
getThroughputLastPeriod
public long getThroughputLastPeriod() -
getAvgInferenceTimeLastPeriod
-
getCacheHitCountLastPeriod
-
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
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
equals
-
hashCode
public int hashCode()
-