Examples of parseProperties()


Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

  public static ZookeeperTuple runShutdownableZooKeeper(Configuration conf)
      throws Exception {
    Properties zkProperties = makeZKProps(conf);
    writeMyID(zkProperties);
    QuorumPeerConfig zkConfig = new QuorumPeerConfig();
    zkConfig.parseProperties(zkProperties);
    ShutdownableZooKeeperServerMain zk = new ShutdownableZooKeeperServerMain();
    ServerConfig serverConfig = new ServerConfig();
    serverConfig.readFrom(zkConfig);
    return new ZookeeperTuple(zk, serverConfig);
  }
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

    private ZooKeeperServerMain zooKeeperServer;

    public ZooKeeperLocal(Properties zkProperties) throws IOException{
        QuorumPeerConfig quorumConfiguration = new QuorumPeerConfig();
        try {
            quorumConfiguration.parseProperties(zkProperties);
        } catch(Exception e) {
            throw new RuntimeException(e);
        }

        zooKeeperServer = new ZooKeeperServerMain();
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

    HBaseConfiguration conf = new HBaseConfiguration();
    try {
      Properties zkProperties = makeZKProps(conf);
      writeMyID(zkProperties);
      QuorumPeerConfig zkConfig = new QuorumPeerConfig();
      zkConfig.parseProperties(zkProperties);
      runZKServer(zkConfig);
    } catch (Exception e) {
      e.printStackTrace();
      System.exit(-1);
    }
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

            zkProperties.setProperty("initLimit", "10");
            zkProperties.setProperty("syncLimit", "5");
            zkProperties.setProperty("snapCount", "50000");

            QuorumPeerConfig qpConfig = new QuorumPeerConfig();
            qpConfig.parseProperties(zkProperties);

            // create and run the zookeeper instance
            final InternalZooKeeper zookeeper = new InternalZooKeeper();
            final ServerConfig zkConfig = new ServerConfig();
            zkConfig.readFrom(qpConfig);
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

    Configuration conf = new HamaConfiguration(baseConf);
    try {
      Properties zkProperties = makeZKProps(conf);
      writeMyID(zkProperties);
      QuorumPeerConfig zkConfig = new QuorumPeerConfig();
      zkConfig.parseProperties(zkProperties);
      runZKServer(zkConfig);
    } catch (Exception e) {
      e.printStackTrace();
      System.exit(-1);
    }
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

    Configuration conf = HBaseConfiguration.create();
    try {
      Properties zkProperties = ZKConfig.makeZKProps(conf);
      writeMyID(zkProperties);
      QuorumPeerConfig zkConfig = new QuorumPeerConfig();
      zkConfig.parseProperties(zkProperties);
      runZKServer(zkConfig);
    } catch (Exception e) {
      e.printStackTrace();
      System.exit(-1);
    }
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

      private InetSocketAddress randomPort(InetSocketAddress clientPortAddress) {
        return new InetSocketAddress(clientPortAddress.getAddress(), 0);
      }
    };
    try {
      config.parseProperties(properties);
    } catch (IOException e) {
      LOG.error(e);
      throw new RuntimeException(e);
    } catch (ConfigException e) {
      LOG.error(e);
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

   */
  public static void runZooKeeper(Configuration conf) throws Exception {
    Properties zkProperties = makeZKProps(conf);
    writeMyID(zkProperties);
    QuorumPeerConfig zkConfig = new QuorumPeerConfig();
    zkConfig.parseProperties(zkProperties);
    runZKServer(zkConfig);
  }

  /**
   * Runs a shutdownable Zookeeper main server. This does not work with multiple
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

  public static ZookeeperTuple runShutdownableZooKeeper(Configuration conf)
      throws Exception {
    Properties zkProperties = makeZKProps(conf);
    writeMyID(zkProperties);
    QuorumPeerConfig zkConfig = new QuorumPeerConfig();
    zkConfig.parseProperties(zkProperties);
    ShutdownableZooKeeperServerMain zk = new ShutdownableZooKeeperServerMain();
    ServerConfig serverConfig = new ServerConfig();
    serverConfig.readFrom(zkConfig);
    return new ZookeeperTuple(zk, serverConfig);
  }
View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties()

      // Configure a local zookeeper instance
      Properties zkProperties = configLocalZooKeeper(zkDir);

      QuorumPeerConfig qpConfig = new QuorumPeerConfig();
      qpConfig.parseProperties(zkProperties);

      // Create and run the zookeeper instance
      final InternalZooKeeper zookeeper = new InternalZooKeeper();
      final ServerConfig zkConfig = new ServerConfig();
      zkConfig.readFrom(qpConfig);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.