org.apache.streams.pojo.json

Class StreamsTaskCounterBroadcast

java.lang.Object

org.apache.streams.pojo.json.Broadcast

org.apache.streams.pojo.json.StreamsTaskCounterBroadcast

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class StreamsTaskCounterBroadcast
extends Broadcast
implements Serializable

object

Snapshot of a Stream Task Counter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamsTaskCounterBroadcast()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
Object	getAvgTime() Average amount of time an item spent in this Task
Object	getErrorRate() Rate of failed items
Long	getMaxTime() Longest amount of time an item spent in this Task
String	getName() Name of the MBean
Long	getNumEmitted() Number of items that have been emitted
Long	getNumReceived() Number of items this Task has received
Long	getNumUnhandledErrors() Number of unhandled errors
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setAvgTime(Object avgTime) Average amount of time an item spent in this Task
void	setErrorRate(Object errorRate) Rate of failed items
void	setMaxTime(Long maxTime) Longest amount of time an item spent in this Task
void	setName(String name) Name of the MBean
void	setNumEmitted(Long numEmitted) Number of items that have been emitted
void	setNumReceived(Long numReceived) Number of items this Task has received
void	setNumUnhandledErrors(Long numUnhandledErrors) Number of unhandled errors
String	toString()
StreamsTaskCounterBroadcast	withAdditionalProperty(String name, Object value)
StreamsTaskCounterBroadcast	withAvgTime(Object avgTime)
StreamsTaskCounterBroadcast	withErrorRate(Object errorRate)
StreamsTaskCounterBroadcast	withMaxTime(Long maxTime)
StreamsTaskCounterBroadcast	withName(String name)
StreamsTaskCounterBroadcast	withNumEmitted(Long numEmitted)
StreamsTaskCounterBroadcast	withNumReceived(Long numReceived)
StreamsTaskCounterBroadcast	withNumUnhandledErrors(Long numUnhandledErrors)

Methods inherited from class org.apache.streams.pojo.json.Broadcast

getStartedAt, getStreamIdentifier, setStartedAt, setStreamIdentifier, withStartedAt, withStreamIdentifier

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamsTaskCounterBroadcast

public StreamsTaskCounterBroadcast()

Method Detail

getErrorRate

@BeanProperty(value="errorRate")
public Object getErrorRate()

Rate of failed items

Returns:

The errorRate

setErrorRate

@BeanProperty(value="errorRate")
public void setErrorRate(Object errorRate)

Rate of failed items

Parameters:

errorRate - The errorRate

withErrorRate

public StreamsTaskCounterBroadcast withErrorRate(Object errorRate)

getNumEmitted

@BeanProperty(value="numEmitted")
public Long getNumEmitted()

Number of items that have been emitted

Returns:

The numEmitted

setNumEmitted

@BeanProperty(value="numEmitted")
public void setNumEmitted(Long numEmitted)

Number of items that have been emitted

Parameters:

numEmitted - The numEmitted

withNumEmitted

public StreamsTaskCounterBroadcast withNumEmitted(Long numEmitted)

getNumReceived

@BeanProperty(value="numReceived")
public Long getNumReceived()

Number of items this Task has received

Returns:

The numReceived

setNumReceived

@BeanProperty(value="numReceived")
public void setNumReceived(Long numReceived)

Number of items this Task has received

Parameters:

numReceived - The numReceived

withNumReceived

public StreamsTaskCounterBroadcast withNumReceived(Long numReceived)

getNumUnhandledErrors

@BeanProperty(value="numUnhandledErrors")
public Long getNumUnhandledErrors()

Number of unhandled errors

Returns:

The numUnhandledErrors

setNumUnhandledErrors

@BeanProperty(value="numUnhandledErrors")
public void setNumUnhandledErrors(Long numUnhandledErrors)

Number of unhandled errors

Parameters:

numUnhandledErrors - The numUnhandledErrors

withNumUnhandledErrors

public StreamsTaskCounterBroadcast withNumUnhandledErrors(Long numUnhandledErrors)

getAvgTime

@BeanProperty(value="avgTime")
public Object getAvgTime()

Average amount of time an item spent in this Task

Returns:

The avgTime

setAvgTime

@BeanProperty(value="avgTime")
public void setAvgTime(Object avgTime)

Average amount of time an item spent in this Task

Parameters:

avgTime - The avgTime

withAvgTime

public StreamsTaskCounterBroadcast withAvgTime(Object avgTime)

getMaxTime

@BeanProperty(value="maxTime")
public Long getMaxTime()

Longest amount of time an item spent in this Task

Returns:

The maxTime

setMaxTime

@BeanProperty(value="maxTime")
public void setMaxTime(Long maxTime)

Longest amount of time an item spent in this Task

Parameters:

maxTime - The maxTime

withMaxTime

public StreamsTaskCounterBroadcast withMaxTime(Long maxTime)

getName

@BeanProperty(value="name")
public String getName()

Name of the MBean

Overrides:

getName in class Broadcast

Returns:

The name

setName

@BeanProperty(value="name")
public void setName(String name)

Name of the MBean

Overrides:

setName in class Broadcast

Parameters:

name - The name

withName

public StreamsTaskCounterBroadcast withName(String name)

Overrides:

withName in class Broadcast

toString

public String toString()

Overrides:

toString in class Broadcast

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class Broadcast

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

Overrides:

setAdditionalProperty in class Broadcast

withAdditionalProperty

public StreamsTaskCounterBroadcast withAdditionalProperty(String name,
                                                          Object value)

Overrides:

withAdditionalProperty in class Broadcast

hashCode

public int hashCode()

Overrides:

hashCode in class Broadcast

equals

public boolean equals(Object other)

Overrides:

equals in class Broadcast