io.druid.indexing.kafka.supervisor

Class KafkaSupervisorReport.KafkaSupervisorReportPayload

java.lang.Object

io.druid.indexing.kafka.supervisor.KafkaSupervisorReport.KafkaSupervisorReportPayload

Enclosing class:

KafkaSupervisorReport

public static class KafkaSupervisorReport.KafkaSupervisorReportPayload
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSupervisorReportPayload(String dataSource, String topic, Integer partitions, Integer replicas, Long durationSeconds, Map<Integer,Long> latestOffsets, Map<Integer,Long> minimumLag, Long aggregateLag, org.joda.time.DateTime offsetsLastUpdated)

Method Summary

Modifier and Type	Method and Description
List<TaskReportData>	getActiveTasks()
Long	getAggregateLag()
String	getDataSource()
Long	getDurationSeconds()
Map<Integer,Long>	getLatestOffsets()
Map<Integer,Long>	getMinimumLag()
org.joda.time.DateTime	getOffsetsLastUpdated()
Integer	getPartitions()
List<TaskReportData>	getPublishingTasks()
Integer	getReplicas()
String	getTopic()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSupervisorReportPayload

public KafkaSupervisorReportPayload(String dataSource,
                                    String topic,
                                    Integer partitions,
                                    Integer replicas,
                                    Long durationSeconds,
                                    @Nullable
                                    Map<Integer,Long> latestOffsets,
                                    @Nullable
                                    Map<Integer,Long> minimumLag,
                                    @Nullable
                                    Long aggregateLag,
                                    @Nullable
                                    org.joda.time.DateTime offsetsLastUpdated)

Method Detail

getDataSource

public String getDataSource()

getTopic

public String getTopic()

getPartitions

public Integer getPartitions()

getReplicas

public Integer getReplicas()

getDurationSeconds

public Long getDurationSeconds()

getActiveTasks

public List<TaskReportData> getActiveTasks()

getPublishingTasks

public List<TaskReportData> getPublishingTasks()

getLatestOffsets

public Map<Integer,Long> getLatestOffsets()

getMinimumLag

public Map<Integer,Long> getMinimumLag()

getAggregateLag

public Long getAggregateLag()

getOffsetsLastUpdated

public org.joda.time.DateTime getOffsetsLastUpdated()

toString

public String toString()

Overrides:

toString in class Object