org.kepler.stratosphere.stub

Class StubUtilities

java.lang.Object

org.kepler.stratosphere.stub.StubUtilities

public class StubUtilities
extends java.lang.Object

A collection of utilities used by Kepler PACT stubs.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
StubUtilities()

Method Summary

Modifier and Type	Method and Description
static byte[]	arrayTokenToByteArray(ArrayToken arrayToken) Convert ArrayToken to an array of byte.
static eu.stratosphere.types.Value[]	arrayTokenToPactData(ArrayToken arrayToken) Convert ArrayToken to an array of Value.
static UnsignedByteToken[]	byteArrayToToken(byte[] byteArray) Convert byte array data to an array of UnsignedByteToken.
static java.lang.Object	convertPactDataToObject(eu.stratosphere.types.Record record, int fieldNum, java.lang.Class<? extends eu.stratosphere.types.Value> classType) Convert PACT data to an object.
static Token	convertPactDataToToken(java.util.Iterator<eu.stratosphere.types.Record> records, int fieldNum, java.lang.Class<? extends eu.stratosphere.types.Value> classType) Convert PACT data to a token.
static Token	convertPactDataToToken(eu.stratosphere.types.Record record, int fieldNum, java.lang.Class<? extends eu.stratosphere.types.Value> classType) Convert PACT data to a token.
static void	convertResultsToCollector(java.util.List<?> resultKeys, java.util.List<?> resultValues, eu.stratosphere.util.Collector<eu.stratosphere.types.Record> collector) Write lists of Java Object keys and values to a Collector.
static void	convertTokenToCollector(java.util.List<Token> tokenList, eu.stratosphere.util.Collector<eu.stratosphere.types.Record> collector) Convert a token to PACT data and add to a Collector.
static eu.stratosphere.types.Key	convertTokenToPactKeyData(Token token) Convert a token to PACT Key data.
static eu.stratosphere.types.Value	convertTokenToPactValueData(Token token) Convert a token to PACT Value data.
static void	initializeKepler(eu.stratosphere.configuration.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

convertResultsToCollector

public static void convertResultsToCollector(java.util.List<?> resultKeys,
                                             java.util.List<?> resultValues,
                                             eu.stratosphere.util.Collector<eu.stratosphere.types.Record> collector)

Write lists of Java Object keys and values to a Collector.

convertTokenToCollector

public static void convertTokenToCollector(java.util.List<Token> tokenList,
                                           eu.stratosphere.util.Collector<eu.stratosphere.types.Record> collector)
                                    throws IllegalActionException

Convert a token to PACT data and add to a Collector.

Throws:

IllegalActionException

convertTokenToPactValueData

public static eu.stratosphere.types.Value convertTokenToPactValueData(Token token)
                                                               throws IllegalActionException

Convert a token to PACT Value data.

Throws:

IllegalActionException

convertTokenToPactKeyData

public static eu.stratosphere.types.Key convertTokenToPactKeyData(Token token)
                                                           throws IllegalActionException

Convert a token to PACT Key data.

Throws:

IllegalActionException

convertPactDataToObject

public static java.lang.Object convertPactDataToObject(eu.stratosphere.types.Record record,
                                                       int fieldNum,
                                                       java.lang.Class<? extends eu.stratosphere.types.Value> classType)

Convert PACT data to an object.

convertPactDataToToken

public static Token convertPactDataToToken(eu.stratosphere.types.Record record,
                                           int fieldNum,
                                           java.lang.Class<? extends eu.stratosphere.types.Value> classType)

Convert PACT data to a token.

byteArrayToToken

public static UnsignedByteToken[] byteArrayToToken(byte[] byteArray)

Convert byte array data to an array of UnsignedByteToken.

arrayTokenToPactData

public static eu.stratosphere.types.Value[] arrayTokenToPactData(ArrayToken arrayToken)
                                                          throws IllegalActionException

Convert ArrayToken to an array of Value.

Throws:

IllegalActionException

arrayTokenToByteArray

public static byte[] arrayTokenToByteArray(ArrayToken arrayToken)
                                    throws IllegalActionException

Convert ArrayToken to an array of byte.

Throws:

IllegalActionException

convertPactDataToToken

public static Token convertPactDataToToken(java.util.Iterator<eu.stratosphere.types.Record> records,
                                           int fieldNum,
                                           java.lang.Class<? extends eu.stratosphere.types.Value> classType)

Convert PACT data to a token.

initializeKepler

public static void initializeKepler(eu.stratosphere.configuration.Configuration parameters)

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

initializePtolemy

public static void initializePtolemy()

Initialize Ptolemy.