org.apache.beam.sdk.extensions.sql

Interface BeamSqlSeekableTable

All Superinterfaces:

java.io.Serializable

@Experimental
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
java.util.List<BeamRecord>	seekRecord(BeamRecord lookupSubRecord) return a list of BeamRecord with given key set.

Method Detail

seekRecord

java.util.List<BeamRecord> seekRecord(BeamRecord lookupSubRecord)

return a list of BeamRecord with given key set.