io.druid.indexing.kafka.supervisor

Class KafkaSupervisorReport.KafkaSupervisorReportPayload

java.lang.Object

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

Enclosing class:

KafkaSupervisorReport

public class KafkaSupervisorReport.KafkaSupervisorReportPayload
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSupervisorReportPayload(String dataSource, String topic, Integer partitions, Integer replicas, Long durationSeconds)

Method Summary

Modifier and Type	Method and Description
List<TaskReportData>	getActiveTasks()
String	getDataSource()
Long	getDurationSeconds()
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)

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()

toString

public String toString()

Overrides:

toString in class Object