We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5fc6008 commit e9aed0bCopy full SHA for e9aed0b
bigquery/bigquerystorage/src/main/java/com/example/bigquerystorage/StorageSample.java
@@ -123,8 +123,7 @@ public static void main(String... args) throws Exception {
123
// read from a single stream. Consider BALANCED if you're consuming
124
// multiple streams concurrently and want more consistent stream sizes.
125
.setShardingStrategy(Storage.ShardingStrategy.LIQUID)
126
- .setRequestedStreams(1)
127
- .setFormat(DataFormat.AVRO);
+ .setRequestedStreams(1);
128
129
// Optionally specify the snapshot time. When unspecified, snapshot time is "now".
130
if (snapshotMillis != null) {
0 commit comments