@@ -22,16 +22,16 @@ If you are using Maven, add this to your pom.xml file
2222<dependency >
2323 <groupId >com.google.cloud</groupId >
2424 <artifactId >google-cloud-bigquery</artifactId >
25- <version >0.24 .0-beta</version >
25+ <version >0.25 .0-beta</version >
2626</dependency >
2727```
2828If you are using Gradle, add this to your dependencies
2929``` Groovy
30- compile 'com.google.cloud:google-cloud-bigquery:0.24 .0-beta'
30+ compile 'com.google.cloud:google-cloud-bigquery:0.25 .0-beta'
3131```
3232If you are using SBT, add this to your dependencies
3333``` Scala
34- libraryDependencies += " com.google.cloud" % " google-cloud-bigquery" % " 0.24 .0-beta"
34+ libraryDependencies += " com.google.cloud" % " google-cloud-bigquery" % " 0.25 .0-beta"
3535```
3636
3737Example Application
@@ -125,7 +125,7 @@ Then add the following code to create the table:
125125``` java
126126TableId tableId = TableId . of(datasetId, " my_table_id"
127127// Table field definition
128- Field stringField = Field . of(" StringField" Field . Type . string() );
128+ Field stringField = Field . of(" StringField" LegacySQLTypeName . STRING
129129// Table schema definition
130130Schema schema = Schema . of(stringField);
131131// Create a table
@@ -172,7 +172,7 @@ for the result. Add the following imports at the top of your file:
172172
173173``` java
174174import com.google.cloud.bigquery.FieldValue ;
175- import com.google.cloud.bigquery.QueryRequest ;
175+ import com.google.cloud.bigquery.QueryJobConfiguration ;
176176import com.google.cloud.bigquery.QueryResponse ;
177177
178178import java.util.Iterator ;
@@ -182,22 +182,17 @@ Then add the following code to run the query and wait for the result:
182182
183183``` java
184184// Create a query request
185- QueryRequest queryRequest =
186- QueryRequest . newBuilder(" SELECT * FROM my_dataset_id.my_table_id"
187- .setMaxWaitTime(60000L )
188- .setPageSize(1000L )
189- .build();
185+ QueryJobConfiguration queryConfig =
186+ QueryJobConfiguration . of(" SELECT * FROM my_dataset_id.my_table_id"
190187// Request query to be executed and wait for results
191- QueryResponse queryResponse = bigquery. query(queryRequest);
192- while (! queryResponse. jobCompleted()) {
193- Thread . sleep(1000L );
194- queryResponse = bigquery. getQueryResults(queryResponse. getJobId());
195- }
188+ QueryResponse queryResponse = bigquery. query(
189+ queryConfig,
190+ QueryOption . of(QueryResultsOption . maxWaitTime(60000L )),
191+ QueryOption . of(QueryResultsOption . pageSize(1000L )));
196192// Read rows
197- Iterator<List<FieldValue > > rowIterator = queryResponse. getResult(). iterateAll();
198193System . out. println(" Table rows:"
199- while (rowIterator . hasNext ()) {
200- System . out. println(rowIterator . next() );
194+ for ( FieldValues row : queryResponse . getResult() . iterateAll ()) {
195+ System . out. println(row );
201196}
202197```
203198#### Complete source code
0 commit comments