Commit dbe81847 authored by Federico Mestrone's avatar Federico Mestrone
Browse files

Fix for windowed writes from Jeff

parent e37b70ce
......@@ -60,7 +60,7 @@ public class StreamingPipeline {
)
.apply(TextIO.write()
.withWindowedWrites()
.withoutSharding()
.withNumShards(1)
.withTempDirectory(FileSystems.matchNewResource(args[4], false))
.to(DefaultFilenamePolicy.fromStandardParameters(ValueProvider.StaticValueProvider.of(FileSystems.matchNewResource(args[4] + "site", false)), DefaultFilenamePolicy.DEFAULT_WINDOWED_SHARD_TEMPLATE, ".csv", true)))
;
......@@ -78,7 +78,7 @@ public class StreamingPipeline {
)
.apply(TextIO.write()
.withWindowedWrites()
.withoutSharding()
.withNumShards(1)
.withTempDirectory(FileSystems.matchNewResource(args[4], false))
.to(DefaultFilenamePolicy.fromStandardParameters(ValueProvider.StaticValueProvider.of(FileSystems.matchNewResource(args[4] + "device", false)), DefaultFilenamePolicy.DEFAULT_WINDOWED_SHARD_TEMPLATE, ".csv", true)))
;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment