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 and 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 and 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(org.apache.pinot.spi.env.PinotConfiguration brokerConf)
String	startController(ControllerConf controllerConf)
String	startMinion(org.apache.pinot.spi.env.PinotConfiguration minionConf)
String	startRole(org.apache.pinot.spi.services.ServiceRole role, Map<String,Object> properties)
String	startServer(org.apache.pinot.spi.env.PinotConfiguration serverConf)
void	stop()
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(ControllerConf controllerConf)
                       throws Exception

Throws:

Exception

startBroker

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

Throws:

Exception

startServer

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

Throws:

Exception

startMinion

public String startMinion(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()

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)