io.druid.indexing.kafka

Class KafkaIndexTaskClient

java.lang.Object

io.druid.indexing.kafka.KafkaIndexTaskClient

public class KafkaIndexTaskClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	KafkaIndexTaskClient.NoTaskLocationException
class	KafkaIndexTaskClient.TaskNotRunnableException

Constructor Summary

Constructors

Constructor and Description
KafkaIndexTaskClient(com.metamx.http.client.HttpClient httpClient, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, TaskInfoProvider taskInfoProvider)

Method Summary

Modifier and Type	Method and Description
Map<Integer,Long>	getCurrentOffsets(String id, boolean retry)
Map<Integer,Long>	getEndOffsets(String id)
org.joda.time.DateTime	getStartTime(String id, boolean retry)
KafkaIndexTask.Status	getStatus(String id)
Map<Integer,Long>	pause(String id)
Map<Integer,Long>	pause(String id, long timeout)
void	resume(String id)
void	setEndOffsets(String id, Map<Integer,Long> endOffsets)
void	setEndOffsets(String id, Map<Integer,Long> endOffsets, boolean resume)
void	stop(String id, boolean publish)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaIndexTaskClient

public KafkaIndexTaskClient(com.metamx.http.client.HttpClient httpClient,
                            com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                            TaskInfoProvider taskInfoProvider)

Method Detail

stop

public void stop(String id,
                 boolean publish)

resume

public void resume(String id)

pause

public Map<Integer,Long> pause(String id)

pause

public Map<Integer,Long> pause(String id,
                               long timeout)

getStatus

public KafkaIndexTask.Status getStatus(String id)

getStartTime

public org.joda.time.DateTime getStartTime(String id,
                                           boolean retry)

getCurrentOffsets

public Map<Integer,Long> getCurrentOffsets(String id,
                                           boolean retry)

getEndOffsets

public Map<Integer,Long> getEndOffsets(String id)

setEndOffsets

public void setEndOffsets(String id,
                          Map<Integer,Long> endOffsets)

setEndOffsets

public void setEndOffsets(String id,
                          Map<Integer,Long> endOffsets,
                          boolean resume)