Packages

object PravegaTable

Annotations
@ApiMayChange()
Source
PravegaTable.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PravegaTable
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def readFlow[K, V](scope: String, tableName: String, tableSettings: TableSettings[K, V]): Flow[K, Option[V], NotUsed]

    A flow from key to and Option[value].

  2. def sink[K, V](scope: String, tableName: String, tableWriterSettings: TableWriterSettings[K, V]): Sink[(K, V), Future[Done]]

    Incoming messages are written to a Pravega table KV.

  3. def source[K, V](scope: String, tableName: String, tableReaderSettings: TableReaderSettings[K, V]): Source[TableEntry[V], Future[Done]]

    Messages are read from a Pravega stream.

    Messages are read from a Pravega stream.

    Materialized value is a Future which completes to Done as soon as the Pravega reader is open.

  4. def writeFlow[K, V](scope: String, tableName: String, tableWriterSettings: TableWriterSettings[K, V]): Flow[(K, V), (K, V), NotUsed]

    Keys and values are extracted from incoming messages and written to Pravega table.

    Keys and values are extracted from incoming messages and written to Pravega table. Messages are emitted downstream unchanged.