Packages

final class FlinkDataClient extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FlinkDataClient
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new FlinkDataClient()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def adminApi(settings: Settings = defaultSettings): FlinkAdminApi

    Create a catalog and configuration administration API object

    Create a catalog and configuration administration API object

    settings

    setting to be used while using admin API

    returns

    catalog admin API

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  7. val defaultSettings: Settings

    Default setting which will be used if no overrides is provided

  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def invalidateCache(hrn: HRN): Unit

    Invalidate internal caches for catalog

    Invalidate internal caches for catalog

    hrn

    catalog identifier

  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  17. def publishApi(hrn: HRN, settings: Settings = defaultSettings): FlinkPublishApi

    Create a catalog publish API object

    Create a catalog publish API object

    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

  18. def queryApi(hrn: HRN, settings: Settings = defaultSettings): FlinkQueryApi

    Create a catalog query API object

    Create a catalog query API object

    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

  19. def readEngine(hrn: HRN, settings: Settings = defaultSettings): FlinkReadEngine

    Read engine supporting read operations in Flink from underlying storage

    Read engine supporting read operations in Flink from underlying storage

    hrn

    catalog identifier

    settings

    DataClient settings

  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def terminate(): Unit

    Terminates the underlying context

  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. def writeEngine(hrn: HRN, blobIdGenerator: BlobIdGenerator = new UUIDBlobIdGenerator(), settings: Settings = defaultSettings): FlinkWriteEngine

    Write engine supporting write operations from Flink to the underlying storage

    Write engine supporting write operations from Flink to the underlying storage

    hrn

    catalog identifier

    settings

    DataClient settings

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped