Packages

  • package root
    Definition Classes
    root
  • package com
    Definition Classes
    root
  • package spotify
    Definition Classes
    com
  • package scio
    Definition Classes
    spotify
  • package annotations
    Definition Classes
    scio
  • package avro

    Main package for Avro APIs.

    Main package for Avro APIs. Import all.

    import com.spotify.scio.avro._
    Definition Classes
    scio
  • package bigquery

    Main package for BigQuery APIs.

    Main package for BigQuery APIs. Import all.

    import com.spotify.scio.bigquery._

    There are two BigQuery dialects, legacy and standard. APIs that take a BigQuery query string as argument, e.g. com.spotify.scio.bigquery.client.BigQuery.query.rows, com.spotify.scio.bigquery.client.BigQuery.query.schema, com.spotify.scio.bigquery.client.BigQuery.getTypedRows and BigQueryType.fromQuery, automatically detects the query's dialect. To override this, start the query with either #legacysql or #standardsql comment line.

    Definition Classes
    scio
  • package bigtable

    Main package for Bigtable APIs.

    Main package for Bigtable APIs. Import all.

    import com.spotify.scio.bigtable._
    Definition Classes
    scio
  • package cassandra

    Main package for Cassandra APIs.

    Main package for Cassandra APIs. Import all.

    import com.spotify.scio.cassandra._
    Definition Classes
    scio
  • package coders
    Definition Classes
    scio
  • package datastore
    Definition Classes
    scio
  • package elasticsearch

    Main package for Elasticsearch APIs.

    Main package for Elasticsearch APIs. Import all.

    import com.spotify.scio.elasticsearch._
    Definition Classes
    scio
  • package estimators
    Definition Classes
    scio
  • package extra
    Definition Classes
    scio
  • package grpc
    Definition Classes
    scio
  • package hash

    Main package for hash APIs.

    Main package for hash APIs. Import all.

    import com.spotify.scio.hash._
    Definition Classes
    scio
  • package iceberg

    Iceberg IO APIs.

    Iceberg IO APIs. Import all.

    import com.spotify.scio.iceberg._
    Definition Classes
    scio
  • package io
    Definition Classes
    scio
  • package jdbc

    Main package for JDBC APIs.

    Main package for JDBC APIs. Import all.

    import com.spotify.scio.jdbc._
    Definition Classes
    scio
  • package managed

    Managed IO APIs.

    Managed IO APIs. Import all.

    import com.spotify.scio.managed._
    Definition Classes
    scio
  • package metrics

    This package contains the schema types for metrics collected during a pipeline run.

    This package contains the schema types for metrics collected during a pipeline run.

    Definition Classes
    scio
  • package neo4j

    Main package for Neo4J APIs.

    Main package for Neo4J APIs. Import all.

    import com.spotify.scio.neo4j._
    Definition Classes
    scio
  • package options
    Definition Classes
    scio
  • package parquet
    Definition Classes
    scio
  • package protobuf
    Definition Classes
    scio
  • package pubsub
    Definition Classes
    scio
  • package redis
    Definition Classes
    scio
  • package instances
  • package syntax
  • package types
  • RedisConnectionOptions
  • RedisDoFn
  • RedisIO
  • RedisMutator
  • RedisRead
  • RedisWrite
  • package runners
    Definition Classes
    scio
  • package schemas
    Definition Classes
    scio
  • package smb
    Definition Classes
    scio
  • package snowflake

    Main package for Snowflake APIs.

    Main package for Snowflake APIs. Import all.

    import com.spotify.scio.snowflake._
    Definition Classes
    scio
  • package spanner
    Definition Classes
    scio
  • package tensorflow
    Definition Classes
    scio
  • package testing
    Definition Classes
    scio
  • package transforms

    Main package for transforms APIs.

    Main package for transforms APIs. Import all.

    Definition Classes
    scio
  • package util
    Definition Classes
    scio
  • package values
    Definition Classes
    scio

package redis

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. redis
  2. SCollectionSyntax
  3. ScioContextSyntax
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package instances
  2. package syntax
  3. package types

Type Members

  1. case class RedisConnectionOptions(host: String, port: Int, auth: Option[String] = None, useSSL: Boolean = false, timeout: Duration = Duration.standardSeconds(2)) extends Product with Serializable
  2. abstract class RedisDoFn[I, O] extends DoFn[I, O]
  3. sealed trait RedisIO[T] extends ScioIO[T]
  4. sealed abstract class RedisMutator[T] extends Serializable
  5. final case class RedisRead(connectionOptions: RedisConnectionOptions, keyPattern: String) extends RedisIO[(String, String)] with Product with Serializable
  6. final case class RedisWrite[T <: RedisMutation](connectionOptions: RedisConnectionOptions)(implicit evidence$1: RedisMutator[T]) extends RedisIO[T] with Product with Serializable

Value Members

  1. implicit def redisSCollectionOps[T <: RedisMutation](coll: SCollection[T])(implicit arg0: RedisMutator[T]): SCollectionRedisOps[T]
    Definition Classes
    SCollectionSyntax
  2. implicit def redisScioContextOps(sc: ScioContext): ScioContextOps
    Definition Classes
    ScioContextSyntax
  3. object RedisConnectionOptions extends Serializable
  4. object RedisMutator extends Serializable
  5. object RedisRead extends Serializable
  6. object RedisWrite extends Serializable

Inherited from SCollectionSyntax

Inherited from ScioContextSyntax

Inherited from AnyRef

Inherited from Any

Ungrouped