Class ChannelConversions

java.lang.Object
org.apache.wayang.spark.channels.ChannelConversions

public class ChannelConversions extends Object
  • Field Details

    • UNCACHED_RDD_TO_CACHED_RDD

      public static final ChannelConversion UNCACHED_RDD_TO_CACHED_RDD
    • COLLECTION_TO_BROADCAST

      public static final ChannelConversion COLLECTION_TO_BROADCAST
    • COLLECTION_TO_UNCACHED_RDD

      public static final ChannelConversion COLLECTION_TO_UNCACHED_RDD
    • UNCACHED_RDD_TO_COLLECTION

      public static final ChannelConversion UNCACHED_RDD_TO_COLLECTION
    • CACHED_RDD_TO_COLLECTION

      public static final ChannelConversion CACHED_RDD_TO_COLLECTION
    • CACHED_RDD_TO_HDFS_TSV

      public static final ChannelConversion CACHED_RDD_TO_HDFS_TSV
    • UNCACHED_RDD_TO_HDFS_TSV

      public static final ChannelConversion UNCACHED_RDD_TO_HDFS_TSV
    • HDFS_TSV_TO_UNCACHED_RDD

      public static final ChannelConversion HDFS_TSV_TO_UNCACHED_RDD
    • CACHED_RDD_TO_HDFS_OBJECT_FILE

      public static final ChannelConversion CACHED_RDD_TO_HDFS_OBJECT_FILE
    • UNCACHED_RDD_TO_HDFS_OBJECT_FILE

      public static final ChannelConversion UNCACHED_RDD_TO_HDFS_OBJECT_FILE
    • HDFS_OBJECT_FILE_TO_UNCACHED_RDD

      public static final ChannelConversion HDFS_OBJECT_FILE_TO_UNCACHED_RDD
    • ALL

      public static Collection<ChannelConversion> ALL
  • Constructor Details

    • ChannelConversions

      public ChannelConversions()