object PravegaTable
- Annotations
- @ApiMayChange()
- Source
- PravegaTable.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- PravegaTable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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].
- 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.
- 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.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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.