Packages

package scaladsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait FlinkAdminApi extends AnyRef

    Maintain catalogs and their configuration.

  2. final class FlinkDataClient extends AnyRef
  3. class FlinkKafkaPublisher extends Serializable

    Use this class for manually managing publishing to a stream layer.

    Use this class for manually managing publishing to a stream layer. Requires call terminate method after multiple usage of publish method.

  4. trait FlinkPublishApi extends AnyRef
  5. trait FlinkQueryApi extends AnyRef
  6. trait FlinkReadEngine extends AnyRef
  7. trait FlinkWriteEngine extends AnyRef
  8. class GetChangesFlatMap extends RichFlatMapFunction[String, Partition]
  9. class GetPartitionsFlatMap extends RichFlatMapFunction[String, Partition]
  10. class OlpStreamConnectorHelper extends AnyRef
  11. case class PartWithTimestamp(partId: String, timestamp: Long) extends Product with Serializable
  12. class QueryIndexPartitionFlatMap extends RichFlatMapFunction[String, IndexPartition]

Value Members

  1. object FlinkKafkaPublisher extends Serializable

    Publish new partitions to a stream layer.

  2. object InteractiveMapProviderFactory
  3. object OlpStreamConnectorHelper

Ungrouped