Package com.here.platform.data.client.flink.javadsl

Class FlinkDataClient

java.lang.Object
com.here.platform.data.client.flink.javadsl.FlinkDataClient
public final class FlinkDataClient extends Object

  • Constructor Details

    • FlinkDataClient

      public FlinkDataClient()

  • Method Details

    • adminApi

      public FlinkAdminApi adminApi()
      Create a catalog admin API object
      Returns:
      catalog admin API

    • adminApi

      public FlinkAdminApi adminApi(Settings settings)
      Create a catalog admin API object
      Parameters:
      settings - setting to be used while using admin API
      Returns:
      catalog admin API

    • defaultSettings

      public Settings defaultSettings()
      Default setting which will be used if no overrides is provided

    • invalidateCache

      public void invalidateCache(HRN hrn)
      Invalidate internal caches for catalog

      Parameters:
      hrn - catalog identifier

    • publishApi

      public FlinkPublishApi publishApi(HRN hrn)
      Create a catalog publish API object
      Parameters:
      hrn - catalog identifier
      Returns:
      catalog publish API if catalog exists, return error if catalog does not exists

    • publishApi

      public FlinkPublishApi publishApi(HRN hrn, Settings settings)
      Create a catalog publish API object
      Parameters:
      hrn - catalog identifier
      settings - setting to be used while using publish API
      Returns:
      catalog publish API if catalog exists, return error if catalog does not exists

    • queryApi

      public FlinkQueryApi queryApi(HRN hrn)
      Create a catalog query API object
      Parameters:
      hrn - catalog identifier
      Returns:
      catalog query API if catalog exists, return error if catalog does not exists

    • queryApi

      public FlinkQueryApi queryApi(HRN hrn, Settings settings)
      Create a catalog query API object
      Parameters:
      hrn - catalog identifier
      settings - setting to be used while using query API
      Returns:
      catalog query API if catalog exists, return error if catalog does not exists

    • readEngine

      public FlinkReadEngine readEngine(HRN hrn)
      Read engine supporting read operations in Flink from underlying storage
      Parameters:
      hrn - catalog identifier

    • readEngine

      public FlinkReadEngine readEngine(HRN hrn, Settings settings)
      Read engine supporting read operations in Flink from underlying storage
      Parameters:
      hrn - catalog identifier
      settings - DataClient settings

    • terminate

      public void terminate()
      Terminates the underlying context

    • writeEngine

      public FlinkWriteEngine writeEngine(HRN hrn)
      Write engine supporting write operations from Flink to the underlying storage
      Parameters:
      hrn - catalog identifier

    • writeEngine

      public FlinkWriteEngine writeEngine(HRN hrn, Settings settings)
      Write engine supporting write operations from Flink to the underlying storage
      Parameters:
      hrn - catalog identifier
      settings - DataClient settings

    • writeEngine

      public FlinkWriteEngine writeEngine(HRN hrn, BlobIdGenerator blobIdGenerator)
      Write engine supporting write operations from Flink to the underlying storage
      Parameters:
      hrn - catalog identifier
      blobIdGenerator - blobId generator

    • writeEngine

      public FlinkWriteEngine writeEngine(HRN hrn, BlobIdGenerator blobIdGenerator, Settings settings)
      Write engine supporting write operations from Flink to the underlying storage
      Parameters:
      hrn - catalog identifier
      blobIdGenerator - blobId generator
      settings - DataClient settings