Package org.apache.wayang.spark.channels
Class ChannelConversions
- java.lang.Object
-
- org.apache.wayang.spark.channels.ChannelConversions
-
public class ChannelConversions extends java.lang.ObjectChannelConversions used by theJavaPlatform.
-
-
Field Summary
Fields Modifier and Type Field Description static java.util.Collection<ChannelConversion>ALLstatic ChannelConversionCACHED_RDD_TO_COLLECTIONstatic ChannelConversionCACHED_RDD_TO_HDFS_OBJECT_FILEstatic ChannelConversionCACHED_RDD_TO_HDFS_TSVstatic ChannelConversionCOLLECTION_TO_BROADCASTstatic ChannelConversionCOLLECTION_TO_UNCACHED_RDDstatic ChannelConversionHDFS_OBJECT_FILE_TO_UNCACHED_RDDstatic ChannelConversionHDFS_TSV_TO_UNCACHED_RDDstatic ChannelConversionUNCACHED_RDD_TO_CACHED_RDDstatic ChannelConversionUNCACHED_RDD_TO_COLLECTIONstatic ChannelConversionUNCACHED_RDD_TO_HDFS_OBJECT_FILEstatic ChannelConversionUNCACHED_RDD_TO_HDFS_TSV
-
Constructor Summary
Constructors Constructor Description ChannelConversions()
-
-
-
Field Detail
-
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 java.util.Collection<ChannelConversion> ALL
-
-