ZIO Pravega
0.11.2+6-0241b274-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER
ZIO Pravega/zio/zio.pravega/PravegaTable

PravegaTable

zio.pravega.PravegaTable
See thePravegaTable companion object
trait PravegaTable

Pravega Table API.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def get[K, V](tableName: String, key: K, settings: TableReaderSettings[K, V]): Task[Option[V]]

Get a value from a Pravega table.

Get a value from a Pravega table.

Attributes

def merge[K, V](tableName: String, key: K, value: V, combine: (V, V) => V, settings: TableWriterSettings[K, V]): Task[V]

Upsert a value in a Pravega table, may overwrite existing values.

Upsert a value in a Pravega table, may overwrite existing values.

Attributes

def openTable[K, V](tableName: String, tableSetting: TableSettings[K, V]): ZIO[Scope, Throwable, PravegaKeyValueTable[K, V]]

Connect to a Pravega table.

Connect to a Pravega table.

The table is closed when the scope is closed.

Attributes

def put[K, V](tableName: String, key: K, value: V, settings: TableWriterSettings[K, V]): Task[Unit]

Insert a value in a Pravega table, may overwrite existing values.

Insert a value in a Pravega table, may overwrite existing values.

Attributes

def readerFlow[K, V](tableName: String, settings: TableReaderSettings[K, V]): ZPipeline[Any, Throwable, K, Option[TableEntry[V]]]

Create a reader flow, which reads from a KVP Pravega table.

Create a reader flow, which reads from a KVP Pravega table.

The reader flow emits an optional value, which is None if the key is not found.

Attributes

def sink[K, V](tableName: String, settings: TableWriterSettings[K, V], combine: (V, V) => V): ZSink[Any, Throwable, (K, V), Nothing, Unit]

Create a sink to write to a KVP Pravega table.

Create a sink to write to a KVP Pravega table.

A @combine function is used to merge old and new entries.

Attributes

def source[K, V](tableName: String, settings: TableReaderSettings[K, V]): ZStream[Any, Throwable, TableEntry[V]]

Create a reader source, which reads from a KVP Pravega table.

Create a reader source, which reads from a KVP Pravega table.

Read entries are emitted in chunks.

Attributes

def writerFlow[K, V](tableName: String, settings: TableWriterSettings[K, V], combine: (V, V) => V): ZPipeline[Any, Throwable, (K, V), (K, V)]

Create a writer flow to a KVP Pravega table.

Create a writer flow to a KVP Pravega table.

A @combine function is used to merge old and new entries, and new values are emitted.

Attributes

Generated with
Copyright (c) 2022-2024, Olivier NOUGUIER
Copyright (c) 2022-2024, Olivier NOUGUIER