import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.BigQueryException;
import com.google.cloud.bigquery.BigQueryOptions;
import com.google.cloud.bigquery.QueryJobConfiguration;
import com.google.cloud.bigquery.TableResult;
// Sample to run query total rows
public class QueryTotalRows {
public static void main(String[] args) {
String query =
"SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013`"
+ " WHERE state = \"TX\""
+ " LIMIT 100";
queryTotalRows(query);
}
public static void queryTotalRows(String query) {
try {
// Initialize client that will be used to send requests. This client only needs to be created
// once, and can be reused for multiple requests.
BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();
TableResult results = bigquery.query(QueryJobConfiguration.of(query));
System.out.println("Query total rows performed successfully." + results.getTotalRows());
} catch (BigQueryException | InterruptedException e) {
System.out.println("Query not performed \n" + e.toString());
}
}
}
# from google.cloud import bigquery
# client = bigquery.Client()
query = (
"SELECT name FROM `bigquery-public-data.usa_names.usa_1910_2013` "
'WHERE state = "TX" '
"LIMIT 100"
)
query_job = client.query(
query,
# Location must match that of the dataset(s) referenced in the query.
location="US",
) # API request - starts the query
results = query_job.result() # Wait for query to complete.
print("Got {} rows.".format(results.total_rows))