in vandelay-bigtable/src/main/java/com/spotify/api/vandelay/bigtable/imports/VandelayBigTableImporter.java [77:106]
public Status importFrom(final VandelayBigTableImportConfiguration importConfiguration) {
try {
final String instanceId = importConfiguration.getInstanceId();
final String projectId = importConfiguration.getProjectId();
logger.info("Attempting export for project id " + projectId + " instance id " + instanceId);
logger.info("Getting instance admin client");
final BigtableInstanceAdminClient instanceAdminClient =
vandelayBigTableClient.getInstanceAdminClient(importConfiguration);
if (importConfiguration.getCreateInstanceIfDoesntExist()) {
logger.info("Attempting to create " + instanceId + " if it doesn't exist");
createInstance(instanceId, importConfiguration, instanceAdminClient);
}
logger.info("Getting table admin client");
final BigtableTableAdminClient tableAdminClient =
vandelayBigTableClient.getTableAdminClient(importConfiguration);
if (importConfiguration.getCreateTableIfDoesntExist()) {
logger.info("Attempting to create tables for " + instanceId + " if they don't exist");
createTables(importConfiguration, tableAdminClient);
}
logger.info("Instance " + instanceId + " has been set up for importing");
return Status.success();
} catch (IOException ex) {
logger.error("IOException occurred creating instance and tables", ex);
return Status.fail(ex.getMessage(), ex);
}
}