org.apache.beam.sdk.io.singlestore

Interface SingleStoreIO.RowMapperWithCoder<T>

All Superinterfaces:

java.io.Serializable, SingleStoreIO.RowMapper<T>

Enclosing class:

SingleStoreIO

public static interface SingleStoreIO.RowMapperWithCoder<T>
extends SingleStoreIO.RowMapper<T>

A RowMapper that provides a Coder for resulting PCollection.

Method Summary

Modifier and Type	Method and Description
Coder<T>	getCoder()

Methods inherited from interface org.apache.beam.sdk.io.singlestore.SingleStoreIO.RowMapper

mapRow

Method Detail

getCoder

Coder<T> getCoder()
           throws java.lang.Exception

Throws:

java.lang.Exception