Package org.apache.wayang.spark.operators

Interface Summary

Interface	Description
SparkExecutionOperator	Execution operator for the SparkPlatform.

Class Summary

Class	Description
SparkBernoulliSampleOperator<Type>	Spark implementation of the SparkBernoulliSampleOperator.
SparkBroadcastOperator<Type>	Takes care of creating a Broadcast that can be used later on.
SparkCacheOperator<Type>	Converts an uncached RddChannel into a cached RddChannel.
SparkCartesianOperator<InputType0,InputType1>	Spark implementation of the CartesianOperator.
SparkCoGroupOperator<In0,In1,Key>	Spark implementation of the JoinOperator.
SparkCollectionSource<Type>	Provides a Collection to a Spark job.
SparkCollectOperator<Type>	Converts a RddChannel into a CollectionChannel of the JavaPlatform.
SparkCountOperator<Type>	Spark implementation of the CountOperator.
SparkDistinctOperator<Type>	Spark implementation of the DistinctOperator.
SparkDoWhileOperator<InputType,ConvergenceType>	Spark implementation of the DoWhileOperator.
SparkFilterOperator<Type>	Spark implementation of the FilterOperator.
SparkFlatMapOperator<InputType,OutputType>	Spark implementation of the FlatMapOperator.
SparkGlobalMaterializedGroupOperator<Type>	Spark implementation of the GlobalMaterializedGroupOperator.
SparkGlobalReduceOperator<Type>	Spark implementation of the GlobalReduceOperator.
SparkIntersectOperator<Type>	Spark implementation of the JoinOperator.
SparkJoinOperator<InputType0,InputType1,KeyType>	Spark implementation of the JoinOperator.
SparkKafkaTopicSink<T>	Implementation of the KafkaTopicSink operator for the Spark platform.
SparkKafkaTopicSource	Provides a Collection to a Spark job.
SparkLocalCallbackSink<T extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Spark platform.
SparkLoopOperator<InputType,ConvergenceType>	Spark implementation of the LoopOperator.
SparkMapOperator<InputType,OutputType>	Spark implementation of the MapOperator.
SparkMapPartitionsOperator<InputType,OutputType>	Spark implementation of the MapPartitionsOperator.
SparkMaterializedGroupByOperator<Type,KeyType>	Spark implementation of the MaterializedGroupByOperator.
SparkObjectFileSink<T>	Operator for the SparkPlatform that creates a sequence file.
SparkObjectFileSource<T>	Operator for the SparkPlatform that creates a sequence file.
SparkRandomPartitionSampleOperator<Type>	Spark implementation of the SampleOperator.
SparkReduceByOperator<Type,KeyType>	Spark implementation of the ReduceByOperator.
SparkRepeatOperator<Type>	Spark implementation of the RepeatOperator.
SparkShufflePartitionSampleOperator<Type>	Spark implementation of the SparkShufflePartitionSampleOperator.
SparkSortOperator<Type,Key>	Spark implementation of the SortOperator.
SparkTextFileSink<T>	Implementation of the TextFileSink operator for the Spark platform.
SparkTextFileSource	Provides a Collection to a Spark job.
SparkTsvFileSink<T extends Tuple2<?,?>>	Operator for the SparkPlatform that creates a TSV file.
SparkTsvFileSource<T>	Operator for the SparkPlatform that creates a sequence file.
SparkUnionAllOperator<Type>	Spark implementation of the UnionAllOperator.
SparkZipWithIdOperator<InputType>	Spark implementation of the MapOperator.