net.sf.farrago.fem.fennel
Class FemWindowStreamDef$Hib

java.lang.Object
  org.eigenbase.enki.jmi.impl.RefBaseObjectBase
      org.eigenbase.enki.jmi.impl.RefFeaturedBase
          org.eigenbase.enki.jmi.impl.RefObjectBase
              net.sf.farrago.fem.fennel.FemWindowStreamDef$Hib

All Implemented Interfaces:

RefBaseObject, RefFeatured, RefObject, FemExecutionStreamDef, FemTupleStreamDef, FemWindowStreamDef

public class FemWindowStreamDef$Hib
extends RefObjectBase
implements FemWindowStreamDef

Implements MOF's WindowStreamDef interface.

Author:

MofImplementationHandler

Execution object which calculates expressions over a set of windows. An output record is made up expressions drawn from the input record and the current bucket of each window.

Note that this a window stream has a superset of the functionality of the FemCalcTupleStreamDef execution object.

Field Summary

private ParamUses	dynamicParamUse
private Boolean	filter
private ExecStreamInput	inputFlow
private FemTupleProjection	inputOrderKeyList
private String	name
private FemTupleDescriptor	outputDesc
private ExecStreamOutput	outputFlow
private String	outputProgram
private Windows	window

Constructor Summary

FemWindowStreamDef$Hib(RefClass refClass)

FemWindowStreamDef$Hib(RefClass refClass, String name, FemTupleDescriptor outputDesc, boolean filter, String outputProgram, FemTupleProjection inputOrderKeyList)

Method Summary

protected void	checkConstraints(List<JmiException> errors, boolean deepVerify)
Collection<FemDynamicParamUse>	getDynamicParamUse() Returns the value of reference DynamicParamUse.
List<FemExecStreamDataFlow>	getInputFlow() Returns the value of reference InputFlow.
FemTupleProjection	getInputOrderKeyList() Returns the value of attribute inputOrderKeyList.
String	getName() Returns the value of attribute name.
FemTupleDescriptor	getOutputDesc() Returns the value of attribute outputDesc.
List<FemExecStreamDataFlow>	getOutputFlow() Returns the value of reference OutputFlow.
String	getOutputProgram() Returns the value of attribute outputProgram.
List<FemWindowDef>	getWindow() Returns the value of reference Window.
boolean	isFilter() Returns the value of attribute filter.
void	setFilter(boolean newValue) Sets the value of filter attribute.
void	setInputOrderKeyList(FemTupleProjection newValue) Sets the value of inputOrderKeyList attribute.
void	setName(String newValue) Sets the value of name attribute.
void	setOutputDesc(FemTupleDescriptor newValue) Sets the value of outputDesc attribute.
void	setOutputProgram(String newValue) Sets the value of outputProgram attribute.

Methods inherited from class org.eigenbase.enki.jmi.impl.RefObjectBase

findAssociationEnd, findAttribute, getRepository, refClass, refDelete, refImmediateComposite, refImmediatePackage, refIsInstanceOf, refMetaObject, refOutermostComposite, setRefMetaObject, unregister

Methods inherited from class org.eigenbase.enki.jmi.impl.RefFeaturedBase

refGetValue, refGetValue, refInvokeOperation, refInvokeOperation, refSetValue, refSetValue

Methods inherited from class org.eigenbase.enki.jmi.impl.RefBaseObjectBase

createInstance, equals, getCurrentInitializer, getEnum, getInitializer, getMofId, getTag, hashCode, invokeMethod, invokeMethod, logJmi, refMofId, refOutermostPackage, refVerifyConstraints, setMofId

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jmi.reflect.RefObject

refClass, refDelete, refImmediateComposite, refIsInstanceOf, refOutermostComposite

Methods inherited from interface javax.jmi.reflect.RefFeatured

refGetValue, refGetValue, refInvokeOperation, refInvokeOperation, refSetValue, refSetValue

Methods inherited from interface javax.jmi.reflect.RefBaseObject

equals, hashCode, refImmediatePackage, refMetaObject, refMofId, refOutermostPackage, refVerifyConstraints

Field Detail

name

private String name

outputDesc

private FemTupleDescriptor outputDesc

filter

private Boolean filter

outputProgram

private String outputProgram

inputOrderKeyList

private FemTupleProjection inputOrderKeyList

outputFlow

private ExecStreamOutput outputFlow

dynamicParamUse

private ParamUses dynamicParamUse

inputFlow

private ExecStreamInput inputFlow

window

private Windows window

Constructor Detail

FemWindowStreamDef$Hib

FemWindowStreamDef$Hib(RefClass refClass)

FemWindowStreamDef$Hib

