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

Transforms for reading and writing from SingleStoreDB.

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.RowMapperWithCoder<T>	A RowMapper that provides a Coder for resulting PCollection.
SingleStoreIO.RowMapperWithInit<T>	A RowMapper that requires initialization.
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.

Exception Summary

Exception	Description
SingleStoreIO.Read.SingleStoreRowMapperInitializationException