io.druid.indexing.common.actions

Class RemoteTaskActionClient

java.lang.Object

io.druid.indexing.common.actions.RemoteTaskActionClient

All Implemented Interfaces:

TaskActionClient

public class RemoteTaskActionClient
extends Object
implements TaskActionClient

Constructor Summary

Constructors

Constructor and Description
RemoteTaskActionClient(Task task, DruidLeaderClient druidLeaderClient, RetryPolicyFactory retryPolicyFactory, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
<RetType> RetType	submit(TaskAction<RetType> taskAction)

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteTaskActionClient

public RemoteTaskActionClient(Task task,
                              DruidLeaderClient druidLeaderClient,
                              RetryPolicyFactory retryPolicyFactory,
                              com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

submit

public <RetType> RetType submit(TaskAction<RetType> taskAction)
                         throws IOException

Specified by:

submit in interface TaskActionClient

Throws:

IOException