Skip to content

Commit ea99ac4

Browse files
aozarovaozarov
committed
---
yaml --- r: 1697 b: refs/heads/master c: 04ab56e h: refs/heads/master i: 1695: 62f0149
1 parent 381bd2c commit ea99ac4

35 files changed

Lines changed: 300 additions & 215 deletions

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
refs/heads/master: 662f57f18845f8d6e5aadd52dddf2b118422c6e5
2+
refs/heads/master: 04ab56e6f662366cf5ba220b6adabbf9caf8246f
33
refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
44
refs/heads/gh-pages: d1b373c30c176edc08692348167bec3a244bb823
55
refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3

‎trunk/README.md‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@ Java idiomatic client for [Google Cloud Platform][cloud-platform] services.
66
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
77
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
88
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java.svg)
9+
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10+
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
911

1012
- [Homepage] (https://googlecloudplatform.github.io/gcloud-java/)
1113
- [API Documentation] (http://googlecloudplatform.github.io/gcloud-java/apidocs)

‎trunk/codacy-conf.json‎

Lines changed: 1 addition & 0 deletions
Large diffs are not rendered by default.

‎trunk/gcloud-java-bigquery/README.md‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@ Java idiomatic client for [Google Cloud BigQuery] (https://cloud.google.com/bigq
66
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
77
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
88
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)
9+
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10+
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
911

1012
- [Homepage] (https://googlecloudplatform.github.io/gcloud-java/)
1113
- [API Documentation] (http://googlecloudplatform.github.io/gcloud-java/apidocs/index.html?com/google/gcloud/bigquery/package-summary.html)

‎trunk/gcloud-java-bigquery/pom.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
<dependency>
3131
<groupId>com.google.apis</groupId>
3232
<artifactId>google-api-services-bigquery</artifactId>
33-
<version>v2-rev254-1.21.0</version>
33+
<version>v2-rev261-1.21.0</version>
3434
<scope>compile</scope>
3535
<exclusions>
3636
<exclusion>
@@ -48,7 +48,7 @@
4848
<dependency>
4949
<groupId>org.easymock</groupId>
5050
<artifactId>easymock</artifactId>
51-
<version>3.3</version>
51+
<version>3.4</version>
5252
<scope>test</scope>
5353
</dependency>
5454
</dependencies>

‎trunk/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/InsertAllRequest.java‎

Lines changed: 29 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -52,15 +52,15 @@ public class InsertAllRequest implements Serializable {
5252
* id used by BigQuery to detect duplicate insertion requests on a best-effort basis.
5353
*
5454
* <p>Example usage of creating a row to insert:
55-
* <pre> {@code
56-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
57-
* Map<String, Object> recordContent = new HashMap<String, Object>();
58-
* recordContent.put("subfieldName1", "value");
59-
* recordContent.put("subfieldName2", repeatedFieldValue);
60-
* Map<String, Object> rowContent = new HashMap<String, Object>();
61-
* rowContent.put("fieldName1", true);
62-
* rowContent.put("fieldName2", recordContent);
63-
* RowToInsert row = new RowToInsert("rowId", rowContent);
55+
* <pre> {@code
56+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
57+
* Map<String, Object> recordContent = new HashMap<String, Object>();
58+
* recordContent.put("subfieldName1", "value");
59+
* recordContent.put("subfieldName2", repeatedFieldValue);
60+
* Map<String, Object> rowContent = new HashMap<String, Object>();
61+
* rowContent.put("fieldName1", true);
62+
* rowContent.put("fieldName2", recordContent);
63+
* RowToInsert row = new RowToInsert("rowId", rowContent);
6464
* }</pre>
6565
*
6666
* @see <a href ="https://cloud.google.com/bigquery/streaming-data-into-bigquery#dataconsistency">
@@ -177,16 +177,16 @@ public Builder addRow(RowToInsert rowToInsert) {
177177
* Adds a row to be inserted with associated id.
178178
*
179179
* <p>Example usage of adding a row with associated id:
180-
* <pre> {@code
181-
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
182-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
183-
* Map<String, Object> recordContent = new HashMap<String, Object>();
184-
* recordContent.put("subfieldName1", "value");
185-
* recordContent.put("subfieldName2", repeatedFieldValue);
186-
* Map<String, Object> rowContent = new HashMap<String, Object>();
187-
* rowContent.put("fieldName1", true);
188-
* rowContent.put("fieldName2", recordContent);
189-
* builder.addRow("rowId", rowContent);
180+
* <pre> {@code
181+
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
182+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
183+
* Map<String, Object> recordContent = new HashMap<String, Object>();
184+
* recordContent.put("subfieldName1", "value");
185+
* recordContent.put("subfieldName2", repeatedFieldValue);
186+
* Map<String, Object> rowContent = new HashMap<String, Object>();
187+
* rowContent.put("fieldName1", true);
188+
* rowContent.put("fieldName2", recordContent);
189+
* builder.addRow("rowId", rowContent);
190190
* }</pre>
191191
*/
192192
public Builder addRow(String id, Map<String, Object> content) {
@@ -198,16 +198,16 @@ public Builder addRow(String id, Map<String, Object> content) {
198198
* Adds a row to be inserted without an associated id.
199199
*
200200
* <p>Example usage of adding a row without an associated id:
201-
* <pre> {@code
202-
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
203-
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
204-
* Map<String, Object> recordContent = new HashMap<String, Object>();
205-
* recordContent.put("subfieldName1", "value");
206-
* recordContent.put("subfieldName2", repeatedFieldValue);
207-
* Map<String, Object> rowContent = new HashMap<String, Object>();
208-
* rowContent.put("fieldName1", true);
209-
* rowContent.put("fieldName2", recordContent);
210-
* builder.addRow(rowContent);
201+
* <pre> {@code
202+
* InsertAllRequest.Builder builder = InsertAllRequest.builder(tableId);
203+
* List<Long> repeatedFieldValue = Arrays.asList(1L, 2L);
204+
* Map<String, Object> recordContent = new HashMap<String, Object>();
205+
* recordContent.put("subfieldName1", "value");
206+
* recordContent.put("subfieldName2", repeatedFieldValue);
207+
* Map<String, Object> rowContent = new HashMap<String, Object>();
208+
* rowContent.put("fieldName1", true);
209+
* rowContent.put("fieldName2", recordContent);
210+
* builder.addRow(rowContent);
211211
* }</pre>
212212
*/
213213
public Builder addRow(Map<String, Object> content) {

‎trunk/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/QueryRequest.java‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -35,26 +35,26 @@
3535
* {@link QueryResponse#jobCompleted()} returns {@code true}.
3636
*
3737
* <p>Example usage of a query request:
38-
* <pre> {@code
39-
* // Substitute "field", "table" and "dataset" with real field, table and dataset identifiers
40-
* QueryRequest request = QueryRequest.builder("SELECT field FROM table")
41-
* .defaultDataset(DatasetId.of("dataset"))
42-
* .maxWaitTime(60000L)
43-
* .maxResults(1000L)
44-
* .build();
45-
* QueryResponse response = bigquery.query(request);
46-
* while (!response.jobCompleted()) {
47-
* Thread.sleep(1000);
48-
* response = bigquery.getQueryResults(response.jobId());
49-
* }
50-
* List<BigQueryError> executionErrors = response.executionErrors();
51-
* // look for errors in executionErrors
52-
* QueryResult result = response.result();
53-
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
54-
* while(rowIterator.hasNext()) {
55-
* List<FieldValue> row = rowIterator.next();
56-
* // do something with row
57-
* }
38+
* <pre> {@code
39+
* // Substitute "field", "table" and "dataset" with real field, table and dataset identifiers
40+
* QueryRequest request = QueryRequest.builder("SELECT field FROM table")
41+
* .defaultDataset(DatasetId.of("dataset"))
42+
* .maxWaitTime(60000L)
43+
* .maxResults(1000L)
44+
* .build();
45+
* QueryResponse response = bigquery.query(request);
46+
* while (!response.jobCompleted()) {
47+
* Thread.sleep(1000);
48+
* response = bigquery.getQueryResults(response.jobId());
49+
* }
50+
* List<BigQueryError> executionErrors = response.executionErrors();
51+
* // look for errors in executionErrors
52+
* QueryResult result = response.result();
53+
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
54+
* while(rowIterator.hasNext()) {
55+
* List<FieldValue> row = rowIterator.next();
56+
* // do something with row
57+
* }
5858
* }</pre>
5959
*
6060
* @see <a href="https://cloud.google.com/bigquery/docs/reference/v2/jobs/query">Query</a>

‎trunk/gcloud-java-bigquery/src/main/java/com/google/gcloud/bigquery/QueryResponse.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -29,20 +29,20 @@
2929
* Query Request ({@link BigQuery#query(QueryRequest)}).
3030
*
3131
* <p>Example usage of a query response:
32-
* <pre> {@code
33-
* QueryResponse response = bigquery.query(request);
34-
* while (!response.jobCompleted()) {
35-
* Thread.sleep(1000);
36-
* response = bigquery.getQueryResults(response.jobId());
37-
* }
38-
* List<BigQueryError> executionErrors = response.executionErrors();
39-
* // look for errors in executionErrors
40-
* QueryResult result = response.result();
41-
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
42-
* while(rowIterator.hasNext()) {
43-
* List<FieldValue> row = rowIterator.next();
44-
* // do something with row
45-
* }
32+
* <pre> {@code
33+
* QueryResponse response = bigquery.query(request);
34+
* while (!response.jobCompleted()) {
35+
* Thread.sleep(1000);
36+
* response = bigquery.getQueryResults(response.jobId());
37+
* }
38+
* List<BigQueryError> executionErrors = response.executionErrors();
39+
* // look for errors in executionErrors
40+
* QueryResult result = response.result();
41+
* Iterator<List<FieldValue>> rowIterator = result.iterateAll();
42+
* while(rowIterator.hasNext()) {
43+
* List<FieldValue> row = rowIterator.next();
44+
* // do something with row
45+
* }
4646
* }</pre>
4747
*
4848
* @see <a href="https://cloud.google.com/bigquery/docs/reference/v2/jobs/getQueryResults">Get Query

trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java renamed to trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/it/ITBigQueryTest.java

Lines changed: 53 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -14,14 +14,8 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.google.gcloud.bigquery;
18-
19-
import static com.google.gcloud.bigquery.BigQuery.DatasetField;
20-
import static com.google.gcloud.bigquery.BigQuery.JobField;
21-
import static com.google.gcloud.bigquery.BigQuery.JobListOption;
22-
import static com.google.gcloud.bigquery.BigQuery.JobOption;
23-
import static com.google.gcloud.bigquery.BigQuery.TableField;
24-
import static com.google.gcloud.bigquery.BigQuery.TableOption;
17+
package com.google.gcloud.bigquery.it;
18+
2519
import static org.junit.Assert.assertEquals;
2620
import static org.junit.Assert.assertFalse;
2721
import static org.junit.Assert.assertNotNull;
@@ -32,7 +26,43 @@
3226
import com.google.common.collect.ImmutableList;
3327
import com.google.common.collect.ImmutableMap;
3428
import com.google.gcloud.Page;
29+
import com.google.gcloud.WriteChannel;
30+
import com.google.gcloud.bigquery.BigQuery;
31+
import com.google.gcloud.bigquery.BigQuery.DatasetField;
3532
import com.google.gcloud.bigquery.BigQuery.DatasetOption;
33+
import com.google.gcloud.bigquery.BigQuery.JobField;
34+
import com.google.gcloud.bigquery.BigQuery.JobListOption;
35+
import com.google.gcloud.bigquery.BigQuery.JobOption;
36+
import com.google.gcloud.bigquery.BigQuery.TableField;
37+
import com.google.gcloud.bigquery.BigQuery.TableOption;
38+
import com.google.gcloud.bigquery.BigQueryError;
39+
import com.google.gcloud.bigquery.BigQueryException;
40+
import com.google.gcloud.bigquery.CopyJobConfiguration;
41+
import com.google.gcloud.bigquery.Dataset;
42+
import com.google.gcloud.bigquery.DatasetId;
43+
import com.google.gcloud.bigquery.DatasetInfo;
44+
import com.google.gcloud.bigquery.ExternalTableDefinition;
45+
import com.google.gcloud.bigquery.ExtractJobConfiguration;
46+
import com.google.gcloud.bigquery.Field;
47+
import com.google.gcloud.bigquery.FieldValue;
48+
import com.google.gcloud.bigquery.FormatOptions;
49+
import com.google.gcloud.bigquery.InsertAllRequest;
50+
import com.google.gcloud.bigquery.InsertAllResponse;
51+
import com.google.gcloud.bigquery.Job;
52+
import com.google.gcloud.bigquery.JobInfo;
53+
import com.google.gcloud.bigquery.JobStatistics;
54+
import com.google.gcloud.bigquery.LoadJobConfiguration;
55+
import com.google.gcloud.bigquery.QueryJobConfiguration;
56+
import com.google.gcloud.bigquery.QueryRequest;
57+
import com.google.gcloud.bigquery.QueryResponse;
58+
import com.google.gcloud.bigquery.Schema;
59+
import com.google.gcloud.bigquery.StandardTableDefinition;
60+
import com.google.gcloud.bigquery.Table;
61+
import com.google.gcloud.bigquery.TableDefinition;
62+
import com.google.gcloud.bigquery.TableId;
63+
import com.google.gcloud.bigquery.TableInfo;
64+
import com.google.gcloud.bigquery.ViewDefinition;
65+
import com.google.gcloud.bigquery.WriteChannelConfiguration;
3666
import com.google.gcloud.bigquery.testing.RemoteBigQueryHelper;
3767
import com.google.gcloud.storage.BlobInfo;
3868
import com.google.gcloud.storage.BucketInfo;
@@ -45,7 +75,6 @@
4575
import org.junit.Test;
4676
import org.junit.rules.Timeout;
4777

48-
import java.io.FileNotFoundException;
4978
import java.io.IOException;
5079
import java.nio.ByteBuffer;
5180
import java.nio.charset.StandardCharsets;
@@ -140,7 +169,7 @@ public class ITBigQueryTest {
140169
public Timeout globalTimeout = Timeout.seconds(300);
141170

142171
@BeforeClass
143-
public static void beforeClass() throws IOException, InterruptedException {
172+
public static void beforeClass() throws InterruptedException {
144173
RemoteBigQueryHelper bigqueryHelper = RemoteBigQueryHelper.create();
145174
RemoteGcsHelper gcsHelper = RemoteGcsHelper.create();
146175
bigquery = bigqueryHelper.options().service();
@@ -169,8 +198,9 @@ public static void afterClass() throws ExecutionException, InterruptedException
169198
if (bigquery != null) {
170199
RemoteBigQueryHelper.forceDelete(bigquery, DATASET);
171200
}
172-
if (storage != null && !RemoteGcsHelper.forceDelete(storage, BUCKET, 10, TimeUnit.SECONDS)) {
173-
if (LOG.isLoggable(Level.WARNING)) {
201+
if (storage != null) {
202+
boolean wasDeleted = RemoteGcsHelper.forceDelete(storage, BUCKET, 10, TimeUnit.SECONDS);
203+
if (!wasDeleted && LOG.isLoggable(Level.WARNING)) {
174204
LOG.log(Level.WARNING, "Deletion of bucket {0} timed out, bucket is not empty", BUCKET);
175205
}
176206
}
@@ -654,10 +684,9 @@ public void testQuery() throws InterruptedException {
654684
rowCount++;
655685
}
656686
assertEquals(2, rowCount);
657-
// todo(mziccard) uncomment as soon as #624 is closed
658-
// Job queryJob = bigquery.getJob(response.jobId());
659-
// JobStatistics.QueryStatistics statistics = queryJob.statistics();
660-
// assertNotNull(statistics.queryPlan());
687+
Job queryJob = bigquery.getJob(response.jobId());
688+
JobStatistics.QueryStatistics statistics = queryJob.statistics();
689+
assertNotNull(statistics.queryPlan());
661690
}
662691

663692
@Test
@@ -685,7 +714,7 @@ public void testListJobsWithSelectedFields() {
685714
}
686715

687716
@Test
688-
public void testCreateAndGetJob() throws InterruptedException {
717+
public void testCreateAndGetJob() {
689718
String sourceTableName = "test_create_and_get_job_source_table";
690719
String destinationTableName = "test_create_and_get_job_destination_table";
691720
TableId sourceTable = TableId.of(DATASET, sourceTableName);
@@ -717,7 +746,7 @@ public void testCreateAndGetJob() throws InterruptedException {
717746
}
718747

719748
@Test
720-
public void testCreateAndGetJobWithSelectedFields() throws InterruptedException {
749+
public void testCreateAndGetJobWithSelectedFields() {
721750
String sourceTableName = "test_create_and_get_job_with_selected_fields_source_table";
722751
String destinationTableName = "test_create_and_get_job_with_selected_fields_destination_table";
723752
TableId sourceTable = TableId.of(DATASET, sourceTableName);
@@ -822,10 +851,9 @@ public void testQueryJob() throws InterruptedException {
822851
}
823852
assertEquals(2, rowCount);
824853
assertTrue(bigquery.delete(DATASET, tableName));
825-
// todo(mziccard) uncomment as soon as #624 is closed
826-
// Job queryJob = bigquery.getJob(remoteJob.jobId());
827-
// JobStatistics.QueryStatistics statistics = queryJob.statistics();
828-
// assertNotNull(statistics.queryPlan());
854+
Job queryJob = bigquery.getJob(remoteJob.jobId());
855+
JobStatistics.QueryStatistics statistics = queryJob.statistics();
856+
assertNotNull(statistics.queryPlan());
829857
}
830858

831859
@Test
@@ -874,20 +902,20 @@ public void testCancelJob() throws InterruptedException {
874902
}
875903

876904
@Test
877-
public void testCancelNonExistingJob() throws InterruptedException {
905+
public void testCancelNonExistingJob() {
878906
assertFalse(bigquery.cancel("test_cancel_non_existing_job"));
879907
}
880908

881909
@Test
882-
public void testInsertFromFile() throws InterruptedException, FileNotFoundException {
910+
public void testInsertFromFile() throws InterruptedException {
883911
String destinationTableName = "test_insert_from_file_table";
884912
TableId tableId = TableId.of(DATASET, destinationTableName);
885913
WriteChannelConfiguration configuration = WriteChannelConfiguration.builder(tableId)
886914
.formatOptions(FormatOptions.json())
887915
.createDisposition(JobInfo.CreateDisposition.CREATE_IF_NEEDED)
888916
.schema(TABLE_SCHEMA)
889917
.build();
890-
try (TableDataWriteChannel channel = bigquery.writer(configuration)) {
918+
try (WriteChannel channel = bigquery.writer(configuration)) {
891919
channel.write(ByteBuffer.wrap(JSON_CONTENT.getBytes(StandardCharsets.UTF_8)));
892920
} catch (IOException e) {
893921
fail("IOException was not expected");

‎trunk/gcloud-java-contrib/README.md‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,12 @@ Google Cloud Java Contributions
33

44
Packages that provide higher-level abstraction/functionality for common gcloud-java use cases.
55

6+
[![Build Status](https://travis-ci.org/GoogleCloudPlatform/gcloud-java.svg?branch=master)](https://travis-ci.org/GoogleCloudPlatform/gcloud-java)
7+
[![Coverage Status](https://coveralls.io/repos/GoogleCloudPlatform/gcloud-java/badge.svg?branch=master)](https://coveralls.io/r/GoogleCloudPlatform/gcloud-java?branch=master)
8+
[![Maven](https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)]( https://img.shields.io/maven-central/v/com.google.gcloud/gcloud-java-bigquery.svg)
9+
[![Codacy Badge](https://api.codacy.com/project/badge/grade/9da006ad7c3a4fe1abd142e77c003917)](https://www.codacy.com/app/mziccard/gcloud-java)
10+
[![Dependency Status](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969/badge.svg?style=flat)](https://www.versioneye.com/user/projects/56bd8ee72a29ed002d2b0969)
11+
612
Quickstart
713
----------
814
If you are using Maven, add this to your pom.xml file

0 commit comments

Comments
 (0)