uni.bielefeld.cmg.sparkhit.pipeline

Class SparkClusterPipe

java.lang.Object

uni.bielefeld.cmg.sparkhit.pipeline.SparkClusterPipe

All Implemented Interfaces:

java.io.Serializable

public class SparkClusterPipe
extends java.lang.Object
implements java.io.Serializable

Returns an object for running the Sparkhit cluster pipeline.

See Also:

, Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkClusterPipe()

Method Summary

Methods

Modifier and Type	Method and Description
void	setParam(DefaultParam param) This method sets the input parameters.
void	spark() runs the Sparkhit pipeline using Spark RDD operations.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkClusterPipe

public SparkClusterPipe()

Method Detail

spark

public void spark()

runs the Sparkhit pipeline using Spark RDD operations.

setParam

public void setParam(DefaultParam param)

This method sets the input parameters.

Parameters:

param - DefaultParam.