Code

Refactor into Writer and Committer#234

Code

Merged

fqtab merged 12 commits intomaindatabricks/iceberg-kafka-connect:mainfrom refactor_writer_commiter_interfacedatabricks/iceberg-kafka-connect:refactor_writer_commiter_interfaceCopy head branch name to clipboardApr 25, 2024

+1,467-417

Commits

Commits on Apr 17, 2024

• Refactor into Writer and Committer

  fqaiser94

  committed
  7d6082e

  Copy full SHA for 7d6082e

Commits on Apr 18, 2024

• Undo Worker changes

  fqaiser94

  committed
  2743522

  Copy full SHA for 2743522

• Undo KafkaClientFactory changes

  fqaiser94

  committed
  a15fbf3

  Copy full SHA for a15fbf3

• Undo Channel changes

  fqaiser94

  committed
  1bd2488

  Copy full SHA for 1bd2488

Commits on Apr 19, 2024

• Add Task (public interface) and TaskImpl

  fqaiser94

  committed
  d0de921

  Copy full SHA for d0de921

Commits on Apr 23, 2024

• minor

  fqaiser94

  committed
  3df51c8

  Copy full SHA for 3df51c8

Commits on Apr 24, 2024

• Avoid not-strictly-necessary Catalog initialization change for now

  fqaiser94

  committed
  8a623bd

  Copy full SHA for 8a623bd

• Avoid unnecessary Channel changes

  fqaiser94

  committed
  da13bea

  Copy full SHA for da13bea

• Avoid unnecessary Worker changes

  fqaiser94

  committed
  b73848f

  Copy full SHA for b73848f

• Clean up tests

  fqaiser94

  committed
  dacb536

  Copy full SHA for dacb536

• Avoid unnecessary CoordinatorThread initialization change

  fqaiser94

  committed
  2acc71e

  Copy full SHA for 2acc71e

• Minor: avoid exposing Catalog in TaskImpl constructor

  fqaiser94

  committed
  669a79a

  Copy full SHA for 669a79a