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 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 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 syntax
  • Neo4jConnectionOptions
  • Neo4jIO
  • Neo4jOptions
  • 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 runners
    Definition Classes
    scio
  • package schemas
    Definition Classes
    scio
  • package smb
    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 neo4j

Main package for Neo4J APIs. Import all.

import com.spotify.scio.neo4j._
Source
package.scala
Linear Supertypes
AllSyntax, SCollectionSyntax, ScioContextSyntax, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. neo4j
  2. AllSyntax
  3. SCollectionSyntax
  4. ScioContextSyntax
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package syntax

Type Members

  1. final case class Neo4jConnectionOptions(url: String, username: String, password: String) extends Product with Serializable

    Options for a Neo4J connection.

    Options for a Neo4J connection.

    url

    connection url, e.g. "neo4j://neo4j.com:7687"

    username

    login username

    password

    login password

  2. final case class Neo4jIO[T](neo4jOptions: Neo4jOptions, cypher: String)(implicit neo4jType: ValueType[T], coder: Coder[T]) extends ScioIO[T] with Product with Serializable
  3. final case class Neo4jOptions(connectionOptions: Neo4jConnectionOptions, sessionConfig: SessionConfig = Neo4jOptions.BeamDefaultSessionConfig, transactionConfig: TransactionConfig = Neo4jOptions.BeamDefaultTransactionConfig) extends Product with Serializable

    Options for configuring a Neo4J driver.

    Options for configuring a Neo4J driver.

    connectionOptions

    connection options

    sessionConfig

    org.neo4j.driver.SessionConfig for specifying Neo4J driver session config

    transactionConfig

    org.neo4j.driver.TransactionConfig for specifying Neo4J driver transaction config

Value Members

  1. implicit def neo4jSCollectionOps[T](sc: SCollection[T]): Neo4jSCollectionOps[T]
    Definition Classes
    SCollectionSyntax
  2. implicit def neo4jScioContextOps(sc: ScioContext): Neo4jScioContextOps
    Definition Classes
    ScioContextSyntax
  3. object Neo4jIO extends Serializable
  4. object Neo4jOptions extends Serializable

Inherited from AllSyntax

Inherited from SCollectionSyntax

Inherited from ScioContextSyntax

Inherited from AnyRef

Inherited from Any

Ungrouped