InProcessPipelineRunner.PCollectionViewWriter (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.runners.inprocess

Interface InProcessPipelineRunner.PCollectionViewWriter<ElemT,ViewT>

• Type Parameters:

  ElemT - the type of elements the input PCollection contains.

  ViewT - the type of the PCollectionView this writer writes to.

  Enclosing class:

  InProcessPipelineRunner

  ---

  
  

  public static interface InProcessPipelineRunner.PCollectionViewWriter<ElemT,ViewT>

  A InProcessPipelineRunner.PCollectionViewWriter is responsible for writing contents of a PCollection to a storage mechanism that can be read from while constructing a PCollectionView.

• • Method Summary

    All Methods Instance Methods Abstract Methods 

    Modifier and Type	Method and Description
    void	add(Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<ElemT>> values)

• • Method Detail

    • add

      void add(Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<ElemT>> values)