Packages

package avro

Main package for Parquet Avro APIs. Import all.

import com.spotify.scio.parquet.avro._
Source
package.scala
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. avro
  2. Syntax
  3. SCollectionSyntax
  4. ScioContextSyntax
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package dynamic

    Parquet avro package for dynamic destinations.

    Parquet avro package for dynamic destinations. Import All.

    import com.spotify.scio.parquet.avro.dynamic._
  2. package syntax

Type Members

  1. class ParquetAvroFileBasedSink[T] extends FileBasedSink[T, Void, T]
  2. final case class ParquetAvroIO[T](path: String)(implicit evidence$1: ClassTag[T], evidence$2: Coder[T]) extends ScioIO[T] with Product with Serializable
  3. class ParquetAvroSink[T] extends Sink[T]
  4. final case class ParquetAvroTap[A, T](path: String, params: ReadParam[A, T])(implicit evidence$1: ClassTag[T], evidence$2: Coder[T]) extends Tap[T] with Product with Serializable

Value Members

  1. val Predicate: me.lyh.parquet.avro.Predicate.type

    Alias for me.lyh.parquet.avro.Predicate.

  2. val Projection: me.lyh.parquet.avro.Projection.type

    Alias for me.lyh.parquet.avro.Projection.

  3. implicit def parquetAvroFileToSCollection[T](self: ParquetAvroFile[T])(implicit arg0: Coder[T]): SCollection[T]
    Definition Classes
    ScioContextSyntax
  4. implicit def parquetAvroSCollection[T <: IndexedRecord](self: ParquetAvroFile[T])(implicit arg0: Coder[T]): SCollectionOps[T]
    Definition Classes
    SCollectionSyntax
  5. implicit def parquetAvroSCollectionOps[T <: IndexedRecord](c: SCollection[T]): SCollectionOps[T]
    Definition Classes
    SCollectionSyntax
  6. implicit def parquetAvroScioContextOps(c: ScioContext): ScioContextOps
    Definition Classes
    ScioContextSyntax
  7. object ParquetAvroIO extends Serializable

Inherited from Syntax

Inherited from SCollectionSyntax

Inherited from ScioContextSyntax

Inherited from AnyRef

Inherited from Any

Ungrouped