Package io.github.flink.gcp.connector.base.table

Interface AsyncLookupRetries.RowConverter<T>

Enclosing class:

AsyncLookupRetries

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@Internal
@FunctionalInterface
public static interface AsyncLookupRetries.RowConverter<T>

Converts a client value to rows, allowing a deserializer's checked exception.

Method Summary

Modifier and Type	Method	Description
Collection<org.apache.flink.table.data.RowData>	convert(T value)	Converts the value; a connector may represent a missing row with null.

Method Details

convert

Collection<org.apache.flink.table.data.RowData> convert(@Nullable
 T value)
                                                 throws Exception

Converts the value; a connector may represent a missing row with null.

Throws:

Exception