edu.iu.dsc.tws.tset.sets

Class BaseTSetWithSchema<T>

java.lang.Object

edu.iu.dsc.tws.tset.sets.BaseTSet<T>

edu.iu.dsc.tws.tset.sets.BaseTSetWithSchema<T>

All Implemented Interfaces:

TBase, Buildable, BuildableTSet, java.io.Serializable

Direct Known Subclasses:

BatchRowTSetImpl, BatchTSetImpl, BatchTupleTSetImpl, RowSinkTSet, SinkTSet, StreamingTSetImpl, StreamingTupleTSetImpl

public abstract class BaseTSetWithSchema<T>
extends BaseTSet<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

BaseTSet.StateType

Constructor Summary

Constructors

Constructor and Description
BaseTSetWithSchema()
BaseTSetWithSchema(TSetEnvironment env, java.lang.String name, int parallel, Schema inputSchema) General constructor for TSets
BaseTSetWithSchema(TSetEnvironment env, java.lang.String name, int parallel, Schema inputSchema, Schema outputSchema)

Method Summary

Modifier and Type	Method and Description
Schema	getInputSchema()
Schema	getOutputSchema()
protected void	setOutputSchema(Schema outputSchema)

Methods inherited from class edu.iu.dsc.tws.tset.sets.BaseTSet

addChildToGraph, addChildToGraph, equals, getId, getInputs, getName, getParallelism, getStateType, getTSetEnv, hashCode, isMutable, rename, setMutable, setStateType, setTSetEnv, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.tset.sets.BuildableTSet

build, getINode

Methods inherited from interface edu.iu.dsc.tws.api.tset.TBase

setName

Methods inherited from interface edu.iu.dsc.tws.tset.Buildable

generateID, getTBaseGraph

Constructor Detail

BaseTSetWithSchema

public BaseTSetWithSchema()

BaseTSetWithSchema

public BaseTSetWithSchema(TSetEnvironment env,
                          java.lang.String name,
                          int parallel,
                          Schema inputSchema)

General constructor for TSets

Parameters:

env - env

name - name

parallel - par

inputSchema - Schema from the preceding TLink

BaseTSetWithSchema

public BaseTSetWithSchema(TSetEnvironment env,
                          java.lang.String name,
                          int parallel,
                          Schema inputSchema,
                          Schema outputSchema)

Method Detail

setOutputSchema

protected void setOutputSchema(Schema outputSchema)

getOutputSchema

public Schema getOutputSchema()

getInputSchema

public Schema getInputSchema()