Package org.apache.beam.runners.spark.translation

Interface Dataset

All Superinterfaces:
Serializable
All Known Implementing Classes:
BoundedDataset, UnboundedDataset
public interface Dataset extends Serializable
Holder for Spark RDD/DStream.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    action()
     
    void
    cache(String storageLevel, Coder<?> coder)
     
    void
    setName(String name)
     

  • Method Details

    • cache

      void cache(String storageLevel, Coder<?> coder)

    • action

      void action()

    • setName

      void setName(String name)