Re: Streaming inserts BQ with Java SDK Beam

2019-05-07 Thread Andres Angel
Pablo thanks so much I will explore this method then for STREAMING_INSERTS , this answer worth much for us :) thanks. On Tue, May 7, 2019 at 1:05 PM Pablo Estrada

Re: Streaming inserts BQ with Java SDK Beam

2019-05-07 Thread Alex Van Boxel
I think you really need a peculiar reason to force streamingInsert in a batch job. In batch mode you. Note that you will quickly hit the quota limit in batch mode: " Maximum rows per second: 100,000 rows per second, per project", as in batch load you can process a lot more information in a shorter

Re: Streaming inserts BQ with Java SDK Beam

2019-05-07 Thread Pablo Estrada
Hi Andres! You can definitely do streaming inserts using the Java SDK. This is available with BigQueryIO.write(). Specifically, you can use the `withMethod`[1] call to specify whether you want batch loads or streaming inserts. If you specify streaming inserts, Beam should insert rows as they come i

Streaming inserts BQ with Java SDK Beam

2019-05-07 Thread Andres Angel
Hello everyone, I need to use BigQuery inserts within my beam pipeline, hence I know well the built-in IO options offer `BigQueryIO`, however this will insert in a batch fashion to BQ creating underneath a BQ load job. I instead need to trigger a streaming insert into BQ, and I was reviewing the J