Skip to content

Commit bbe591b

Browse files
author
Ajay Kannan
committed
---
yaml --- r: 1591 b: refs/heads/master c: 555cc71 h: refs/heads/master i: 1589: 29d220e 1587: 4281477 1583: acad464
1 parent 3dd3dbe commit bbe591b

12 files changed

Lines changed: 72 additions & 85 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: c027e4710e130fe575c410c0e6bf23200f049e20
2+
refs/heads/master: 555cc711ba3b939b792ee232ecff814e1ab10f12
33
refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
44
refs/heads/gh-pages: d1b373c30c176edc08692348167bec3a244bb823
55
refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -443,7 +443,7 @@ public static QueryResultsOption startIndex(long startIndex) {
443443
/**
444444
* Returns an option that sets how long to wait for the query to complete, in milliseconds,
445445
* before returning. Default is 10 seconds. If the timeout passes before the job completes,
446-
* {@link QueryResponse#jobCompleted()} will be {@code false}.
446+
* {@link QueryResponse#jobComplete()} will be {@code false}.
447447
*/
448448
public static QueryResultsOption maxWaitTime(long maxWaitTime) {
449449
checkArgument(maxWaitTime >= 0);

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -514,10 +514,10 @@ public com.google.api.services.bigquery.model.QueryResponse call() {
514514
QueryResponse.Builder builder = QueryResponse.builder();
515515
JobId completeJobId = JobId.fromPb(results.getJobReference());
516516
builder.jobId(completeJobId);
517-
builder.jobCompleted(results.getJobComplete());
517+
builder.jobComplete(results.getJobComplete());
518518
List<TableRow> rowsPb = results.getRows();
519519
if (results.getJobComplete()) {
520-
builder.jobCompleted(true);
520+
builder.jobComplete(true);
521521
QueryResult.Builder resultBuilder = transformQueryResults(completeJobId, rowsPb,
522522
results.getPageToken(), options(), ImmutableMap.<BigQueryRpc.Option, Object>of());
523523
resultBuilder.totalBytesProcessed(results.getTotalBytesProcessed());
@@ -561,7 +561,7 @@ public GetQueryResultsResponse call() {
561561
JobId completeJobId = JobId.fromPb(results.getJobReference());
562562
builder.jobId(completeJobId);
563563
builder.etag(results.getEtag());
564-
builder.jobCompleted(results.getJobComplete());
564+
builder.jobComplete(results.getJobComplete());
565565
List<TableRow> rowsPb = results.getRows();
566566
if (results.getJobComplete()) {
567567
QueryResult.Builder resultBuilder = transformQueryResults(completeJobId, rowsPb,

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

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -225,14 +225,6 @@ public Builder defaultDataset(DatasetId defaultDataset) {
225225
return self();
226226
}
227227

228-
/**
229-
* Sets the default dataset. This dataset is used for all unqualified table names used in the
230-
* query.
231-
*/
232-
public Builder defaultDataset(String defaultDataset) {
233-
return defaultDataset(DatasetId.of(defaultDataset));
234-
}
235-
236228
/**
237229
* Sets a priority for the query. If not specified the priority is assumed to be
238230
* {@link Priority#INTERACTIVE}.

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

Lines changed: 5 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -29,10 +29,10 @@
2929
* a temporary table that is deleted approximately 24 hours after the query is run. The query is run
3030
* through a BigQuery Job whose identity can be accessed via {@link QueryResponse#jobId()}. If the
3131
* query does not complete within the provided {@link Builder#maxWaitTime(Long)}, the response
32-
* returned by {@link BigQuery#query(QueryRequest)} will have {@link QueryResponse#jobCompleted()}
32+
* returned by {@link BigQuery#query(QueryRequest)} will have {@link QueryResponse#jobComplete()}
3333
* set to {@code false} and {@link QueryResponse#result()} set to {@code null}. To obtain query
3434
* results you can use {@link BigQuery#getQueryResults(JobId, BigQuery.QueryResultsOption...)} until
35-
* {@link QueryResponse#jobCompleted()} returns {@code true}.
35+
* {@link QueryResponse#jobComplete()} returns {@code true}.
3636
*
3737
* <p>Example usage of a query request:
3838
* <pre> {@code
@@ -43,7 +43,7 @@
4343
* .maxResults(1000L)
4444
* .build();
4545
* QueryResponse response = bigquery.query(request);
46-
* while (!response.jobCompleted()) {
46+
* while (!response.jobComplete()) {
4747
* Thread.sleep(1000);
4848
* response = bigquery.getQueryResults(response.jobId());
4949
* }
@@ -109,18 +109,11 @@ public Builder defaultDataset(DatasetId defaultDataset) {
109109
return this;
110110
}
111111

112-
/**
113-
* Sets the default dataset to assume for any unqualified table names in the query.
114-
*/
115-
public Builder defaultDataset(String defaultDataset) {
116-
return defaultDataset(DatasetId.of(defaultDataset));
117-
}
118-
119112
/**
120113
* Sets how long to wait for the query to complete, in milliseconds, before the request times
121114
* out and returns. Note that this is only a timeout for the request, not the query. If the
122115
* query takes longer to run than the timeout value, the call returns without any results and
123-
* with the {@link QueryResponse#jobCompleted()} set to {@code false}. If not set, a wait time of
116+
* with the {@link QueryResponse#jobComplete()} set to {@code false}. If not set, a wait time of
124117
* 10000 milliseconds (10 seconds) is used.
125118
*/
126119
public Builder maxWaitTime(Long maxWaitTime) {
@@ -189,7 +182,7 @@ public DatasetId defaultDataset() {
189182
* Returns how long to wait for the query to complete, in milliseconds, before the request times
190183
* out and returns. Note that this is only a timeout for the request, not the query. If the
191184
* query takes longer to run than the timeout value, the call returns without any results and
192-
* with the {@link QueryResponse#jobCompleted()} set to {@code false}. You can call
185+
* with the {@link QueryResponse#jobComplete()} set to {@code false}. You can call
193186
* {@link BigQuery#getQueryResults(JobId, BigQuery.QueryResultsOption...)} to wait for the query
194187
* to complete and read the results. If not set, a wait time of 10000 milliseconds (10 seconds)
195188
* is used.

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

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
* <p>Example usage of a query response:
3232
* <pre> {@code
3333
* QueryResponse response = bigquery.query(request);
34-
* while (!response.jobCompleted()) {
34+
* while (!response.jobComplete()) {
3535
* Thread.sleep(1000);
3636
* response = bigquery.getQueryResults(response.jobId());
3737
* }
@@ -56,15 +56,15 @@ public class QueryResponse implements Serializable {
5656
private final QueryResult result;
5757
private final String etag;
5858
private final JobId jobId;
59-
private final boolean jobCompleted;
59+
private final boolean jobComplete;
6060
private final List<BigQueryError> executionErrors;
6161

6262
static final class Builder {
6363

6464
private QueryResult result;
6565
private String etag;
6666
private JobId jobId;
67-
private boolean jobCompleted;
67+
private boolean jobComplete;
6868
private List<BigQueryError> executionErrors;
6969

7070
private Builder() {}
@@ -84,8 +84,8 @@ Builder jobId(JobId jobId) {
8484
return this;
8585
}
8686

87-
Builder jobCompleted(boolean jobCompleted) {
88-
this.jobCompleted = jobCompleted;
87+
Builder jobComplete(boolean jobComplete) {
88+
this.jobComplete = jobComplete;
8989
return this;
9090
}
9191

@@ -103,13 +103,13 @@ private QueryResponse(Builder builder) {
103103
this.result = builder.result;
104104
this.etag = builder.etag;
105105
this.jobId = builder.jobId;
106-
this.jobCompleted = builder.jobCompleted;
106+
this.jobComplete = builder.jobComplete;
107107
this.executionErrors = builder.executionErrors != null ? builder.executionErrors
108108
: ImmutableList.<BigQueryError>of();
109109
}
110110

111111
/**
112-
* Returns the result of the query. Returns {@code null} if {@link #jobCompleted()} is {@code
112+
* Returns the result of the query. Returns {@code null} if {@link #jobComplete()} is {@code
113113
* false}.
114114
*/
115115
public QueryResult result() {
@@ -137,8 +137,8 @@ public JobId jobId() {
137137
* {@link #result()} returns {@code null}. This method can be used to check if query execution
138138
* completed and results are available.
139139
*/
140-
public boolean jobCompleted() {
141-
return jobCompleted;
140+
public boolean jobComplete() {
141+
return jobComplete;
142142
}
143143

144144
/**
@@ -164,7 +164,7 @@ public String toString() {
164164
.add("result", result)
165165
.add("etag", etag)
166166
.add("jobId", jobId)
167-
.add("jobCompleted", jobCompleted)
167+
.add("jobComplete", jobComplete)
168168
.add("executionErrors", executionErrors)
169169
.toString();
170170
}
@@ -183,7 +183,7 @@ public boolean equals(Object obj) {
183183
return false;
184184
}
185185
QueryResponse response = (QueryResponse) obj;
186-
return jobCompleted == response.jobCompleted
186+
return jobComplete == response.jobComplete
187187
&& Objects.equals(etag, response.etag)
188188
&& Objects.equals(result, response.result)
189189
&& Objects.equals(jobId, response.jobId)

‎trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/BigQueryImplTest.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -902,7 +902,7 @@ public void testQueryRequest() {
902902
assertNull(response.etag());
903903
assertNull(response.result());
904904
assertEquals(queryJob, response.jobId());
905-
assertEquals(false, response.jobCompleted());
905+
assertEquals(false, response.jobComplete());
906906
assertEquals(ImmutableList.<BigQueryError>of(), response.executionErrors());
907907
assertFalse(response.hasErrors());
908908
assertEquals(null, response.result());
@@ -926,7 +926,7 @@ public void testQueryRequestCompleted() {
926926
QueryResponse response = bigquery.query(QUERY_REQUEST);
927927
assertNull(response.etag());
928928
assertEquals(queryJob, response.jobId());
929-
assertEquals(true, response.jobCompleted());
929+
assertEquals(true, response.jobComplete());
930930
assertEquals(false, response.result().cacheHit());
931931
assertEquals(ImmutableList.<BigQueryError>of(), response.executionErrors());
932932
assertFalse(response.hasErrors());
@@ -959,7 +959,7 @@ public void testGetQueryResults() {
959959
QueryResponse response = bigquery.getQueryResults(queryJob);
960960
assertEquals("etag", response.etag());
961961
assertEquals(queryJob, response.jobId());
962-
assertEquals(true, response.jobCompleted());
962+
assertEquals(true, response.jobComplete());
963963
assertEquals(false, response.result().cacheHit());
964964
assertEquals(ImmutableList.<BigQueryError>of(), response.executionErrors());
965965
assertFalse(response.hasErrors());
@@ -993,7 +993,7 @@ public void testGetQueryResultsWithOptions() {
993993
QUERY_RESULTS_OPTION_INDEX, QUERY_RESULTS_OPTION_MAX_RESULTS,
994994
QUERY_RESULTS_OPTION_PAGE_TOKEN);
995995
assertEquals(queryJob, response.jobId());
996-
assertEquals(true, response.jobCompleted());
996+
assertEquals(true, response.jobComplete());
997997
assertEquals(false, response.result().cacheHit());
998998
assertEquals(ImmutableList.<BigQueryError>of(), response.executionErrors());
999999
assertFalse(response.hasErrors());

‎trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -320,7 +320,7 @@ public void testCreateExternalTable() throws InterruptedException {
320320
.maxResults(1000L)
321321
.build();
322322
QueryResponse response = bigquery.query(request);
323-
while (!response.jobCompleted()) {
323+
while (!response.jobComplete()) {
324324
response = bigquery.getQueryResults(response.jobId());
325325
Thread.sleep(1000);
326326
}
@@ -382,7 +382,7 @@ public void testCreateViewTable() throws InterruptedException {
382382
.maxResults(1000L)
383383
.build();
384384
QueryResponse response = bigquery.query(request);
385-
while (!response.jobCompleted()) {
385+
while (!response.jobComplete()) {
386386
response = bigquery.getQueryResults(response.jobId());
387387
Thread.sleep(1000);
388388
}
@@ -627,7 +627,7 @@ public void testQuery() throws InterruptedException {
627627
.maxResults(1000L)
628628
.build();
629629
QueryResponse response = bigquery.query(request);
630-
while (!response.jobCompleted()) {
630+
while (!response.jobComplete()) {
631631
Thread.sleep(1000);
632632
response = bigquery.getQueryResults(response.jobId());
633633
}
@@ -786,7 +786,7 @@ public void testQueryJob() throws InterruptedException {
786786
assertNull(remoteJob.status().error());
787787

788788
QueryResponse response = bigquery.getQueryResults(remoteJob.jobId());
789-
while (!response.jobCompleted()) {
789+
while (!response.jobComplete()) {
790790
Thread.sleep(1000);
791791
response = bigquery.getQueryResults(response.jobId());
792792
}

‎trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/QueryResponseTest.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public QueryResult nextPage() {
6464
private static final QueryResponse QUERY_RESPONSE = QueryResponse.builder()
6565
.etag(ETAG)
6666
.jobId(JOB_ID)
67-
.jobCompleted(JOB_COMPLETE)
67+
.jobComplete(JOB_COMPLETE)
6868
.executionErrors(ERRORS)
6969
.result(QUERY_RESULT)
7070
.build();
@@ -74,18 +74,18 @@ public void testBuilder() {
7474
assertEquals(ETAG, QUERY_RESPONSE.etag());
7575
assertEquals(QUERY_RESULT, QUERY_RESPONSE.result());
7676
assertEquals(JOB_ID, QUERY_RESPONSE.jobId());
77-
assertEquals(JOB_COMPLETE, QUERY_RESPONSE.jobCompleted());
77+
assertEquals(JOB_COMPLETE, QUERY_RESPONSE.jobComplete());
7878
assertEquals(ERRORS, QUERY_RESPONSE.executionErrors());
7979
assertTrue(QUERY_RESPONSE.hasErrors());
8080
}
8181

8282
@Test
8383
public void testBuilderIncomplete() {
84-
QueryResponse queryResponse = QueryResponse.builder().jobCompleted(false).build();
84+
QueryResponse queryResponse = QueryResponse.builder().jobComplete(false).build();
8585
assertNull(queryResponse.etag());
8686
assertNull(queryResponse.result());
8787
assertNull(queryResponse.jobId());
88-
assertFalse(queryResponse.jobCompleted());
88+
assertFalse(queryResponse.jobComplete());
8989
assertEquals(ImmutableList.<BigQueryError>of(), queryResponse.executionErrors());
9090
assertFalse(queryResponse.hasErrors());
9191
}
@@ -100,7 +100,7 @@ private void compareQueryResponse(QueryResponse expected, QueryResponse value) {
100100
assertEquals(expected.etag(), value.etag());
101101
assertEquals(expected.result(), value.result());
102102
assertEquals(expected.jobId(), value.jobId());
103-
assertEquals(expected.jobCompleted(), value.jobCompleted());
103+
assertEquals(expected.jobComplete(), value.jobComplete());
104104
assertEquals(expected.executionErrors(), value.executionErrors());
105105
assertEquals(expected.hasErrors(), value.hasErrors());
106106
}

‎trunk/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/SerializationTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ public class SerializationTest {
213213
private static final QueryResponse QUERY_RESPONSE = QueryResponse.builder()
214214
.etag(ETAG)
215215
.jobId(JOB_ID)
216-
.jobCompleted(true)
216+
.jobComplete(true)
217217
.result(QUERY_RESULT)
218218
.build();
219219

0 commit comments

Comments
 (0)