io.druid.indexing.kafka.supervisor

Class TaskReportData

java.lang.Object

io.druid.indexing.kafka.supervisor.TaskReportData

public class TaskReportData
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskReportData.TaskType

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Map<Integer,Long>	getCurrentOffsets()
String	getId()
Map<Integer,Long>	getLag()
Long	getRemainingSeconds()
Map<Integer,Long>	getStartingOffsets()
org.joda.time.DateTime	getStartTime()
TaskReportData.TaskType	getType()
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,
                      @Nullable
                      Map<Integer,Long> startingOffsets,
                      @Nullable
                      Map<Integer,Long> currentOffsets,
                      org.joda.time.DateTime startTime,
                      Long remainingSeconds,
                      TaskReportData.TaskType type,
                      @Nullable
                      Map<Integer,Long> lag)

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

getType

public TaskReportData.TaskType getType()

getLag

public Map<Integer,Long> getLag()

toString

public String toString()

Overrides:

toString in class Object