learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java [32:52]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static void main(String[] args) {
    PipelineOptions options = PipelineOptionsFactory.fromArgs(args).create();
    Pipeline pipeline = Pipeline.create(options);

    PCollection<Event> events =
        pipeline.apply(
            Create.of(
                new Event("1", "book-order", DateTime.parse("2019-06-01T00:00:00+00:00")),
                new Event("2", "pencil-order", DateTime.parse("2019-06-02T00:00:00+00:00")),
                new Event("3", "paper-order", DateTime.parse("2019-06-03T00:00:00+00:00")),
                new Event("4", "pencil-order", DateTime.parse("2019-06-04T00:00:00+00:00")),
                new Event("5", "book-order", DateTime.parse("2019-06-05T00:00:00+00:00"))
            )
        );

    PCollection<Event> output = applyTransform(events);

    output.apply(Log.ofElements());

    pipeline.run();
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java [33:53]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static void main(String[] args) {
    PipelineOptions options = PipelineOptionsFactory.fromArgs(args).create();
    Pipeline pipeline = Pipeline.create(options);

    PCollection<Event> events =
        pipeline.apply(
            Create.of(
                new Event("1", "book-order", DateTime.parse("2019-06-01T00:00:00+00:00")),
                new Event("2", "pencil-order", DateTime.parse("2019-06-02T00:00:00+00:00")),
                new Event("3", "paper-order", DateTime.parse("2019-06-03T00:00:00+00:00")),
                new Event("4", "pencil-order", DateTime.parse("2019-06-04T00:00:00+00:00")),
                new Event("5", "book-order", DateTime.parse("2019-06-05T00:00:00+00:00"))
            )
        );

    PCollection<Event> output = applyTransform(events);

    output.apply(Log.ofElements());

    pipeline.run();
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -