{"id":110628,"date":"2021-06-30T10:00:00","date_gmt":"2021-06-30T07:00:00","guid":{"rendered":"https:\/\/www.javacodegeeks.com\/?p=110628"},"modified":"2021-06-28T14:18:51","modified_gmt":"2021-06-28T11:18:51","slug":"bigquery-storage-api-avro","status":"publish","type":"post","link":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html","title":{"rendered":"BigQuery Storage API: Avro"},"content":{"rendered":"

Previously we had an introduction<\/a> on the BigQuery Storage API and we proceeded reading data using the Arrow format. In this tutorial we shall read Data using the Avro format.<\/p>\n

What applied on the previous tutorial applies here too.<\/p>\n

We shall create a BigQuery Storage Client, create a ReadSession using the Avro format and iterate the data on each stream.<\/p>\n

\n
\"\"<\/a><\/figure>\n<\/div>\n

Let\u2019s get started by importing the dependencies, we do import the Avro library needed.<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n
19<\/div>\n
20<\/div>\n
21<\/div>\n
22<\/div>\n
23<\/div>\n<\/td>\n
\n
\n
<<\/code>dependencyManagement<\/code>><\/code><\/div>\n
        <\/code><<\/code>dependencies<\/code>><\/code><\/div>\n
            <\/code><<\/code>dependency<\/code>><\/code><\/div>\n
                <\/code><<\/code>groupId<\/code>>com.google.cloud<\/<\/code>groupId<\/code>><\/code><\/div>\n
                <\/code><<\/code>artifactId<\/code>>libraries-bom<\/<\/code>artifactId<\/code>><\/code><\/div>\n
                <\/code><<\/code>version<\/code>>20.5.0<\/<\/code>version<\/code>><\/code><\/div>\n
                <\/code><<\/code>type<\/code>>pom<\/<\/code>type<\/code>><\/code><\/div>\n
                <\/code><<\/code>scope<\/code>>import<\/<\/code>scope<\/code>><\/code><\/div>\n
            <\/code><\/<\/code>dependency<\/code>><\/code><\/div>\n
        <\/code><\/<\/code>dependencies<\/code>><\/code><\/div>\n
    <\/code><\/<\/code>dependencyManagement<\/code>><\/code><\/div>\n
 <\/div>\n
    <\/code><<\/code>dependencies<\/code>><\/code><\/div>\n
        <\/code><<\/code>dependency<\/code>><\/code><\/div>\n
            <\/code><<\/code>groupId<\/code>>com.google.cloud<\/<\/code>groupId<\/code>><\/code><\/div>\n
            <\/code><<\/code>artifactId<\/code>>google-cloud-bigquerystorage<\/<\/code>artifactId<\/code>><\/code><\/div>\n
        <\/code><\/<\/code>dependency<\/code>><\/code><\/div>\n
        <\/code><<\/code>dependency<\/code>><\/code><\/div>\n
            <\/code><<\/code>groupId<\/code>>org.apache.avro<\/<\/code>groupId<\/code>><\/code><\/div>\n
            <\/code><<\/code>artifactId<\/code>>avro<\/<\/code>artifactId<\/code>><\/code><\/div>\n
            <\/code><<\/code>version<\/code>>1.9.2<\/<\/code>version<\/code>><\/code><\/div>\n
        <\/code><\/<\/code>dependency<\/code>><\/code><\/div>\n
    <\/code><\/<\/code>dependencies<\/code>><\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

Our next step would be to create an Avro Data Reader for our rows that have the schema of col1:string, col2:int. In our case we shall just print the data through sys.out<\/p>\n

\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n
19<\/div>\n
20<\/div>\n
21<\/div>\n
22<\/div>\n
23<\/div>\n
24<\/div>\n
25<\/div>\n
26<\/div>\n
27<\/div>\n
28<\/div>\n
29<\/div>\n
30<\/div>\n
31<\/div>\n
32<\/div>\n
33<\/div>\n
34<\/div>\n
35<\/div>\n
36<\/div>\n
37<\/div>\n<\/td>\n
\n
\n
package<\/code> com.gkatzioura.bigquery.storage.api.avro;<\/code><\/div>\n
 <\/div>\n
import<\/code> java.io.ByteArrayInputStream;<\/code><\/div>\n
import<\/code> java.io.IOException;<\/code><\/div>\n
import<\/code> java.io.InputStream;<\/code><\/div>\n
 <\/div>\n
import<\/code> org.apache.avro.Schema;<\/code><\/div>\n
import<\/code> org.apache.avro.generic.GenericDatumReader;<\/code><\/div>\n
import<\/code> org.apache.avro.generic.GenericRecord;<\/code><\/div>\n
import<\/code> org.apache.avro.io.BinaryDecoder;<\/code><\/div>\n
import<\/code> org.apache.avro.io.DecoderFactory;<\/code><\/div>\n
 <\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.AvroSchema;<\/code><\/div>\n
import<\/code> com.google.protobuf.ByteString;<\/code><\/div>\n
 <\/div>\n
public<\/code> class<\/code> AvroReader {<\/code><\/div>\n
 <\/div>\n
    <\/code>private<\/code> final<\/code> GenericDatumReader<GenericRecord> datumReader;<\/code><\/div>\n
 <\/div>\n
    <\/code>public<\/code> AvroReader(AvroSchema arrowSchema) {<\/code><\/div>\n
        <\/code>Schema schema = <\/code>new<\/code> Schema.Parser().parse(arrowSchema.getSchema());<\/code><\/div>\n
        <\/code>this<\/code>.datumReader = <\/code>new<\/code> GenericDatumReader<>(schema);<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
    <\/code>public<\/code> void<\/code> processRows(ByteString avroRows) <\/code>throws<\/code> IOException {<\/code><\/div>\n
        <\/code>try<\/code>(InputStream inputStream = <\/code>new<\/code> ByteArrayInputStream(avroRows.toByteArray())) {<\/code><\/div>\n
            <\/code>BinaryDecoder decoder =DecoderFactory.get().binaryDecoder(inputStream, <\/code>null<\/code>);<\/code><\/div>\n
 <\/div>\n
            <\/code>while<\/code> (!decoder.isEnd()) {<\/code><\/div>\n
                <\/code>GenericRecord item = datumReader.read(<\/code>null<\/code>, decoder);<\/code><\/div>\n
 <\/div>\n
                <\/code>System.out.println(item.get(<\/code>\"col1\"<\/code>)+<\/code>\",\"<\/code>+item.get(<\/code>\"col2\"<\/code>));<\/code><\/div>\n
            <\/code>}<\/code><\/div>\n
        <\/code>}<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

Then on to our main class which is the one with any BigQuery logic needed.

<\/div> <\/div><\/p>\n
\n
\n\n\n\n
\n
01<\/div>\n
02<\/div>\n
03<\/div>\n
04<\/div>\n
05<\/div>\n
06<\/div>\n
07<\/div>\n
08<\/div>\n
09<\/div>\n
10<\/div>\n
11<\/div>\n
12<\/div>\n
13<\/div>\n
14<\/div>\n
15<\/div>\n
16<\/div>\n
17<\/div>\n
18<\/div>\n
19<\/div>\n
20<\/div>\n
21<\/div>\n
22<\/div>\n
23<\/div>\n
24<\/div>\n
25<\/div>\n
26<\/div>\n
27<\/div>\n
28<\/div>\n
29<\/div>\n
30<\/div>\n
31<\/div>\n
32<\/div>\n
33<\/div>\n
34<\/div>\n
35<\/div>\n
36<\/div>\n
37<\/div>\n
38<\/div>\n
39<\/div>\n
40<\/div>\n
41<\/div>\n
42<\/div>\n
43<\/div>\n
44<\/div>\n
45<\/div>\n
46<\/div>\n
47<\/div>\n
48<\/div>\n
49<\/div>\n
50<\/div>\n
51<\/div>\n
52<\/div>\n
53<\/div>\n
54<\/div>\n
55<\/div>\n<\/td>\n
\n
\n
package<\/code> com.gkatzioura.bigquery.storage.api.avro;<\/code><\/div>\n
 <\/div>\n
import<\/code> org.apache.arrow.util.Preconditions;<\/code><\/div>\n
 <\/div>\n
import<\/code> com.google.api.gax.rpc.ServerStream;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.BigQueryReadClient;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.DataFormat;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.ReadRowsRequest;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.ReadRowsResponse;<\/code><\/div>\n
import<\/code> com.google.cloud.bigquery.storage.v1.ReadSession;<\/code><\/div>\n
 <\/div>\n
public<\/code> class<\/code> AvroMain {<\/code><\/div>\n
 <\/div>\n
    <\/code>public<\/code> static<\/code> void<\/code> main(String[] args) <\/code>throws<\/code> Exception {<\/code><\/div>\n
 <\/div>\n
        <\/code>String projectId = System.getenv(<\/code>\"PROJECT_ID\"<\/code>);<\/code><\/div>\n
 <\/div>\n
        <\/code>try<\/code> (BigQueryReadClient client = BigQueryReadClient.create()) {<\/code><\/div>\n
            <\/code>String parent = String.format(<\/code>\"projects\/%s\"<\/code>, projectId);<\/code><\/div>\n
 <\/div>\n
            <\/code>String srcTable =<\/code><\/div>\n
                    <\/code>String.format(<\/code><\/div>\n
                            <\/code>\"projects\/%s\/datasets\/%s\/tables\/%s\"<\/code>,<\/code><\/div>\n
                            <\/code>projectId, System.getenv(<\/code>\"DATASET\"<\/code>), System.getenv(<\/code>\"TABLE\"<\/code>));<\/code><\/div>\n
 <\/div>\n
            <\/code>ReadSession.Builder sessionBuilder =<\/code><\/div>\n
                    <\/code>ReadSession.newBuilder()<\/code><\/div>\n
                               <\/code>.setTable(srcTable)<\/code><\/div>\n
                               <\/code>.setDataFormat(DataFormat.AVRO);<\/code><\/div>\n
 <\/div>\n
 <\/div>\n
            <\/code>CreateReadSessionRequest.Builder builder =<\/code><\/div>\n
                    <\/code>CreateReadSessionRequest.newBuilder()<\/code><\/div>\n
                                            <\/code>.setParent(parent)<\/code><\/div>\n
                                            <\/code>.setReadSession(sessionBuilder)<\/code><\/div>\n
                                            <\/code>.setMaxStreamCount(<\/code>1<\/code>);<\/code><\/div>\n
            <\/code>ReadSession session = client.createReadSession(builder.build());<\/code><\/div>\n
 <\/div>\n
            <\/code>Preconditions.checkState(session.getStreamsCount() > <\/code>0<\/code>);<\/code><\/div>\n
 <\/div>\n
            <\/code>String streamName = session.getStreams(<\/code>0<\/code>).getName();<\/code><\/div>\n
 <\/div>\n
            <\/code>ReadRowsRequest readRowsRequest =<\/code><\/div>\n
                    <\/code>ReadRowsRequest.newBuilder().setReadStream(streamName).build();<\/code><\/div>\n
 <\/div>\n
            <\/code>ServerStream<ReadRowsResponse> stream = client.readRowsCallable().call(readRowsRequest);<\/code><\/div>\n
 <\/div>\n
            <\/code>for<\/code> (ReadRowsResponse response : stream) {<\/code><\/div>\n
                <\/code>new<\/code> AvroReader(session.getAvroSchema()).processRows(response.getAvroRows().getSerializedBinaryRows());<\/code><\/div>\n
            <\/code>}<\/code><\/div>\n
        <\/code>}<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n
}<\/code><\/div>\n<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n

A BigQuery client is created. Then we create a session request with a max number of streams. We did specify that the format to be used will be Avro.
Once we get a Response, the response will contain the initiated the Session, the Avro schema and the streams that we shall use to retrieve the Data.
For each stream there has to be a ReadRowsRequest in order to fetch the data.
Then we pass data to our Avro decoder.<\/p>\n

That\u2019s it we just read data from the BigQuery Storage API using Avro and Arrow!<\/p>\n

\n\n\n\n
\n

Published on Java Code Geeks with permission by Emmanouil Gkatziouras, partner at our JCG program<\/a>. See the original article here: BigQuery Storage API: Avro<\/a><\/p>\n

Opinions expressed by Java Code Geeks contributors are their own.<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n","protected":false},"excerpt":{"rendered":"

Previously we had an introduction on the BigQuery Storage API and we proceeded reading data using the Arrow format. In this tutorial we shall read Data using the Avro format. What applied on the previous tutorial applies here too. We shall create a BigQuery Storage Client, create a ReadSession using the Avro format and iterate …<\/p>\n","protected":false},"author":936,"featured_media":112,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8],"tags":[372],"class_list":["post-110628","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-enterprise-java","tag-big-data"],"yoast_head":"\nBigQuery Storage API: Avro - Java Code Geeks<\/title>\n<meta name=\"description\" content=\"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.\" \/>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html\" \/>\n<meta property=\"og:locale\" content=\"en_US\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"BigQuery Storage API: Avro - Java Code Geeks\" \/>\n<meta property=\"og:description\" content=\"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html\" \/>\n<meta property=\"og:site_name\" content=\"Java Code Geeks\" \/>\n<meta property=\"article:publisher\" content=\"https:\/\/www.facebook.com\/javacodegeeks\" \/>\n<meta property=\"article:published_time\" content=\"2021-06-30T07:00:00+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"150\" \/>\n\t<meta property=\"og:image:height\" content=\"150\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"Emmanouil Gkatziouras\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:creator\" content=\"@javacodegeeks\" \/>\n<meta name=\"twitter:site\" content=\"@javacodegeeks\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"Emmanouil Gkatziouras\" \/>\n\t<meta name=\"twitter:label2\" content=\"Est. reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\\\/\\\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#article\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html\"},\"author\":{\"name\":\"Emmanouil Gkatziouras\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/person\\\/5eee031b356c7682e1fd24c8297561c6\"},\"headline\":\"BigQuery Storage API: Avro\",\"datePublished\":\"2021-06-30T07:00:00+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html\"},\"wordCount\":285,\"commentCount\":0,\"publisher\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/enterprise-java-logo.jpg\",\"keywords\":[\"Big Data\"],\"articleSection\":[\"Enterprise Java\"],\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"CommentAction\",\"name\":\"Comment\",\"target\":[\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#respond\"]}]},{\"@type\":\"WebPage\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html\",\"name\":\"BigQuery Storage API: Avro - Java Code Geeks\",\"isPartOf\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#website\"},\"primaryImageOfPage\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#primaryimage\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#primaryimage\"},\"thumbnailUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/enterprise-java-logo.jpg\",\"datePublished\":\"2021-06-30T07:00:00+00:00\",\"description\":\"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.\",\"breadcrumb\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#breadcrumb\"},\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html\"]}]},{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#primaryimage\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/enterprise-java-logo.jpg\",\"contentUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2012\\\/10\\\/enterprise-java-logo.jpg\",\"width\":150,\"height\":150,\"caption\":\"java-interview-questions-answers\"},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/2021\\\/06\\\/bigquery-storage-api-avro.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Java\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/category\\\/java\"},{\"@type\":\"ListItem\",\"position\":3,\"name\":\"Enterprise Java\",\"item\":\"https:\\\/\\\/www.javacodegeeks.com\\\/category\\\/java\\\/enterprise-java\"},{\"@type\":\"ListItem\",\"position\":4,\"name\":\"BigQuery Storage API: Avro\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#website\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\",\"name\":\"Java Code Geeks\",\"description\":\"Java Developers Resource Center\",\"publisher\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\"},\"alternateName\":\"JCG\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\\\/\\\/www.javacodegeeks.com\\\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"en-US\"},{\"@type\":\"Organization\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#organization\",\"name\":\"Exelixis Media P.C.\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/\",\"logo\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/logo\\\/image\\\/\",\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2022\\\/06\\\/exelixis-logo.png\",\"contentUrl\":\"https:\\\/\\\/www.javacodegeeks.com\\\/wp-content\\\/uploads\\\/2022\\\/06\\\/exelixis-logo.png\",\"width\":864,\"height\":246,\"caption\":\"Exelixis Media P.C.\"},\"image\":{\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/logo\\\/image\\\/\"},\"sameAs\":[\"https:\\\/\\\/www.facebook.com\\\/javacodegeeks\",\"https:\\\/\\\/x.com\\\/javacodegeeks\"]},{\"@type\":\"Person\",\"@id\":\"https:\\\/\\\/www.javacodegeeks.com\\\/#\\\/schema\\\/person\\\/5eee031b356c7682e1fd24c8297561c6\",\"name\":\"Emmanouil Gkatziouras\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g\",\"url\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g\",\"contentUrl\":\"https:\\\/\\\/secure.gravatar.com\\\/avatar\\\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g\",\"caption\":\"Emmanouil Gkatziouras\"},\"description\":\"He is a versatile software engineer with experience in a wide variety of applications\\\/services.He is enthusiastic about new projects, embracing new technologies, and getting to know people in the field of software.\",\"sameAs\":[\"http:\\\/\\\/egkatzioura.wordpress.com\\\/\",\"https:\\\/\\\/gr.linkedin.com\\\/in\\\/gkatziourasemmanouil\"],\"url\":\"https:\\\/\\\/www.javacodegeeks.com\\\/author\\\/emmanouil-gkatziouras\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"BigQuery Storage API: Avro - Java Code Geeks","description":"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html","og_locale":"en_US","og_type":"article","og_title":"BigQuery Storage API: Avro - Java Code Geeks","og_description":"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.","og_url":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html","og_site_name":"Java Code Geeks","article_publisher":"https:\/\/www.facebook.com\/javacodegeeks","article_published_time":"2021-06-30T07:00:00+00:00","og_image":[{"width":150,"height":150,"url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg","type":"image\/jpeg"}],"author":"Emmanouil Gkatziouras","twitter_card":"summary_large_image","twitter_creator":"@javacodegeeks","twitter_site":"@javacodegeeks","twitter_misc":{"Written by":"Emmanouil Gkatziouras","Est. reading time":"4 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#article","isPartOf":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html"},"author":{"name":"Emmanouil Gkatziouras","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/person\/5eee031b356c7682e1fd24c8297561c6"},"headline":"BigQuery Storage API: Avro","datePublished":"2021-06-30T07:00:00+00:00","mainEntityOfPage":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html"},"wordCount":285,"commentCount":0,"publisher":{"@id":"https:\/\/www.javacodegeeks.com\/#organization"},"image":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#primaryimage"},"thumbnailUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg","keywords":["Big Data"],"articleSection":["Enterprise Java"],"inLanguage":"en-US","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#respond"]}]},{"@type":"WebPage","@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html","url":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html","name":"BigQuery Storage API: Avro - Java Code Geeks","isPartOf":{"@id":"https:\/\/www.javacodegeeks.com\/#website"},"primaryImageOfPage":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#primaryimage"},"image":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#primaryimage"},"thumbnailUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg","datePublished":"2021-06-30T07:00:00+00:00","description":"Interested to learn about Avro? Check our article explaining how to read Data using the Avro format.","breadcrumb":{"@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#breadcrumb"},"inLanguage":"en-US","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html"]}]},{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#primaryimage","url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg","contentUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2012\/10\/enterprise-java-logo.jpg","width":150,"height":150,"caption":"java-interview-questions-answers"},{"@type":"BreadcrumbList","@id":"https:\/\/www.javacodegeeks.com\/2021\/06\/bigquery-storage-api-avro.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/www.javacodegeeks.com\/"},{"@type":"ListItem","position":2,"name":"Java","item":"https:\/\/www.javacodegeeks.com\/category\/java"},{"@type":"ListItem","position":3,"name":"Enterprise Java","item":"https:\/\/www.javacodegeeks.com\/category\/java\/enterprise-java"},{"@type":"ListItem","position":4,"name":"BigQuery Storage API: Avro"}]},{"@type":"WebSite","@id":"https:\/\/www.javacodegeeks.com\/#website","url":"https:\/\/www.javacodegeeks.com\/","name":"Java Code Geeks","description":"Java Developers Resource Center","publisher":{"@id":"https:\/\/www.javacodegeeks.com\/#organization"},"alternateName":"JCG","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.javacodegeeks.com\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"en-US"},{"@type":"Organization","@id":"https:\/\/www.javacodegeeks.com\/#organization","name":"Exelixis Media P.C.","url":"https:\/\/www.javacodegeeks.com\/","logo":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/logo\/image\/","url":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","contentUrl":"https:\/\/www.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","width":864,"height":246,"caption":"Exelixis Media P.C."},"image":{"@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/logo\/image\/"},"sameAs":["https:\/\/www.facebook.com\/javacodegeeks","https:\/\/x.com\/javacodegeeks"]},{"@type":"Person","@id":"https:\/\/www.javacodegeeks.com\/#\/schema\/person\/5eee031b356c7682e1fd24c8297561c6","name":"Emmanouil Gkatziouras","image":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/secure.gravatar.com\/avatar\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g","url":"https:\/\/secure.gravatar.com\/avatar\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/5c6d031d211ab786ec335687ad6f3f076f93f47e24c92d78041d2f805ee6c291?s=96&d=mm&r=g","caption":"Emmanouil Gkatziouras"},"description":"He is a versatile software engineer with experience in a wide variety of applications\/services.He is enthusiastic about new projects, embracing new technologies, and getting to know people in the field of software.","sameAs":["http:\/\/egkatzioura.wordpress.com\/","https:\/\/gr.linkedin.com\/in\/gkatziourasemmanouil"],"url":"https:\/\/www.javacodegeeks.com\/author\/emmanouil-gkatziouras"}]}},"_links":{"self":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/110628","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/users\/936"}],"replies":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/comments?post=110628"}],"version-history":[{"count":0,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/110628\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/media\/112"}],"wp:attachment":[{"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/media?parent=110628"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/categories?post=110628"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.javacodegeeks.com\/wp-json\/wp\/v2\/tags?post=110628"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}