Commits · 0bfa08bd59be9d4414ea44ffc5bb7659e16b5c49 · Sören Henning / theodolite

Mar 24, 2022
- Fix typos · 0bfa08bd
  Sören Henning authored 3 years ago
  
  0bfa08bd
- Support pipeline cancelation from BeamService · df4ebc10
  Sören Henning authored 3 years ago
  
  df4ebc10
Mar 08, 2022
- Allow configuring max.poll.records · 2e509237
  Sören Henning authored 3 years ago
  
  2e509237
- Fix config capitalization · 5db4cce2
  Sören Henning authored 3 years ago
  
  5db4cce2
Feb 28, 2022
- Fix code quality issues · 9cfffc58
  Sören Henning authored 3 years ago
  
  9cfffc58
- Align Eclipse settings among projects · 02161dba
  Sören Henning authored 3 years ago
  
  02161dba
- Create template for new Beam framework · cdc1e135
  Sören Henning authored 3 years ago
  
  cdc1e135
Feb 25, 2022
- Register coders before creating pipeline · 25155d6c
  Sören Henning authored 3 years ago
  
  25155d6c
Feb 24, 2022
- Refactor package names for Beam · 86aff281
  Sören Henning authored 3 years ago
  
  86aff281
- Fix code quality issues · a89fbc33
  Sören Henning authored 3 years ago
  
  a89fbc33
- Align Eclipse settings among projects · 15d753eb
  Sören Henning authored 3 years ago
  
  15d753eb
Feb 22, 2022
- Create template for new Beam framework · 1bd89de6
  Sören Henning authored 3 years ago
  
  1bd89de6
Feb 19, 2022
- Minor code refactroing · 1661623c
  Sören Henning authored 3 years ago
  
  1661623c
Jan 31, 2022
- Suppress PMD warning · 47ec6dbc
  Sören Henning authored 3 years ago
  
  47ec6dbc
- Suppress and fix PMD/Spotbugs warnings · a78f5df9
  Sören Henning authored 3 years ago
  
  a78f5df9
- Write Avro records with schema registry · 3bdc9c14
  Sören Henning authored 3 years ago
  
  3bdc9c14
- Fix missing imports · 39e0a5ee
  Sören Henning authored 3 years ago
  
  39e0a5ee
- Use provided (but hidden) Confluent deserializer · 7d77ea38
  Sören Henning authored 3 years ago
  
  7d77ea38
- Fix code quality issues · 7c7d0634
  Sören Henning authored 3 years ago
  
  7c7d0634
- Code refactoring for Kafka Beam reader · ac0e3dc5
  Sören Henning authored 3 years ago
  
  ac0e3dc5
- Update Eclipse format settings · 4083c0f6
  Sören Henning authored 3 years ago
  
  4083c0f6
Jan 14, 2022
- Replace jcenter() with mavenCentral() · 27783328
  Sören Henning authored 3 years ago
  
  27783328
Jan 13, 2022
- Upgrade to Beam 2.35 · 15f6fcde
  Sören Henning authored 3 years ago
  
  15f6fcde
Jan 04, 2022
- Fix minor JavaDoc issues · 29dba57a
  Sören Henning authored 3 years ago
  
  29dba57a
Dec 15, 2021
- Add null check for beam ActivePowerReader · a21b77ad
  Lorenz Boguhn authored 3 years ago
  
  a21b77ad
Dec 07, 2021
- Remove unnecessary SuppressWarnings beam-commons · b6d305b4
  Lorenz Boguhn authored 3 years ago
  
  b6d305b4
- Remove not used keys in ConfigurationKeys · 357e8130
  Lorenz Boguhn authored 3 years ago
  
  357e8130
- Remove empty row beam-common · 7aca9aa9
  Lorenz Boguhn authored 3 years ago
  
  7aca9aa9
- Add Types to beam-common KafkaActivePowerRecordReader · 795f095e
  Lorenz Boguhn authored 3 years ago
  
  795f095e
Dec 03, 2021
- Add logging of Pipeline options · 38e37ecd
  Lorenz Boguhn authored 3 years ago
  
  38e37ecd
Nov 30, 2021
- Add generic Reader from Kafka · 777ad136
  Lorenz Boguhn authored 3 years ago
  
  Just in usecase 4 for now
  777ad136
- Refactor + Repair pipeline and · 15588dbf
  Lorenz Boguhn authored 3 years ago
  
  delete Uc4ApplicationBeamNoFeedback
  15588dbf
Nov 25, 2021
- Change KafkaConsumer from HashMap to Map · f3493a1f
  Lorenz Boguhn authored 3 years ago
  
  refactor uc4-beam a bit
  f3493a1f
- Refactor using import in beam-commons EventTimePolicy · d0d3cdaa
  Lorenz Boguhn authored 3 years ago
  
  d0d3cdaa
- Fix uc4-beam · bbe7169c
  Lorenz Boguhn authored 3 years ago
  
  refactor + use Generalized KafkaReader and writer
  bbe7169c
Nov 24, 2021
- Add forgotten things to uc4-beam · e9b3ac88
  Lorenz Boguhn authored 3 years ago
  
  settings.gradle + build.gradle + Changes to KafkaReader
  e9b3ac88
- Change KafkaConfig from Properties to HashMap · 2e87cb47
  Lorenz Boguhn authored 3 years ago
  
  2e87cb47
Nov 19, 2021
- Fixing uc3-beam · 00c0c259
  Lorenz Boguhn authored 3 years ago
  
  pmd + checkstyle + Add New KafkaActivePowerTimestampReader + Refactoring
  00c0c259
- Enhanced beam-commons for uc3 · 6cccc5ee
  Lorenz Boguhn authored 3 years ago
  
  6cccc5ee
- Add uc2-beam-flink + · 786b874b
  Lorenz Boguhn authored 3 years ago
  
  Put inputTopic and bootstrapServer variable inside AbstractPipeline
  786b874b