Code

Mqtt connector metadata#772

Code

Closed

vaibhawvipul wants to merge 41 commits intoArroyoSystems:masterArroyoSystems/arroyo:masterfrom vaibhawvipul:mqtt-connector-metadatavaibhawvipul/arroyo:mqtt-connector-metadataCopy head branch name to clipboard

+591-44

Commits

Commits on Oct 19, 2024

• adding metadata fn

  vaibhawvipul

  committed
  6658bb9

  Copy full SHA for 6658bb9

Commits on Oct 21, 2024

• Adding check if metadata column fn

  vaibhawvipul

  committed
  3bc6929

  Copy full SHA for 3bc6929

• remove log for debugs

  vaibhawvipul

  committed
  abff63a

  Copy full SHA for abff63a

Commits on Oct 23, 2024

• updating schema to columns

  vaibhawvipul

  committed
  440f700

  Copy full SHA for 440f700

Commits on Oct 24, 2024

• Adding validations and data to kafka messages

  vaibhawvipul

  committed
  3abecab

  Copy full SHA for 3abecab

• Merge branch 'master' into kafka-metadata

  vaibhawvipul

  committed
  b5ac3d4

  Copy full SHA for b5ac3d4

• fmt fixes

  vaibhawvipul

  committed
  cc8faaf

  Copy full SHA for cc8faaf

• fmt errors

  vaibhawvipul

  committed
  52041c4

  Copy full SHA for 52041c4

• fix clippy errors

  vaibhawvipul

  committed
  616b793

  Copy full SHA for 616b793

• fix clippy errors

  vaibhawvipul

  committed
  bdcad60

  Copy full SHA for bdcad60

• fix clippy

  vaibhawvipul

  committed
  74c4043

  Copy full SHA for 74c4043

• fmt fixes

  vaibhawvipul

  committed
  e342ed7

  Copy full SHA for e342ed7

• adding a check for json only

  vaibhawvipul

  committed
  167d3ac

  Copy full SHA for 167d3ac

Commits on Oct 25, 2024

• removing double serialization and adding values using array builders

  vaibhawvipul

  committed
  ec5c023

  Copy full SHA for ec5c023

• taking kafka metadata from configs

  vaibhawvipul

  committed
  4f39469

  Copy full SHA for 4f39469

• Merge branch 'ArroyoSystems:master' into kafka-metadata

  vaibhawvipul

  authored
  dc59fb6

  Copy full SHA for dc59fb6

• Merge branch 'kafka-metadata' of github.com:vaibhawvipul/arroyo into kafka-metadata

  vaibhawvipul

  committed
  dc59444

  Copy full SHA for dc59444

• adding enable_metadata flag to deser

  vaibhawvipul

  committed
  4f754a6

  Copy full SHA for 4f754a6

• fmt and clippy fixes

  vaibhawvipul

  committed
  53b6b83

  Copy full SHA for 53b6b83

• fmt fixes

  vaibhawvipul

  committed
  fc8b8cf

  Copy full SHA for fc8b8cf

• fmt fixes in planner

  vaibhawvipul

  committed
  b4c4815

  Copy full SHA for b4c4815

• fmt fixes in tables.rs

  vaibhawvipul

  committed
  c5af394

  Copy full SHA for c5af394

• clippy fixes

  vaibhawvipul

  committed
  9cd7c04

  Copy full SHA for 9cd7c04

Commits on Oct 27, 2024

• adding structs for better readability

  vaibhawvipul

  committed
  fca90ce

  Copy full SHA for fca90ce

• code refactor

  vaibhawvipul

  committed
  111e67c

  Copy full SHA for 111e67c

Commits on Oct 28, 2024

• code reformatting to address generic functionality

  vaibhawvipul

  committed
  efb3fbb

  Copy full SHA for efb3fbb

• Merge branch 'master' into kafka-metadata

  vaibhawvipul

  committed
  00afc89

  Copy full SHA for 00afc89

• bug fix

  vaibhawvipul

  committed
  3f3fe61

  Copy full SHA for 3f3fe61

• remove clippy warn hints

  vaibhawvipul

  committed
  65ea896

  Copy full SHA for 65ea896

• adding validations during planning

  vaibhawvipul

  committed
  737536a

  Copy full SHA for 737536a

Commits on Oct 29, 2024

• checking metadata columns have only a metadata function in themC

  vaibhawvipul

  committed
  6e047e8

  Copy full SHA for 6e047e8

• simplifying using if let in kafka connector

  vaibhawvipul

  committed
  c468d00

  Copy full SHA for c468d00

• fix clippy errors

  vaibhawvipul

  committed
  2dfe404

  Copy full SHA for 2dfe404

• code reformating for if let deserializer

  vaibhawvipul

  committed
  16e76ef

  Copy full SHA for 16e76ef

• adding if let in deserialize_single fn

  vaibhawvipul

  committed
  b3cd088

  Copy full SHA for b3cd088

• code reformat

  vaibhawvipul

  committed
  bcff0f0

  Copy full SHA for bcff0f0

• Merge branch 'master' into kafka-metadata

  vaibhawvipul

  committed
  970c090

  Copy full SHA for 970c090

• adding tests

  vaibhawvipul

  committed
  174835b

  Copy full SHA for 174835b

• adding validations for datatypes

  vaibhawvipul

  committed
  77f6a90

  Copy full SHA for 77f6a90

• bug fix in test

  vaibhawvipul

  committed
  66e996a

  Copy full SHA for 66e996a

• adding metadata mqtt

  vaibhawvipul

  committed
  11c4b66

  Copy full SHA for 11c4b66