Code

Implement the filter transformation#121

Code

Open

afausti wants to merge 21 commits intomasterlsst-sqre/kafka-aggregator:masterfrom tickets/DM-31914lsst-sqre/kafka-aggregator:tickets/DM-31914Copy head branch name to clipboard

+474-436

Commits

Commits on Oct 4, 2021

• Move tumbling window test one level up

  Show description for 9fedc50
  afausti

  committed
  9fedc50

  Copy full SHA for 9fedc50

• Refactor kafka-aggregator example

  Show description for daf01e4
  afausti

  committed
  daf01e4

  Copy full SHA for daf01e4

• Update example configuration

  afausti

  committed
  4867e02

  Copy full SHA for 4867e02

• Add command line options for generate-agents

  Show description for 9fbb1d8
  afausti

  committed
  9fbb1d8

  Copy full SHA for 9fbb1d8

• Use config_file consistently

  afausti

  committed
  12b8cad

  Copy full SHA for 12b8cad

• Refactor topic_schema classes

  Show description for a89d316
  afausti

  committed
  a89d316

  Copy full SHA for a89d316

• Use the AggregatedTopic config object

  Show description for 9621444
  afausti

  committed
  9621444

  Copy full SHA for 9621444

• Refactor create_record_and_register() method

  afausti

  committed
  226dd6e

  Copy full SHA for 226dd6e

• Fix test_compute

  afausti

  committed
  23bb138

  Copy full SHA for 23bb138

• UnexpectedNumberOfTopicsError not needed anymore

  Show description for 56ab1fc
  afausti

  committed
  56ab1fc

  Copy full SHA for 56ab1fc

Commits on Oct 5, 2021

• Refactor AgentGenerator class

  Show description for 75d5e49
  afausti

  committed
  75d5e49

  Copy full SHA for 75d5e49

• Refactor agent template

  afausti

  committed
  25a421a

  Copy full SHA for 25a421a

• Update docs

  afausti

  committed
  de7aff6

  Copy full SHA for de7aff6

• Ignore Mac OS Finder .DS_Store files

  afausti

  committed
  02fa5ca

  Copy full SHA for 02fa5ca

• Get all source topics from the aggregator config

  afausti

  committed
  e245654

  Copy full SHA for e245654

• Refactor the example code

  Show description for 44c8ce9
  afausti

  committed
  44c8ce9

  Copy full SHA for 44c8ce9

Commits on Oct 6, 2021

• Rename field window_size to window_size_seconds

  afausti

  committed
  ba98f7b

  Copy full SHA for ba98f7b

• Add ability to filter field names

  Show description for aea62bc
  afausti

  committed
  aea62bc

  Copy full SHA for aea62bc

• Fixup field name

  afausti

  committed
  29d45e7

  Copy full SHA for 29d45e7

Commits on Mar 14, 2022

• Refactor example

  afausti

  committed
  377391f

  Copy full SHA for 377391f

• Update docs

  afausti

  committed
  366f0f9

  Copy full SHA for 366f0f9