io.druid.indexing.kafka.supervisor

Class KafkaSupervisorReport.TaskReportData

java.lang.Object

io.druid.indexing.kafka.supervisor.KafkaSupervisorReport.TaskReportData

Enclosing class:

KafkaSupervisorReport

public class KafkaSupervisorReport.TaskReportData
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskReportData(String id, Map<Integer,Long> startingOffsets, Map<Integer,Long> currentOffsets, org.joda.time.DateTime startTime, Long remainingSeconds)

Method Summary

Modifier and Type	Method and Description
Map<Integer,Long>	getCurrentOffsets()
String	getId()
Long	getRemainingSeconds()
Map<Integer,Long>	getStartingOffsets()
org.joda.time.DateTime	getStartTime()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskReportData

public TaskReportData(String id,
                      Map<Integer,Long> startingOffsets,
                      Map<Integer,Long> currentOffsets,
                      org.joda.time.DateTime startTime,
                      Long remainingSeconds)

Method Detail

getId

public String getId()

getStartingOffsets

public Map<Integer,Long> getStartingOffsets()

getCurrentOffsets

public Map<Integer,Long> getCurrentOffsets()

getStartTime

public org.joda.time.DateTime getStartTime()

getRemainingSeconds

public Long getRemainingSeconds()

toString

public String toString()

Overrides:

toString in class Object