| Class | Description |
|---|---|
| AddShardKeyDoFn |
This class adds pseudo-key with a given cardinality.
|
| RecordToPublishResultDoFn |
This class just transforms to PublishResult to be able to capture the windowing with the right
strategy.
|
| SolaceOutput |
The
SolaceIO.Write transform's output return this type, containing the successful
publishes (SolaceOutput.getSuccessfulPublish()). |
| UnboundedBatchedSolaceWriter |
This DoFn is the responsible for writing to Solace in batch mode (holding up any messages), and
emit the corresponding output (success or fail; only for persistent messages), so the
SolaceIO.Write connector can be composed with other subsequent transforms in the pipeline.
|
| UnboundedSolaceWriter |
This DoFn encapsulates common code used both for the
UnboundedBatchedSolaceWriter and
UnboundedStreamingSolaceWriter. |
| UnboundedStreamingSolaceWriter |
This DoFn is the responsible for writing to Solace in streaming mode (one message at a time, not
holding up any message), and emit the corresponding output (success or fail; only for persistent
messages), so the SolaceIO.Write connector can be composed with other subsequent transforms in
the pipeline.
|