Package 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

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method Description
      default void finishBundle​(org.apache.beam.sdk.transforms.DoFn.FinishBundleContext context, org.apache.beam.sdk.options.PipelineOptions pipelineOptions)  
      java.util.List<org.apache.beam.sdk.values.Row> seekRow​(org.apache.beam.sdk.values.Row lookupSubRow)
      return a list of Row with given key set.
      default void setUp​(org.apache.beam.sdk.schemas.Schema joinSubsetType)
      prepare the instance.
      default void startBundle​(org.apache.beam.sdk.transforms.DoFn.StartBundleContext context, org.apache.beam.sdk.options.PipelineOptions pipelineOptions)  
      default void tearDown()
      cleanup resources of the instance.

    • Method Detail

      • setUp

        default void setUp​(org.apache.beam.sdk.schemas.Schema joinSubsetType)
        prepare the instance.
        Parameters:
        joinSubsetType - joining subset schema

      • startBundle

        default void startBundle​(org.apache.beam.sdk.transforms.DoFn.StartBundleContext context,
                         org.apache.beam.sdk.options.PipelineOptions pipelineOptions)

      • finishBundle

        default void finishBundle​(org.apache.beam.sdk.transforms.DoFn.FinishBundleContext context,
                          org.apache.beam.sdk.options.PipelineOptions pipelineOptions)

      • seekRow

        java.util.List<org.apache.beam.sdk.values.Row> seekRow​(org.apache.beam.sdk.values.Row lookupSubRow)
        return a list of Row with given key set.

      • tearDown

        default void tearDown()
        cleanup resources of the instance.