org.apache.beam.sdk.io.singlestore

Interface SingleStoreIO.RowMapper<T>

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

SingleStoreIO.RowMapperWithCoder<T>, SingleStoreIO.RowMapperWithInit<T>

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.RowMapper<T>
extends java.io.Serializable

An interface used by SingleStoreIO.Read and SingleStoreIO.ReadWithPartitions for converting each row of the ResultSet into an element of the resulting PCollection.

Method Summary

Modifier and Type	Method and Description
T	mapRow(java.sql.ResultSet resultSet)

Method Detail

mapRow

T mapRow(java.sql.ResultSet resultSet)
  throws java.lang.Exception

Throws:

java.lang.Exception