Code

Refactor Kinesis IO#26117

Code

Merged

mosche merged 14 commits intoapache:masterapache/beam:masterfrom psolomin:refactor-kinesis-iopsolomin/beam:refactor-kinesis-ioCopy head branch name to clipboardApr 11, 2023

+1,303-765

Commits

Commits on Apr 11, 2023

• Make shard listing methods static

  psolomin

  committed
  8675cd9

• Move shard listing methods to a new class

  psolomin

  committed
  755fdaa

• Pass checkpoints instead of generators

  psolomin

  committed
  ee5c150

• Enhance checkpoint classes

  Show description for 6a1532b
  psolomin

  committed
  6a1532b

• Drop checkpoint generator classes

  psolomin

  committed
  de59090

• Add serialVersionUID for Source and IO.Read

  Show description for 986548f
  psolomin

  committed
  986548f

• Drop wornings suppression in KinesisSource

  psolomin

  committed
  a7aec74

• Add extended tests for Pool

  Show description for 4c8e395
  psolomin

  committed
  4c8e395

• Rename class

  psolomin

  committed
  41ac9ec

• Rename functions which create test records

  psolomin

  committed
  83d42b9

• Switch logging of requests to debug

  psolomin

  committed
  233b158

• Add tests for exception handling

  psolomin

  committed
  e75de96

• Keep wrapping exceptions only in SimplifiedKinesisClient

  psolomin

  committed
  894a226

• Drop redundant tests

  Show description for 25a6af1
  psolomin

  committed
  25a6af1