Skip to content
Snippets Groups Projects

Migrate Beam benchmark implementation

Merged Migrate Beam benchmark implementation
stu203404/theodolite:feature/147-add-beam-implementations into master
Merged Lorenz Boguhn requested to merge stu203404/theodolite:feature/147-add-beam-implementations into master
  1. Jan 13, 2022
  3. Jan 12, 2022
  5. Jan 07, 2022
  7. Jan 05, 2022
  9. Jan 04, 2022
  11. Dec 25, 2021
  13. Dec 24, 2021
  15. Dec 17, 2021
  17. Dec 15, 2021
  19. Dec 09, 2021
  21. Dec 07, 2021
  23. Dec 05, 2021
  25. Dec 03, 2021
  27. Nov 30, 2021
  29. Nov 28, 2021
  31. Nov 25, 2021
  33. Nov 24, 2021
    • Lorenz Boguhn's avatar
      Add uc4-beam-flink · 70492a50
      Lorenz Boguhn authored 
      Also excption Exception in thread main java.lang.IllegalArgumentException:
 Cannot union streams of different types:
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,org.apache.beam.sdk.coders.AvroCoder@b03f3cea),IntervalWindow)}
  and
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,NullableCoder(org.apache.beam.sdk.coders.AvroCoder@b03f3cea)),IntervalWindow)}
 by just using the raw not NullableCoder
      70492a50
    • Lorenz Boguhn's avatar
      Add forgotten things to uc4-beam · e9b3ac88
      Lorenz Boguhn authored 
      settings.gradle + build.gradle + Changes to KafkaReader
      e9b3ac88
    • Lorenz Boguhn's avatar
      Change KafkaConfig from Properties to HashMap · 2e87cb47
      Lorenz Boguhn authored
      2e87cb47
    • Lorenz Boguhn's avatar
      Add uc4-beam · 981e72e3
      Lorenz Boguhn authored 
      move all classes from old samza project to common pipeline project
      981e72e3
  35. Nov 19, 2021
  37. Nov 17, 2021