Packages

package scio

Main package for public APIs. Import all.

import com.spotify.scio._
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. scio
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class Args extends Serializable

    Encapsulate parsed commandline arguments.

  2. class DistCacheScioContext extends AnyRef

    An enhanced ScioContext with distributed cache features.

  3. sealed trait IsJavaBean[T] extends AnyRef

    Proof that a type is implemented in Java

  4. trait RunnerContext extends AnyRef

    Runner specific context.

  5. trait RunnerResult extends AnyRef

    Represent a Beam runner specific result.

  6. class ScioContext extends TransformNameable

    Main entry point for Scio functionality.

    Main entry point for Scio functionality. A ScioContext represents a pipeline and can be used to create SCollections and distributed caches on that cluster.

  7. trait ScioExecutionContext extends AnyRef

    ScioExecutionContext is the result of ScioContext#run().

    ScioExecutionContext is the result of ScioContext#run().

    This is a handle to the underlying running job and allows getting the state, checking if it's completed and to wait for it's execution.

  8. abstract class ScioResult extends AnyRef

    Represent a Scio pipeline result.

  9. final case class SysProp(flag: String, description: String) extends Product with Serializable
  10. trait SysProps extends AnyRef
  11. implicit class WaitableClosedTap[T] extends AnyRef
  12. implicit class WaitableFutureTap[T] extends AnyRef
  13. implicit class WaitableNestedFutureTap[T] extends AnyRef

    Wait for nested Tap to be available, flatten result and get Tap reference from Future.

  14. final macro class registerSysProps extends Annotation with StaticAnnotation
    Annotations
    @compileTimeOnly( ... )

Value Members

  1. object Args extends Serializable

    A simple command line argument parser.

    A simple command line argument parser.

    Arguments can be either properties (--key=value1,value2,...) or booleans (--test).

  2. object BuildInfo extends Product with Serializable

    This object was generated by sbt-buildinfo.

  3. object ContextAndArgs

    Convenience object for creating ScioContext and Args.

  4. object CoreSysProps
    Annotations
    @registerSysProps()
  5. object IsJavaBean
  6. object JavaConverters

    Converters for Beam Java SDK APIs.

    Converters for Beam Java SDK APIs. Import all.

    import com.spotify.scio.JavaConverters._
  7. object ScioContext

    Companion object for ScioContext.

  8. object ScioExecutionContext
  9. object ScioMetrics

    Utility object for creating metrics.

    Utility object for creating metrics. The main types available are org.apache.beam.sdk.metrics.Counter, org.apache.beam.sdk.metrics.Distribution and org.apache.beam.sdk.metrics.Gauge.

  10. object SysProps

Inherited from AnyRef

Inherited from Any

Ungrouped