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

Interface SingleStoreIO.RowMapperWithInit<T>

All Superinterfaces:

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	Description
void	init(ResultSetMetaData resultSetMetaData)

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

mapRow

Method Details

init

void init(ResultSetMetaData resultSetMetaData)
   throws Exception

Throws:

Exception