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

CoderInstances

ElasticsearchIO

ElasticsearchOptions

ElasticsearchSCollection

IndexAdmin

package estimators

Definition Classes: scio

package extra

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.

Definition Classes: scio

package options

Definition Classes: scio

package parquet

Definition Classes: scio

package pubsub

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

com.spotify.scio

elasticsearch

package elasticsearch

Main package for Elasticsearch APIs. Import all.

import com.spotify.scio.elasticsearch._

Linear Supertypes

CoderInstances, AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

elasticsearch
CoderInstances
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Type Members

trait CoderInstances extends AnyRef
final case class ElasticsearchIO[T](esOptions: ElasticsearchOptions) extends ScioIO[T] with Product with Serializable
final case class ElasticsearchOptions(clusterName: String, servers: Seq[InetSocketAddress]) extends Product with Serializable
implicit final class ElasticsearchSCollection[T] extends AnyVal

Value Members

implicit val deleteRequestCoder: Coder[DeleteRequest]
Definition Classes
CoderInstances
implicit val docWriteRequestCoder: Coder[DocWriteRequest[_]]
Definition Classes
CoderInstances
implicit val indexRequestCoder: Coder[IndexRequest]
Definition Classes
CoderInstances
implicit val updateRequestCoder: Coder[UpdateRequest]
Definition Classes
CoderInstances
object ElasticsearchIO extends Serializable
object IndexAdmin

Packages

elasticsearch

package elasticsearch

Type Members

Value Members

Inherited from CoderInstances

Inherited from AnyRef

Inherited from Any

Ungrouped

Packages

elasticsearch

package elasticsearch

Type Members

Value Members

Inherited from CoderInstances

Inherited from AnyRef

Inherited from Any

Ungrouped

elasticsearch