Package org.apache.pinot.tools.utils

Class PinotConfigUtils

java.lang.Object

org.apache.pinot.tools.utils.PinotConfigUtils

public class PinotConfigUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	TMP_DIR

Method Summary

Modifier and Type	Method	Description
static Map<String,Object>	generateBrokerConf(String clusterName, String zkAddress, String brokerHost, int brokerPort)
static Map<String,Object>	generateControllerConf(String configFileName)
static Map<String,Object>	generateControllerConf(String zkAddress, String clusterName, String controllerHost, String controllerPort, String dataDir, ControllerConf.ControllerMode controllerMode, boolean tenantIsolation)
static Map<String,Object>	generateMinionConf(String clusterName, String zkAddress, String minionHost, int minionPort)
static Map<String,Object>	generateServerConf(String clusterName, String zkAddress, String serverHost, int serverPort, int serverAdminPort, String serverDataDir, String serverSegmentDir)
static int	getAvailablePort()
static Map<String,Object>	readConfigFromFile(String configFileName)
static Map<String,Object>	readControllerConfigFromFile(String configFileName)
static boolean	validateControllerConfig(ControllerConf conf)

Methods inherited from class java.lang.Object

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

Field Detail

TMP_DIR

public static final String TMP_DIR

Method Detail

generateControllerConf

public static Map<String,Object> generateControllerConf(String zkAddress,
                                                              String clusterName,
                                                              String controllerHost,
                                                              String controllerPort,
                                                              String dataDir,
                                                              ControllerConf.ControllerMode controllerMode,
                                                              boolean tenantIsolation)
                                                       throws SocketException,
                                                              UnknownHostException

Throws:

SocketException

UnknownHostException

generateControllerConf

public static Map<String,Object> generateControllerConf(String configFileName)
                                                       throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

readControllerConfigFromFile

public static Map<String,Object> readControllerConfigFromFile(String configFileName)
                                                             throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

validateControllerConfig

public static boolean validateControllerConfig(ControllerConf conf)
                                        throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

readConfigFromFile

public static Map<String,Object> readConfigFromFile(String configFileName)
                                                   throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException

generateBrokerConf

public static Map<String,Object> generateBrokerConf(String clusterName,
                                                          String zkAddress,
                                                          String brokerHost,
                                                          int brokerPort)
                                                   throws SocketException,
                                                          UnknownHostException

Throws:

SocketException

UnknownHostException

generateServerConf

public static Map<String,Object> generateServerConf(String clusterName,
                                                          String zkAddress,
                                                          String serverHost,
                                                          int serverPort,
                                                          int serverAdminPort,
                                                          String serverDataDir,
                                                          String serverSegmentDir)
                                                   throws SocketException,
                                                          UnknownHostException

Throws:

SocketException

UnknownHostException

generateMinionConf

public static Map<String,Object> generateMinionConf(String clusterName,
                                                          String zkAddress,
                                                          String minionHost,
                                                          int minionPort)
                                                   throws SocketException,
                                                          UnknownHostException

Throws:

SocketException

UnknownHostException

getAvailablePort

public static int getAvailablePort()