Package org.apache.beam.sdk.extensions.sql

Interface BeamSqlSeekableTable

All Superinterfaces:
Serializable
public interface BeamSqlSeekableTable extends 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 Details

    • setUp

      default void setUp(Schema joinSubsetType)
      prepare the instance.
      Parameters:
      joinSubsetType - joining subset schema

    • startBundle

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

    • finishBundle

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

    • seekRow

      List<Row> seekRow(Row lookupSubRow)
      return a list of Row with given key set.

    • tearDown

      default void tearDown()
      cleanup resources of the instance.