package redis
- Source
- package.scala
- Alphabetic
- By Inheritance
- redis
- SCollectionSyntax
- ScioContextSyntax
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- case class RedisConnectionOptions(host: String, port: Int, auth: Option[String] = None, useSSL: Boolean = false, timeout: Duration = Duration.standardSeconds(2)) extends Product with Serializable
- abstract class RedisDoFn[I, O] extends DoFn[I, O]
- sealed trait RedisIO[T] extends ScioIO[T]
- sealed abstract class RedisMutator[T] extends Serializable
- final case class RedisRead(connectionOptions: RedisConnectionOptions, keyPattern: String) extends RedisIO[(String, String)] with Product with Serializable
- final case class RedisWrite[T <: RedisMutation](connectionOptions: RedisConnectionOptions)(implicit evidence$1: RedisMutator[T]) extends RedisIO[T] with Product with Serializable
Value Members
- implicit def redisSCollectionOps[T <: RedisMutation](coll: SCollection[T])(implicit arg0: RedisMutator[T]): SCollectionRedisOps[T]
- Definition Classes
- SCollectionSyntax
- implicit def redisScioContextOps(sc: ScioContext): ScioContextOps
- Definition Classes
- ScioContextSyntax
- object RedisConnectionOptions extends Serializable
- object RedisMutator extends Serializable
- object RedisRead extends Serializable
- object RedisWrite extends Serializable