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

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_RETRY_WAIT_SECONDS

Constructor Summary

Constructors

Constructor and Description
KafkaIndexTaskClient(com.metamx.http.client.HttpClient httpClient, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, TaskInfoProvider taskInfoProvider, String dataSource, int numThreads, org.joda.time.Duration httpTimeout, long numRetries)

Method Summary

Modifier and Type	Method and Description
void	close()
Map<Integer,Long>	getCurrentOffsets(String id, boolean retry)
com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>>	getCurrentOffsetsAsync(String id, boolean retry)
Map<Integer,Long>	getEndOffsets(String id)
com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>>	getEndOffsetsAsync(String id)
org.joda.time.DateTime	getStartTime(String id)
com.google.common.util.concurrent.ListenableFuture<org.joda.time.DateTime>	getStartTimeAsync(String id)
KafkaIndexTask.Status	getStatus(String id)
com.google.common.util.concurrent.ListenableFuture<KafkaIndexTask.Status>	getStatusAsync(String id)
Map<Integer,Long>	pause(String id)
Map<Integer,Long>	pause(String id, long timeout)
com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>>	pauseAsync(String id)
com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>>	pauseAsync(String id, long timeout)
boolean	resume(String id)
com.google.common.util.concurrent.ListenableFuture<Boolean>	resumeAsync(String id)
boolean	setEndOffsets(String id, Map<Integer,Long> endOffsets)
boolean	setEndOffsets(String id, Map<Integer,Long> endOffsets, boolean resume)
com.google.common.util.concurrent.ListenableFuture<Boolean>	setEndOffsetsAsync(String id, Map<Integer,Long> endOffsets)
com.google.common.util.concurrent.ListenableFuture<Boolean>	setEndOffsetsAsync(String id, Map<Integer,Long> endOffsets, boolean resume)
boolean	stop(String id, boolean publish)
com.google.common.util.concurrent.ListenableFuture<Boolean>	stopAsync(String id, boolean publish)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_RETRY_WAIT_SECONDS

public static final int MAX_RETRY_WAIT_SECONDS

See Also:

Constant Field Values

Constructor Detail

KafkaIndexTaskClient

public KafkaIndexTaskClient(com.metamx.http.client.HttpClient httpClient,
                            com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                            TaskInfoProvider taskInfoProvider,
                            String dataSource,
                            int numThreads,
                            org.joda.time.Duration httpTimeout,
                            long numRetries)

Method Detail

close

public void close()

stop

public boolean stop(String id,
                    boolean publish)

resume

public boolean 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)

getCurrentOffsets

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

getEndOffsets

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

setEndOffsets

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

setEndOffsets

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

stopAsync

public com.google.common.util.concurrent.ListenableFuture<Boolean> stopAsync(String id,
                                                                             boolean publish)

resumeAsync

public com.google.common.util.concurrent.ListenableFuture<Boolean> resumeAsync(String id)

pauseAsync

public com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>> pauseAsync(String id)

pauseAsync

public com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>> pauseAsync(String id,
                                                                                        long timeout)

getStatusAsync

public com.google.common.util.concurrent.ListenableFuture<KafkaIndexTask.Status> getStatusAsync(String id)

getStartTimeAsync

public com.google.common.util.concurrent.ListenableFuture<org.joda.time.DateTime> getStartTimeAsync(String id)

getCurrentOffsetsAsync

public com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>> getCurrentOffsetsAsync(String id,
                                                                                                    boolean retry)

getEndOffsetsAsync

public com.google.common.util.concurrent.ListenableFuture<Map<Integer,Long>> getEndOffsetsAsync(String id)

setEndOffsetsAsync

public com.google.common.util.concurrent.ListenableFuture<Boolean> setEndOffsetsAsync(String id,
                                                                                      Map<Integer,Long> endOffsets)

setEndOffsetsAsync

public com.google.common.util.concurrent.ListenableFuture<Boolean> setEndOffsetsAsync(String id,
                                                                                      Map<Integer,Long> endOffsets,
                                                                                      boolean resume)