google cloud dataflow - Accessing BigQuery table through Apache Beam -
i retrieving schema of bigquery tables using dataflow v1.9 using below code:
bigquery bigqueryclient=transport.newbigqueryclient(options.as(bigqueryoptions.class)).build(); tables tablerequest = bigqueryclient.tables(); table table = tablerequest.get("","","").execute(); list<tablefieldschema> fieldss = table.getschema().getfields(); tableschema schemaa = table.getschema();
however, same doesn't work in apache beam. how same in apache beam?
i getting below message while writing same code in apache beam: "the method newbigqueryclient(options.as(bigqueryoptions.class)) undefined type transport
thank you
Comments
Post a Comment