org.apache.beam.sdk.io.singlestore

Interface SingleStoreIO.RowMapperWithInit<T>

All Superinterfaces:

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

Enclosing class:

SingleStoreIO

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

A RowMapper that requires initialization. init method is called during pipeline construction time.

Method Summary

Modifier and Type	Method and Description
void	init(java.sql.ResultSetMetaData resultSetMetaData)

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

mapRow

Method Detail

init

void init(java.sql.ResultSetMetaData resultSetMetaData)
   throws java.lang.Exception

Throws:

java.lang.Exception