package bigtable
Main package for Bigtable APIs. Import all.
import com.spotify.scio.bigtable._- Source
- package.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- bigtable
- AllSyntax
- RowSyntax
- ScioContextSyntax
- SCollectionSyntax
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- abstract class BigtableBatchDoFn[Input, BatchRequest, BatchResponse, Result] extends GuavaAsyncBatchLookupDoFn[Input, BatchRequest, BatchResponse, Result, BigtableSession]
A
DoFnwhich batches elements and performs asynchronous lookup for them using Google Cloud Bigtable. - class BigtableBulkWriter extends PTransform[PCollection[KV[ByteString, Iterable[Mutation]]], PDone]
- abstract class BigtableDoFn[A, B] extends GuavaAsyncLookupDoFn[A, B, BigtableSession]
A
DoFnthat performs asynchronous lookup using Google Cloud Bigtable. - sealed trait BigtableIO[T] extends ScioIO[T]
- final case class BigtableRead(bigtableOptions: BigtableOptions, tableId: String) extends BigtableIO[Row] with Product with Serializable
- final class BigtableUtil extends AnyRef
Utilities to deal with Bigtable.
- final case class BigtableWrite[T <: Mutation](bigtableOptions: BigtableOptions, tableId: String) extends BigtableIO[(ByteString, Iterable[T])] with Product with Serializable
- class ChannelPoolCreator extends AnyRef
Value Members
- implicit def bigtableMutationOps[T <: Mutation](sc: SCollection[(ByteString, Iterable[T])]): SCollectionMutationOps[T]
- Definition Classes
- SCollectionSyntax
- implicit def bigtableScioContextOps(sc: ScioContext): ScioContextOps
- Definition Classes
- ScioContextSyntax
- implicit def rowOps(row: Row): RowOps
- Definition Classes
- RowSyntax
- object BigtableIO
- object BigtableRead extends Serializable
- object BigtableWrite extends Serializable
- object Mutations
Helper methods for
Mutation. - object Rows
Helper methods for
Row. - object TableAdmin
Bigtable Table Admin API helper commands.