|
20 | 20 | import com.google.cloud.bigquery.BigQueryOptions; |
21 | 21 | import com.google.cloud.bigquery.FieldValue; |
22 | 22 | import com.google.cloud.bigquery.QueryParameterValue; |
23 | | -import com.google.cloud.bigquery.QueryRequest; |
| 23 | +import com.google.cloud.bigquery.QueryJobConfiguration; |
24 | 24 | import com.google.cloud.bigquery.QueryResponse; |
25 | 25 | import com.google.cloud.bigquery.QueryResult; |
26 | 26 | import org.joda.time.DateTime; |
@@ -122,8 +122,8 @@ private static void runNamed(final String corpus, final long minWordCount) |
122 | 122 | + "WHERE corpus = @corpus\n" |
123 | 123 | + "AND word_count >= @min_word_count\n" |
124 | 124 | + "ORDER BY word_count DESC"; |
125 | | - QueryRequest queryRequest = |
126 | | - QueryRequest.newBuilder(queryString) |
| 125 | + QueryJobConfiguration queryRequest = |
| 126 | + QueryJobConfiguration.newBuilder(queryString) |
127 | 127 | .addNamedParameter("corpus", QueryParameterValue.string(corpus)) |
128 | 128 | .addNamedParameter("min_word_count", QueryParameterValue.int64(minWordCount)) |
129 | 129 | // Standard SQL syntax is required for parameterized queries. |
@@ -177,8 +177,8 @@ private static void runArray(String gender, String[] states) throws InterruptedE |
177 | 177 | + "GROUP BY name\n" |
178 | 178 | + "ORDER BY count DESC\n" |
179 | 179 | + "LIMIT 10;"; |
180 | | - QueryRequest queryRequest = |
181 | | - QueryRequest.newBuilder(queryString) |
| 180 | + QueryJobConfiguration queryRequest = |
| 181 | + QueryJobConfiguration.newBuilder(queryString) |
182 | 182 | .addNamedParameter("gender", QueryParameterValue.string(gender)) |
183 | 183 | .addNamedParameter("states", QueryParameterValue.array(states, String.class)) |
184 | 184 | // Standard SQL syntax is required for parameterized queries. |
@@ -224,8 +224,8 @@ private static void runTimestamp() throws InterruptedException { |
224 | 224 | DateTime timestamp = new DateTime(2016, 12, 7, 8, 0, 0, DateTimeZone.UTC); |
225 | 225 |
|
226 | 226 | String queryString = "SELECT TIMESTAMP_ADD(@ts_value, INTERVAL 1 HOUR);"; |
227 | | - QueryRequest queryRequest = |
228 | | - QueryRequest.newBuilder(queryString) |
| 227 | + QueryJobConfiguration queryRequest = |
| 228 | + QueryJobConfiguration.newBuilder(queryString) |
229 | 229 | .addNamedParameter( |
230 | 230 | "ts_value", |
231 | 231 | QueryParameterValue.timestamp( |
|
0 commit comments