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

package org.apache.beam.sdk.io.singlestore

Transforms for reading and writing from SingleStoreDB.

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.singlestore.schematransform	SingleStoreIO SchemaTransforms.

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.Read.SingleStoreRowMapperInitializationException
SingleStoreIO.ReadWithPartitions<T>	A PTransform for reading data from SingleStoreDB.
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.
SingleStoreIO.Write<T>	A PTransform for writing data to SingleStoreDB.