org.kepler.spark.stub

Class StubUtilities

java.lang.Object

org.kepler.spark.stub.StubUtilities

public class StubUtilities
extends java.lang.Object

A collection of utilities used by Kepler Spark stubs.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
StubUtilities()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	convertArrayTokenToObject(ArrayToken arrayToken) Convert ArrayToken to an array of objects.
static void	convertListsToTupleList(java.util.List<?> keys, java.util.List<?> values, java.util.List<scala.Tuple2<java.lang.Object,java.lang.Object>> tuples) Convert lists of keys and values to a list of Tuple2s.
static java.lang.Object	convertTokenToObject(Token token) Convert a token to a Java Object.
static void	convertTokenToTupleList(java.util.List<Token> tokenList, java.util.List<scala.Tuple2<java.lang.Object,java.lang.Object>> out) Convert a list of record tokens into a list of Tuple2s containing Java Objects.
static java.lang.Object	convertToObject(java.lang.Object value) Convert from a (possible) Hadoop Writable to an object.
static Token	convertToToken(java.lang.Object value) Convert Hadoop data types or Java Objects to a Ptolemy token.
static org.apache.hadoop.conf.Configuration	deserializeConfiguration(byte[] bytes)
static void	initializeKepler(org.apache.hadoop.conf.Configuration parameters) Initialize the parts of Kepler required to run the sub-workflow in the stub.
static void	initializePtolemy() Initialize Ptolemy.

Methods inherited from class java.lang.Object

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

Constructor Detail

StubUtilities

public StubUtilities()

Method Detail

convertToObject

public static java.lang.Object convertToObject(java.lang.Object value)

Convert from a (possible) Hadoop Writable to an object.

convertToToken

public static Token convertToToken(java.lang.Object value)
                            throws IllegalActionException

Convert Hadoop data types or Java Objects to a Ptolemy token.

Throws:

IllegalActionException

convertTokenToTupleList

public static void convertTokenToTupleList(java.util.List<Token> tokenList,
                                           java.util.List<scala.Tuple2<java.lang.Object,java.lang.Object>> out)
                                    throws IllegalActionException

Convert a list of record tokens into a list of Tuple2s containing Java Objects.

Throws:

IllegalActionException

convertListsToTupleList

public static void convertListsToTupleList(java.util.List<?> keys,
                                           java.util.List<?> values,
                                           java.util.List<scala.Tuple2<java.lang.Object,java.lang.Object>> tuples)

Convert lists of keys and values to a list of Tuple2s.

convertTokenToObject

public static java.lang.Object convertTokenToObject(Token token)
                                             throws IllegalActionException

Convert a token to a Java Object.

Throws:

IllegalActionException

convertArrayTokenToObject

public static java.lang.Object convertArrayTokenToObject(ArrayToken arrayToken)
                                                  throws IllegalActionException

Convert ArrayToken to an array of objects.

Throws:

IllegalActionException

initializeKepler

public static void initializeKepler(org.apache.hadoop.conf.Configuration parameters)

Initialize the parts of Kepler required to run the sub-workflow in the stub.

initializePtolemy

public static void initializePtolemy()

Initialize Ptolemy.

deserializeConfiguration

public static org.apache.hadoop.conf.Configuration deserializeConfiguration(byte[] bytes)
                                                                     throws java.io.IOException

Throws:

java.io.IOException