import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private Connection connectToBigtable(List<ConfigIssue> issues) {
  Connection conn;
  try {
    conn = BigtableConfiguration.connect(conf.bigtableProjectID, conf.bigtableInstanceID);

  } catch (Exception ex) {
    LOG.error(Errors.BIGTABLE_01.getMessage(), conf.bigtableProjectID, ex.toString(), ex);
    issues.add(getContext().createConfigIssue(Groups.BIGTABLE.name(),
        CONFIG,
        Errors.BIGTABLE_01,
        conf.bigtableProjectID,
        ex.toString()
    ));
    return null;
  }
  return conn;
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
public static Connection createBigTableConnection(Config config) {
  final String projectId = config.getString(BIGTABLE_PROJECT_ID);
  final String instanceId = config.getString(BIGTABLE_INSTANCE_ID);

  LOG.info("Creating Bigtable connection for project:{}, instance:{}",
           projectId, instanceId);

  final Configuration bigtableConfiguration = new Configuration();
  bigtableConfiguration.set("google.bigtable.project.id", projectId);
  bigtableConfiguration.set("google.bigtable.instance.id", instanceId);
  bigtableConfiguration.setBoolean("google.bigtable.rpc.use.timeouts", true);

  return BigtableConfiguration.connect(bigtableConfiguration);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
/**
 * Really basic test to make sure that Cloud Bigtable connections can be made.
 */
@Test
public void testConnect() {
  Configuration conf = BigtableConfiguration.configure("someProjectId", "someInstanceId");
  @SuppressWarnings("unused")
  HBaseClient client = new HBaseClient(conf, null);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
@BeforeClass
public static void createTable() throws IOException {
  String projectId = System.getProperty( "google.bigtable.project.id");
  String instanceId = System.getProperty( "google.bigtable.instance.id");
  client = new HBaseClient(BigtableConfiguration.configure(projectId, instanceId),
      Executors.newCachedThreadPool());
  Admin admin = client.getBigtableConnection().getAdmin();
  try {
    admin.createTable(
      new HTableDescriptor(TABLE_NAME)
        .addFamily(new HColumnDescriptor(FAMILY)));
  } finally {
    admin.close();
  }
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
/** Connect will establish the connection to Cloud Bigtable. */
public static void connect() throws IOException {

  if (PROJECT_ID == null || INSTANCE_ID == null) {
    if (sc != null) {
      sc.log("environment variables BIGTABLE_PROJECT, and BIGTABLE_INSTANCE need to be defined.");
    }
    return;
  }

  connection = BigtableConfiguration.connect(PROJECT_ID, INSTANCE_ID);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private Table getTable() {
  Connection conn = BigtableConfiguration.connect(projectID, instanceID);
  Table tab;
  try {
    tab = conn.getTable(TableName.valueOf(tableName));

  } catch (Exception ex) {
    tab = null;
  }
  return tab;
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private static void dropTable() {
  Connection conn = BigtableConfiguration.connect(projectID, instanceID);
  try {
    Admin admin = conn.getAdmin();
    admin.disableTable(TableName.valueOf(tableName));
    admin.deleteTable(TableName.valueOf(tableName));
  } catch (Exception ex) {
    LOG.info("dropTable(): exception {} ", ex.toString());
  }
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
/**
* Connect will establish the connection to Cloud Bigtable.
**/
 public static void connect() throws IOException {

   if (PROJECT_ID == null || INSTANCE_ID == null ) {
     if (sc != null) {
       sc.log("environment variables BIGTABLE_PROJECT, and BIGTABLE_INSTANCE need to be defined.");
     }
     return;
   }

   connection = BigtableConfiguration.connect(PROJECT_ID, INSTANCE_ID);
 }
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
public static void writeTestData(String projectId, String instanceId,
    TableName tableName, long rowCount, int valueSize) throws IOException {
  System.out.println("Writing to table: " + tableName);
  try (Connection conn = BigtableConfiguration.connect(projectId, instanceId)) {
    BigtableUtilities.createTable(tableName, conn);
    runMutationTests(conn, tableName, rowCount, valueSize);
  }
  System.out.println("Closed the connection");
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
/**
 * Connect will establish the connection to Cloud Bigtable.
 **/
public static void connect() throws IOException {
  if (PROJECT_ID == null || INSTANCE_ID == null) {
    sc.log(
        "environment variables "
            + "BIGTABLE_PROJECT, and INSTANCE_ID "
            + "need to be defined.");
    return;
  }

  connection = BigtableConfiguration.connect(PROJECT_ID, INSTANCE_ID);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private static Connection getConnection(
		final String projectId,
		final String instanceId ) {

	final Configuration config = BigtableConfiguration.configure(
			projectId,
			instanceId);

	// TODO: Bigtable configgy things? What about connection pooling?
	config.setBoolean(
			"hbase.online.schema.update.enable",
			true);

	return BigtableConfiguration.connect(config);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
public HBaseClient(final Configuration configuration, final ExecutorService executor) {
  this.executor = executor;
  hbase_config = configuration;
  LOG.info("BigTable API: Connecting with config: {}", hbase_config);
  hbase_connection = BigtableConfiguration.connect(hbase_config);
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private void createTable(String tab) throws Exception {
  Connection conn = BigtableConfiguration.connect(projectID, instanceID);
  Admin admin = conn.getAdmin();
  admin.createTable(new HTableDescriptor(TableName.valueOf(tab)));
}
 

import com.google.cloud.bigtable.hbase.BigtableConfiguration; //导入依赖的package包/类
private void createColumnFamily(String tab, String cf) throws Exception {
  Connection conn = BigtableConfiguration.connect(projectID, instanceID);
  Admin admin = conn.getAdmin();
  admin.addColumn(TableName.valueOf(tab), new HColumnDescriptor(cf));
}