@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.singlestore

Transforms for reading and writing from SingleStoreDB.

See: Description

Interface Summary

Interface	Description
SingleStoreIO.RowMapper<T>	An interface used by SingleStoreIO.Read and SingleStoreIO.ReadWithPartitions for converting each row of the ResultSet into an element of the resulting PCollection.
SingleStoreIO.StatementPreparator	An interface used by the SingleStoreIO SingleStoreIO.Read to set the parameters of the PreparedStatement.
SingleStoreIO.UserDataMapper<T>	An interface used by the SingleStoreIO SingleStoreIO.Write to map a data from each element of PCollection to a List of Strings.

Class Summary

Class	Description
SingleStoreIO	IO to read and write data on SingleStoreDB.
SingleStoreIO.DataSourceConfiguration	A POJO describing a SingleStoreDB DataSource by providing all properties needed to create it.
SingleStoreIO.Read<T>	A PTransform for reading data from SingleStoreDB.
SingleStoreIO.ReadWithPartitions<T>	A PTransform for reading data from SingleStoreDB.
SingleStoreIO.Write<T>	A PTransform for writing data to SingleStoreDB.

Package org.apache.beam.sdk.io.singlestore Description

Transforms for reading and writing from SingleStoreDB.