Minor fixes: Windowed comments

.gitignore

@@ -9,6 +9,7 @@
 # Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
 
 # User-specific stuff
+.idea/**
 .idea/**/workspace.xml
 .idea/**/tasks.xml
 .idea/**/usage.statistics.xml
@@ -97,4 +98,5 @@ fabric.properties
 *.rar
 
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
+hs_err_pid*
+target/**

beam_df_dedup/src/main/java/com/google/examples/dfdedup/DedupWithDistinct.java

@@ -30,7 +30,7 @@ public class DedupWithDistinct {
     private static final Logger LOG = LoggerFactory.getLogger(DedupWithDistinct.class);
 
     private static PCollection<Message> dedupWithDistinct(PCollection<Message> stream) {
-
+        // [START FIXED_WINDOW_DISTINCT]
         PCollection<Message> windowedStream =
                 stream.apply("WindowForDistinct",
                         Window.<Message>into(FixedWindows.of(Duration.standardSeconds(10)))
@@ -43,12 +43,12 @@ private static PCollection<Message> dedupWithDistinct(PCollection<Message> strea
                 windowedStream.apply(Distinct.withRepresentativeValueFn(
                         (Message m) -> (m.getLogicalId()))
                         .withRepresentativeType(TypeDescriptor.of(String.class)));
-
+        // [END FIXED_WINDOW_DISTINCT]
         return dedupedStream;
     }
 
     private static PCollection<Message> dedupWithDistinctGlobal(PCollection<Message> stream) {
-
+        // [START GLOBAL_WINDOW_DISTINCT]
         PCollection<Message> windowedStream =
                 stream.apply("WindowForDistinct",
                         Window.<Message>into(new GlobalWindows())
@@ -61,7 +61,7 @@ private static PCollection<Message> dedupWithDistinctGlobal(PCollection<Message>
                 windowedStream.apply(Distinct.withRepresentativeValueFn(
                         (Message m) -> (m.getLogicalId()))
                         .withRepresentativeType(TypeDescriptor.of(String.class)));
-
+        // [END GLOBAL_WINDOW_DISTINCT]
         return dedupedStream;
     }