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)

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()
TaskReportData.TaskType	getType()
void	setCurrentOffsets(Map<Integer,Long> currentOffsets)
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,
                      TaskReportData.TaskType type)

Method Detail

getId

public String getId()

getStartingOffsets

public Map<Integer,Long> getStartingOffsets()

getCurrentOffsets

public Map<Integer,Long> getCurrentOffsets()

setCurrentOffsets

public void setCurrentOffsets(Map<Integer,Long> currentOffsets)

getStartTime

public org.joda.time.DateTime getStartTime()

getRemainingSeconds

public Long getRemainingSeconds()

getType

public TaskReportData.TaskType getType()

toString

public String toString()

Overrides:

toString in class Object