Package org.apache.beam.sdk.io.singlestore

Interface SingleStoreIO.RowMapperWithCoder<T>

All Superinterfaces:
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
    Coder<T>
    getCoder()
     

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

    mapRow