Package 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	Description
org.apache.beam.sdk.coders.Coder<T>	getCoder()

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

mapRow

Method Detail

getCoder

org.apache.beam.sdk.coders.Coder<T> getCoder()
                                      throws java.lang.Exception

Throws:

java.lang.Exception