FemWindowStreamDef$Hib(RefClass refClass,
                       String name,
                       FemTupleDescriptor outputDesc,
                       boolean filter,
                       String outputProgram,
                       FemTupleProjection inputOrderKeyList)

Method Detail

getName

public String getName()

Description copied from interface: FemExecutionStreamDef

Returns the value of attribute name.

Specified by:

getName in interface FemExecutionStreamDef

Returns:

Value of attribute name.

setName

public void setName(String newValue)

Description copied from interface: FemExecutionStreamDef

Sets the value of name attribute. See FemExecutionStreamDef.getName() for description on the attribute.

Specified by:

setName in interface FemExecutionStreamDef

Parameters:

newValue - New value to be set.

getOutputDesc

public FemTupleDescriptor getOutputDesc()

Description copied from interface: FemExecutionStreamDef

Returns the value of attribute outputDesc.

Specified by:

getOutputDesc in interface FemExecutionStreamDef

Returns:

Value of attribute outputDesc.

setOutputDesc

public void setOutputDesc(FemTupleDescriptor newValue)

Description copied from interface: FemExecutionStreamDef

Sets the value of outputDesc attribute. See FemExecutionStreamDef.getOutputDesc() for description on the attribute.

Specified by:

setOutputDesc in interface FemExecutionStreamDef

Parameters:

newValue - New value to be set.

isFilter

public boolean isFilter()

Description copied from interface: FemWindowStreamDef

Returns the value of attribute filter.

If true, the output program sets a status register which determines whether to output the row.

Specified by:

isFilter in interface FemWindowStreamDef

Returns:

Value of attribute filter.

setFilter

public void setFilter(boolean newValue)

Description copied from interface: FemWindowStreamDef

Sets the value of filter attribute. See FemWindowStreamDef.isFilter() for description on the attribute.

Specified by:

setFilter in interface FemWindowStreamDef

Parameters:

newValue - New value to be set.

getOutputProgram

public String getOutputProgram()

Description copied from interface: FemWindowStreamDef

Returns the value of attribute outputProgram.

Calculator program to generate a row of output.

Input fields to the programs are the fields of the input record, followed by the fields of the current bucket of each window.

If 'filter' is true, the program sets a status register which the XO should use to determine whether to output the row.

Specified by:

getOutputProgram in interface FemWindowStreamDef

Returns:

Value of attribute outputProgram.

setOutputProgram

public void setOutputProgram(String newValue)

Description copied from interface: FemWindowStreamDef

Sets the value of outputProgram attribute. See FemWindowStreamDef.getOutputProgram() for description on the attribute.

Specified by:

setOutputProgram in interface FemWindowStreamDef

Parameters:

newValue - New value to be set.

getInputOrderKeyList

public FemTupleProjection getInputOrderKeyList()

Description copied from interface: FemWindowStreamDef

Returns the value of attribute inputOrderKeyList.

List of columns on which the input stream is sorted.

Specified by:

getInputOrderKeyList in interface FemWindowStreamDef

Returns:

Value of attribute inputOrderKeyList.

setInputOrderKeyList

public void setInputOrderKeyList(FemTupleProjection newValue)

Description copied from interface: FemWindowStreamDef

Sets the value of inputOrderKeyList attribute. See FemWindowStreamDef.getInputOrderKeyList() for description on the attribute.

Specified by:

setInputOrderKeyList in interface FemWindowStreamDef

Parameters:

newValue - New value to be set.

getOutputFlow

public List<FemExecStreamDataFlow> getOutputFlow()

Description copied from interface: FemExecutionStreamDef

Returns the value of reference OutputFlow.

Specified by:

getOutputFlow in interface FemExecutionStreamDef

Returns:

Value of reference OutputFlow. Element type: FemExecStreamDataFlow

getDynamicParamUse

public Collection<FemDynamicParamUse> getDynamicParamUse()

Description copied from interface: FemExecutionStreamDef

Returns the value of reference DynamicParamUse.

Specified by:

getDynamicParamUse in interface FemExecutionStreamDef

Returns:

Value of reference DynamicParamUse. Element type: FemDynamicParamUse

getInputFlow

public List<FemExecStreamDataFlow> getInputFlow()

Description copied from interface: FemExecutionStreamDef

Returns the value of reference InputFlow.

Specified by:

getInputFlow in interface FemExecutionStreamDef

Returns:

Value of reference InputFlow. Element type: FemExecStreamDataFlow

getWindow

public List<FemWindowDef> getWindow()

Description copied from interface: FemWindowStreamDef

Returns the value of reference Window.

Specified by:

getWindow in interface FemWindowStreamDef

Returns:

Value of reference Window. Element type: FemWindowDef

checkConstraints

protected void checkConstraints(List<JmiException> errors,
                                boolean deepVerify)

Specified by:

checkConstraints in class RefBaseObjectBase