Java 类org.apache.hadoop.hbase.avro.generated.HBase 实例源码

项目：LCIndex-HBase-0.94.16 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：IRIndex 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：RStore 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：HBase-Research 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：hbase-0.94.8-qod 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：hbase-0.94.8-qod 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}

项目：hindex 文件：AvroServer.java

protected static void doMain(final String[] args) throws Exception {
  if (args.length < 1) {
    printUsageAndExit();
  }
  int port = 9090;
  final String portArgKey = "--port=";
  for (String cmd: args) {
    if (cmd.startsWith(portArgKey)) {
      port = Integer.parseInt(cmd.substring(portArgKey.length()));
      continue;
    } else if (cmd.equals("--help") || cmd.equals("-h")) {
      printUsageAndExit();
    } else if (cmd.equals("start")) {
      continue;
    } else if (cmd.equals("stop")) {
      printUsageAndExit("To shutdown the Avro server run " +
        "bin/hbase-daemon.sh stop avro or send a kill signal to " +
        "the Avro server pid");
    }

    // Print out usage if we get to here.
    printUsageAndExit();
  }
  Log LOG = LogFactory.getLog("AvroServer");
  LOG.info("starting HBase Avro server on port " + Integer.toString(port));
  SpecificResponder r = new SpecificResponder(HBase.class, new HBaseImpl());
  HttpServer server = new HttpServer(r, port);
  server.start();
  server.join();
}