Beam BQ output Truncating table is not working
@@ -150,7 +150,7 @@ public class BeamBQOutputTransform extends PTransform<PCollection<HopRow>, PDone
BigQueryIO.Write.WriteDisposition writeDisposition;
if (truncateTable) {
- writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_APPEND;
+ writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_TRUNCATE;
} else {
if (failIfNotEmpty) {
writeDisposition = BigQueryIO.Write.WriteDisposition.WRITE_EMPTY;
