org.kepler.stratosphere.io.input

Class TokenDataSource

java.lang.Object

eu.stratosphere.api.common.operators.Operator

eu.stratosphere.api.common.operators.GenericDataSource<TokenInputFormat>

org.kepler.stratosphere.io.input.TokenDataSource

All Implemented Interfaces:

eu.stratosphere.api.common.operators.util.AnnotationConfigurable, eu.stratosphere.util.Visitable<eu.stratosphere.api.common.operators.Operator>

public class TokenDataSource
extends eu.stratosphere.api.common.operators.GenericDataSource<TokenInputFormat>

A data source for Ptolemy tokens.

Author:

Daniel Crawl

Field Summary

Fields inherited from class eu.stratosphere.api.common.operators.GenericDataSource

formatWrapper, statisticsKey

Fields inherited from class eu.stratosphere.api.common.operators.Operator

compilerHints, name, ocs, parameters

Constructor Summary

Constructors

Constructor and Description
TokenDataSource(java.lang.Class<? extends TokenInputFormat> format, java.lang.String sourceName)

Method Summary

Methods inherited from class eu.stratosphere.api.common.operators.GenericDataSource

accept, addStubAnnotation, getFormatWrapper, getStatisticsKey, getStubAnnotation, getUserCodeWrapper, setStatisticsKey, toString

Methods inherited from class eu.stratosphere.api.common.operators.Operator

getCompilerHints, getDegreeOfParallelism, getName, getParameters, getUserCodeAnnotation, setDegreeOfParallelism, setName, setParameter, setParameter, setParameter

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenDataSource

public TokenDataSource(java.lang.Class<? extends TokenInputFormat> format,
                       java.lang.String sourceName)