package avro
Main package for Parquet Avro APIs. Import all.
import com.spotify.scio.parquet.avro._- Source
- package.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- avro
- Syntax
- SCollectionSyntax
- ScioContextSyntax
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Package Members
Type Members
- class ParquetAvroFileBasedSink[T] extends FileBasedSink[T, Void, T]
- final case class ParquetAvroIO[T](path: String)(implicit evidence$1: ClassTag[T], evidence$2: Coder[T]) extends ScioIO[T] with Product with Serializable
- class ParquetAvroSink[T] extends Sink[T]
- 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
- val Predicate: me.lyh.parquet.avro.Predicate.type
Alias for
me.lyh.parquet.avro.Predicate. - val Projection: me.lyh.parquet.avro.Projection.type
Alias for
me.lyh.parquet.avro.Projection. - implicit def parquetAvroFileToSCollection[T](self: ParquetAvroFile[T])(implicit arg0: Coder[T]): SCollection[T]
- Definition Classes
- ScioContextSyntax
- implicit def parquetAvroSCollection[T <: IndexedRecord](self: ParquetAvroFile[T])(implicit arg0: Coder[T]): SCollectionOps[T]
- Definition Classes
- SCollectionSyntax
- implicit def parquetAvroSCollectionOps[T <: IndexedRecord](c: SCollection[T]): SCollectionOps[T]
- Definition Classes
- SCollectionSyntax
- implicit def parquetAvroScioContextOps(c: ScioContext): ScioContextOps
- Definition Classes
- ScioContextSyntax
- object ParquetAvroIO extends Serializable