org.apache.beam.sdk.io.singlestore

Interface SingleStoreIO.UserDataMapper<T>

All Superinterfaces:

java.io.Serializable

Enclosing class:

SingleStoreIO

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface SingleStoreIO.UserDataMapper<T>
extends java.io.Serializable

An interface used by the SingleStoreIO SingleStoreIO.Write to map a data from each element of PCollection to a List of Strings. Returned values are used to send LOAD DATA SQL queries to the database.

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	mapRow(T element)

Method Detail

mapRow

java.util.List<java.lang.String> mapRow(T element)