Code

SolaceIO write connector#32060

Code

Merged

Abacn merged 30 commits intoapache:masterapache/beam:masterfrom iht:solace_writer_finalpriht/beam:solace_writer_finalprCopy head branch name to clipboardNov 13, 2024

+2,508-392

Commits

Commits on Nov 12, 2024

• This is a follow-up PR to apache#31953, and part of the issue apache#31905.

  Show description for dba27f5
  

  iht

  authored and

  bzablocki

  committed
  dba27f5

  Copy full SHA for dba27f5

• Use static imports for Preconditions

  

  iht

  authored and

  bzablocki

  committed
  dc044b9

  Copy full SHA for dc044b9

• Remove unused method

  

  iht

  authored and

  bzablocki

  committed
  0bd77d0

  Copy full SHA for 0bd77d0

• Logging has builtin formatting support

  

  iht

  authored and

  bzablocki

  committed
  5249d9e

  Copy full SHA for 5249d9e

• Use TypeDescriptors to check the type used as input

  

  iht

  authored and

  bzablocki

  committed
  4681a07

  Copy full SHA for 4681a07

• Fix parameter name

  

  iht

  authored and

  bzablocki

  committed
  99d9993

  Copy full SHA for 99d9993

• Use interface + utils class for MessageProducer

  

  iht

  authored and

  bzablocki

  committed
  048de8a

  Copy full SHA for 048de8a

• Use null instead of optional

  

  iht

  authored and

  bzablocki

  committed
  bbeaff4

  Copy full SHA for bbeaff4

• Avoid using ByteString just to create an empty byte array.

  

  iht

  authored and

  bzablocki

  committed
  3ab4d0b

  Copy full SHA for 3ab4d0b

• Fix documentation, we are not using ByteString now.

  

  iht

  authored and

  bzablocki

  committed
  cd01cff

  Copy full SHA for cd01cff

• Not needed anymore, we are not using ByteString

  

  iht

  authored and

  bzablocki

  committed
  f6d1f1e

  Copy full SHA for f6d1f1e

• Defer transforming latency from nanos to millis.

  Show description for ce1327b
  

  iht

  authored and

  bzablocki

  committed
  ce1327b

  Copy full SHA for ce1327b

• Avoid using top level classes with a single inner class.

  Show description for af28bde
  

  iht

  authored and

  bzablocki

  committed
  af28bde

  Copy full SHA for af28bde

• Remove using a state variable, there is already a timer.

  Show description for e5521ae
  

  iht

  authored and

  bzablocki

  committed
  e5521ae

  Copy full SHA for e5521ae

• Properties must always be set.

  Show description for 19ade8a
  

  iht

  authored and

  bzablocki

  committed
  19ade8a

  Copy full SHA for 19ade8a

• Add a new custom mode so no JCSMP property is overridden.

  Show description for 26c9d48
  

  iht

  authored and

  bzablocki

  committed
  26c9d48

  Copy full SHA for 26c9d48

• Add some more documentation about the new custom submission mode.

  

  iht

  authored and

  bzablocki

  committed
  997fe56

  Copy full SHA for 997fe56

• Fix bug introduced with the refactoring of code for this PR.

  Show description for 251f14d
  

  iht

  authored and

  bzablocki

  committed
  251f14d

  Copy full SHA for 251f14d

• Remove unnecessary Serializable annotation.

  

  iht

  authored and

  bzablocki

  committed
  a7a5eff

  Copy full SHA for a7a5eff

• Make the PublishResult class for handling callbacks non-static to handle pipelines with multiple write transforms.

  bzablocki

  committed
  29ed200

  Copy full SHA for 29ed200

• Rename maxNumOfUsedWorkers to numShards

  bzablocki

  committed
  ff5f09a

  Copy full SHA for ff5f09a

• Use RoundRobin assignment of producers to process bundles.

  bzablocki

  committed
  33d1771

  Copy full SHA for 33d1771

• Output results in a GlobalWindow

  bzablocki

  committed
  fe8b3ca

  Copy full SHA for fe8b3ca

• Add ErrorHandler

  bzablocki

  committed
  ad5c45b

  Copy full SHA for ad5c45b

• Fix docs

  bzablocki

  committed
  6a8b9ce

  Copy full SHA for 6a8b9ce

• Remove PublishResultHandler class that was just a wrapper around a Queue

  bzablocki

  committed
  44059c8

  Copy full SHA for 44059c8

• small refactors

  bzablocki

  committed
  602e85b

  Copy full SHA for 602e85b

• Revert CsvIO docs fix

  bzablocki

  committed
  f31a320

  Copy full SHA for f31a320

• Add withErrorHandler docs

  bzablocki

  committed
  4dddd33

  Copy full SHA for 4dddd33

• fix var scope

  bzablocki

  committed
  4f9c024

  Copy full SHA for 4f9c024