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 Detail

      • mapRow

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