co.cask.cdap.data.stream.service.heartbeat

Class StreamWriterHeartbeat

java.lang.Object

co.cask.cdap.data.stream.service.heartbeat.StreamWriterHeartbeat

public class StreamWriterHeartbeat
extends Object

Heartbeat sent by a Stream writer containing the total size of its files, in bytes. The heartbeats concerning one stream are aggregated by the DistributedStreamService elected leader of the stream.

Constructor Summary

Constructors

Constructor and Description
StreamWriterHeartbeat(long timestamp, int instanceId, Map<Id.Stream,Long> streamsSizes)

Method Summary

Methods

Modifier and Type	Method and Description
int	getInstanceId()
Map<Id.Stream,Long>	getStreamsSizes()
long	getTimestamp()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamWriterHeartbeat

public StreamWriterHeartbeat(long timestamp,
                     int instanceId,
                     Map<Id.Stream,Long> streamsSizes)

Method Detail

getTimestamp

public long getTimestamp()

getInstanceId

public int getInstanceId()

getStreamsSizes

public Map<Id.Stream,Long> getStreamsSizes()

toString

public String toString()

Overrides:

toString in class Object