Package org.apache.pinot.common.minion

Class MinionClient

java.lang.Object

org.apache.pinot.common.minion.MinionClient

@Private
@Evolving
public class MinionClient
extends Object

MinionClient is the client-side APIs for Pinot Controller tasks APIs. Minion feature is still in beta development mode, so those APIs may change frequently. Please use this client in caution.

Constructor Summary

Constructors

Constructor	Description
MinionClient(String controllerUrl)
MinionClient(String controllerHost, String controllerPort)
MinionClient(String scheme, String controllerHost, String controllerPort)

Method Summary

Modifier and Type	Method	Description
String	getControllerUrl()
Map<String,String>	getTasksStates(String taskType)
String	getTaskState(String taskName)
Map<String,String>	scheduleMinionTasks(String taskType, String tableNameWithType)

Methods inherited from class java.lang.Object

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

Constructor Detail

MinionClient

public MinionClient(String controllerHost,
                    String controllerPort)

MinionClient

public MinionClient(String scheme,
                    String controllerHost,
                    String controllerPort)

MinionClient

public MinionClient(String controllerUrl)

Method Detail

getControllerUrl

public String getControllerUrl()

scheduleMinionTasks

public Map<String,String> scheduleMinionTasks(@Nullable
                                                    String taskType,
                                                    @Nullable
                                                    String tableNameWithType)
                                             throws IOException

Throws:

IOException

getTasksStates

public Map<String,String> getTasksStates(String taskType)
                                        throws IOException

Throws:

IOException

getTaskState

public String getTaskState(String taskName)
                    throws IOException

Throws:

IOException