Package org.apache.beam.sdk.io.solace

package org.apache.beam.sdk.io.solace

Solace IO connector.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.
org.apache.beam.sdk.io.solace.broker	Solace IO broker-related classes.
org.apache.beam.sdk.io.solace.data	Solace IO connector - data-related classes.
org.apache.beam.sdk.io.solace.read	Solace IO connector - read connector classes.
org.apache.beam.sdk.io.solace.write	SolaceIO Write connector.

Class	Description
RetryCallableManager	A class that manages retrying of callables based on the exceptions they throw.
RetryCallableManager.Builder
SolaceIO	A PTransform to read and write from/to Solace event broker.
SolaceIO.Read<T>
SolaceIO.SubmissionMode
SolaceIO.Write<T>
SolaceIO.WriterType