Package org.apache.pinot.tools.service

Class PinotServiceManager

java.lang.Object

org.apache.pinot.tools.service.PinotServiceManager

public class PinotServiceManager
extends Object

PinotServiceManager is a user entry point to start Pinot instances in one process.

Constructor Summary

Constructors

Constructor	Description
PinotServiceManager(String zkAddress, String clusterName)
PinotServiceManager(String zkAddress, String clusterName, int port)
PinotServiceManager(String zkAddress, String clusterName, String hostname, int port)

Method Summary

Modifier and Type	Method	Description
String	getClusterName()
String	getInstanceId()
PinotInstanceStatus	getInstanceStatus(String instanceName)
List<String>	getRunningInstanceIds()
int	getServicePort()
String	getZkAddress()
boolean	isStarted()
static void	main(String[] args)
void	start()
String	startBroker(String brokerStarterClassName, org.apache.pinot.spi.env.PinotConfiguration brokerConf)
String	startController(String controllerStarterClassName, org.apache.pinot.spi.env.PinotConfiguration controllerConf)
String	startMinion(String minionStarterClassName, org.apache.pinot.spi.env.PinotConfiguration minionConf)
String	startRole(org.apache.pinot.spi.services.ServiceRole role, Map<String,Object> properties)
String	startServer(String serverStarterClassName, org.apache.pinot.spi.env.PinotConfiguration serverConf)
void	stop()
void	stopAll()
boolean	stopPinotInstance(org.apache.pinot.spi.services.ServiceStartable instance)
boolean	stopPinotInstanceById(String instanceName)

Methods inherited from class java.lang.Object

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

Constructor Detail

PinotServiceManager

public PinotServiceManager(String zkAddress,
                           String clusterName)

PinotServiceManager

public PinotServiceManager(String zkAddress,
                           String clusterName,
                           int port)

PinotServiceManager

public PinotServiceManager(String zkAddress,
                           String clusterName,
                           String hostname,
                           int port)

Method Detail

main

public static void main(String[] args)

startRole

public String startRole(org.apache.pinot.spi.services.ServiceRole role,
                        Map<String,Object> properties)
                 throws Exception

Throws:

Exception

startController

public String startController(String controllerStarterClassName,
                              org.apache.pinot.spi.env.PinotConfiguration controllerConf)
                       throws Exception

Throws:

Exception

startBroker

public String startBroker(String brokerStarterClassName,
                          org.apache.pinot.spi.env.PinotConfiguration brokerConf)
                   throws Exception

Throws:

Exception

startServer

public String startServer(String serverStarterClassName,
                          org.apache.pinot.spi.env.PinotConfiguration serverConf)
                   throws Exception

Throws:

Exception

startMinion

public String startMinion(String minionStarterClassName,
                          org.apache.pinot.spi.env.PinotConfiguration minionConf)
                   throws Exception

Throws:

Exception

stopPinotInstance

public boolean stopPinotInstance(org.apache.pinot.spi.services.ServiceStartable instance)

start

public void start()

stop

public void stop()

stopAll

public void stopAll()

isStarted

public boolean isStarted()

getInstanceId

public String getInstanceId()

getServicePort

public int getServicePort()

getInstanceStatus

public PinotInstanceStatus getInstanceStatus(String instanceName)

getRunningInstanceIds

public List<String> getRunningInstanceIds()

getZkAddress

public String getZkAddress()

getClusterName

public String getClusterName()

stopPinotInstanceById

public boolean stopPinotInstanceById(String instanceName)