Examples of org.kiji.schema.cassandra.CassandraFactory

  }


  /** {@inheritDoc} */
  @Override
  public CassandraKiji open(KijiURI uri) throws IOException {
    CassandraFactory cassandraFactory = CassandraFactory.Provider.get();
    CassandraAdminFactory adminFactory = cassandraFactory.getCassandraAdminFactory(uri);
    CassandraAdmin admin = adminFactory.create(uri);
    return new CassandraKiji(uri, admin);
  }

      KijiURI uri,
      HBaseFactory hbaseFactory,
      Map<String, String> properties,
      Configuration conf
    ) throws IOException {
    final CassandraFactory cassandraFactory = CassandraFactory.Provider.get();
    if (uri.getInstance() == null) {
      throw new KijiInvalidNameException(String.format(
          "Kiji URI '%s' does not specify a Kiji instance name", uri));
    }


    try {
      LOG.info(String.format("Installing Cassandra Kiji instance '%s'.", uri));


      CassandraAdminFactory cassandraAdminFactory = cassandraFactory.getCassandraAdminFactory(uri);
      LOG.debug("Creating CassandraAdmin for Kiji installation.");
      CassandraAdmin cassandraAdmin = cassandraAdminFactory.create(uri);


      // Install the system, meta, and schema tables.
      CassandraSystemTable.install(cassandraAdmin, uri, properties);

Related Classes of org.kiji.schema.cassandra.CassandraFactory

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.