Package org.apache.beam.sdk.io.solace.write
package org.apache.beam.sdk.io.solace.write
SolaceIO Write connector.
-
ClassesClassDescriptionThis class adds pseudo-key with a given cardinality.This class just transforms to PublishResult to be able to capture the windowing with the right strategy.The
SolaceIO.Writetransform's output return this type, containing the successful publishes (SolaceOutput.getSuccessfulPublish()).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.This DoFn encapsulates common code used both for theUnboundedBatchedSolaceWriterandUnboundedStreamingSolaceWriter.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.