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 and Description
static String	TMP_DIR

Constructor Summary

Constructors

Constructor and Description
PinotConfigUtils()

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	generateBrokerConf(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 minionHost, int minionPort)
static Map<String,Object>	generateServerConf(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

Constructor Detail

PinotConfigUtils

public PinotConfigUtils()

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(int brokerPort)

generateServerConf

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

Throws:

SocketException

UnknownHostException

generateMinionConf

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

Throws:

SocketException

UnknownHostException

getAvailablePort

public static int getAvailablePort()