Read from a query
Stay organized with collections
Save and categorize content based on your preferences.
Use the BigQueryIO connector to read from a query result.
Explore further
For detailed documentation that includes this code sample, see the following:
Code sample
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],[],[[["\u003cp\u003eThis content demonstrates how to use the BigQueryIO connector to read data from a query result within a Dataflow pipeline.\u003c/p\u003e\n"],["\u003cp\u003eThe provided Java code example executes a SQL query against a BigQuery public dataset to retrieve and process repository commit counts.\u003c/p\u003e\n"],["\u003cp\u003eThe code snippet utilizes the \u003ccode\u003eManaged.read(Managed.BIGQUERY)\u003c/code\u003e function to read the query results and then transforms the output rows.\u003c/p\u003e\n"],["\u003cp\u003eApplication Default Credentials are required to authenticate to Dataflow when using the provided code sample.\u003c/p\u003e\n"],["\u003cp\u003eThe full documentation can be found in the \u003ccode\u003eRead from BigQuery to Dataflow\u003c/code\u003e resource.\u003c/p\u003e\n"]]],[],null,[]]