@@ -125,33 +125,31 @@ Here is a code snippet showing a simple usage example from within Compute/App En
125125must [supply credentials](# authentication) and a project ID if running this snippet elsewhere.
126126
127127` ` ` java
128+ import com.google.gcloud.bigquery.BaseTableInfo;
128129import com.google.gcloud.bigquery.BigQuery;
129130import com.google.gcloud.bigquery.BigQueryOptions;
130131import com.google.gcloud.bigquery.Field;
131- import com.google.gcloud.bigquery.Job;
132132import com.google.gcloud.bigquery.JobStatus;
133133import com.google.gcloud.bigquery.JobInfo;
134- import com.google.gcloud.bigquery.LoadJobConfiguration;
135134import com.google.gcloud.bigquery.Schema;
136- import com.google.gcloud.bigquery.StandardTableDefinition;
137- import com.google.gcloud.bigquery.Table;
138135import com.google.gcloud.bigquery.TableId;
139136import com.google.gcloud.bigquery.TableInfo;
140137
141138BigQuery bigquery = BigQueryOptions.defaultInstance().service ();
142139TableId tableId = TableId.of(" dataset" , " table" );
143- Table table = bigquery.getTable(tableId);
144- if (table == null) {
140+ BaseTableInfo info = bigquery.getTable(tableId);
141+ if (info == null) {
145142 System.out.println(" Creating table " + tableId);
146143 Field integerField = Field.of(" fieldName" , Field.Type.integer ());
147- Schema schema = Schema.of(integerField);
148- bigquery.create(TableInfo.of(tableId, StandardTableDefinition.of(schema)));
144+ bigquery.create(TableInfo.of(tableId, Schema.of(integerField)));
149145} else {
150146 System.out.println(" Loading data into table " + tableId);
151147 LoadJobConfiguration configuration = LoadJobConfiguration.of(tableId, " gs://bucket/path" );
152- Job loadJob = bigquery.create(JobInfo.of(configuration));
153- while (! loadJob.isDone()) {
148+ JobInfo loadJob = JobInfo.of(configuration);
149+ loadJob = bigquery.create(loadJob);
150+ while (loadJob.status().state() ! = JobStatus.State.DONE) {
154151 Thread.sleep(1000L);
152+ loadJob = bigquery.getJob(loadJob.jobId ());
155153 }
156154 if (loadJob.status().error() ! = null) {
157155 System.out.println(" Job completed with errors" );
@@ -250,6 +248,7 @@ Here is a code snippet showing a simple usage example from within Compute/App En
250248import static java.nio.charset.StandardCharsets.UTF_8;
251249
252250import com.google.gcloud.storage.Blob;
251+ import com.google.gcloud.storage.BlobInfo;
253252import com.google.gcloud.storage.BlobId;
254253import com.google.gcloud.storage.Storage;
255254import com.google.gcloud.storage.StorageOptions;
@@ -259,7 +258,7 @@ import java.nio.channels.WritableByteChannel;
259258
260259Storage storage = StorageOptions.defaultInstance().service();
261260BlobId blobId = BlobId.of("bucket", "blob_name");
262- Blob blob = Blob .get(storage, blobId);
261+ Blob blob = storage .get(storage, blobId);
263262if (blob == null) {
264263 BlobInfo blobInfo = BlobInfo.builder(blobId).contentType("text/plain").build();
265264 storage.create(blobInfo, "Hello, Cloud Storage!".getBytes(UTF_8));
0 commit comments