org.apache.beam.sdk.extensions.sql

Interface BeamSqlSeekableTable

All Superinterfaces:

java.io.Serializable

public interface BeamSqlSeekableTable
extends java.io.Serializable

A seekable table converts a JOIN operator to an inline lookup. It's triggered by SELECT * FROM FACT_TABLE JOIN LOOKUP_TABLE ON ....

Method Summary

Modifier and Type	Method and Description
default void	finishBundle(DoFn.FinishBundleContext context, PipelineOptions pipelineOptions)
java.util.List<Row>	seekRow(Row lookupSubRow) return a list of Row with given key set.
default void	setUp(Schema joinSubsetType) prepare the instance.
default void	startBundle(DoFn.StartBundleContext context, PipelineOptions pipelineOptions)
default void	tearDown() cleanup resources of the instance.

Method Detail

setUp

default void setUp(Schema joinSubsetType)

prepare the instance.

Parameters:

joinSubsetType - joining subset schema

startBundle

default void startBundle(DoFn.StartBundleContext context,
                         PipelineOptions pipelineOptions)

finishBundle

default void finishBundle(DoFn.FinishBundleContext context,
                          PipelineOptions pipelineOptions)

seekRow

java.util.List<Row> seekRow(Row lookupSubRow)

return a list of Row with given key set.

tearDown

default void tearDown()

cleanup resources of the instance.