Hi,
This pipeline is sinking the rows to BQ. I use the following syntax:
| 'write to BQ' >>
beam.io.Write(beam.io.BigQuerySink(dataset='dataset_cell_line.cell_lines_1',
schema='accession_list:STRING,comment_list:STRING,derived_from:STRING,disease_list:STRING,name_list:STRING,\
reference_list:STRING,same_origin_as:STRING,species_list:STRING,str_list:STRING,\
web_page_list:STRING,xref_list:STRING',
create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED,
write_disposition=beam.io.BigQueryDisposition.WRITE_TRUNCATE)))
The following error is being fired:
TypeErrorTraceback (most recent call
last)<ipython-input-134-d09b4d35756f> in <module>() 6
reference_list:STRING,same_origin_as:STRING,species_list:STRING,str_list:STRING,\
7
web_page_list:STRING,xref_list:STRING',
create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED,---->
8
write_disposition=beam.io.BigQueryDisposition.WRITE_TRUNCATE)))TypeError:
__init__() takes at least 2 arguments (5 given)
Please let me know what I am missing.
Thanks so much,
--
Eila
www.orielresearch.org
https://www.meetu <https://www.meetup.com/Deep-Learning-In-Production/>p.co
<https://www.meetup.com/Deep-Learning-In-Production/>
m/Deep-Learning-In-Production/
<https://www.meetup.com/Deep-Learning-In-Production/>
