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

Class BigtableLookupConfig

java.lang.Object
io.github.flink.gcp.connector.bigtable.table.BigtableLookupConfig
All Implemented Interfaces:
Serializable
@Internal public final class BigtableLookupConfig extends Object implements Serializable
The lookup values a CREATE TABLE maps into the Bigtable table source.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.table.connector.source.lookup.cache.trigger.CacheReloadTrigger
    createFullReloadTrigger()
    Creates the configured full-cache reload trigger.
    org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache
    createPartialCache()
    Creates the partial cache from Flink's standard options.
    boolean
    equals(Object o)
     
    static BigtableLookupConfig
    from(org.apache.flink.configuration.ReadableConfig config)
    Maps the lookup options from the factory's validated configuration.
    org.apache.flink.table.connector.source.lookup.LookupOptions.LookupCacheType
    getCacheType()
    The standard Flink cache mode.
    int
    getMaxRetries()
    The number of retries after the initial point read.
    int
    hashCode()
     
    boolean
    isAsync()
    Whether the source should return an asynchronous lookup provider.

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • from

      public static BigtableLookupConfig from(org.apache.flink.configuration.ReadableConfig config)
      Maps the lookup options from the factory's validated configuration.

    • isAsync

      public boolean isAsync()
      Whether the source should return an asynchronous lookup provider.

    • getCacheType

      public org.apache.flink.table.connector.source.lookup.LookupOptions.LookupCacheType getCacheType()
      The standard Flink cache mode.

    • getMaxRetries

      public int getMaxRetries()
      The number of retries after the initial point read.

    • createPartialCache

      public org.apache.flink.table.connector.source.lookup.cache.DefaultLookupCache createPartialCache()
      Creates the partial cache from Flink's standard options.

    • createFullReloadTrigger

      public org.apache.flink.table.connector.source.lookup.cache.trigger.CacheReloadTrigger createFullReloadTrigger()
      Creates the configured full-cache reload trigger.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object