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

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

Class	Description
AsyncLookupRetries	Retries an asynchronous Table API lookup and converts its successful result to rows.
AsyncLookupRetries.RowConverter<T>	Converts a client value to rows, allowing a deserializer's checked exception.
LookupKeyFilter	Separates an addressing key from additional equality keys on the produced physical row.
LookupKeyFilter.FilteringAsyncLookupFunction	Public because Flink requires the provided function class to be public.
LookupKeyFilter.FilteringLookupFunction	Public because Flink requires the provided function class to be public.
OptionSetters	Applies Table API option values to DataStream builder setters, renaming a rejected value's failure to the option key the SQL caller actually wrote (issue #1030, ADR-0133).