Package adams.flow.transformer
Class MOAFilter.FixedInstanceStream
- java.lang.Object
-
- moa.AbstractMOAObject
-
- adams.flow.transformer.MOAFilter.FixedInstanceStream
-
- All Implemented Interfaces:
Serializable
,moa.capabilities.CapabilitiesHandler
,moa.MOAObject
,moa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
,moa.streams.InstanceStream
- Enclosing class:
- MOAFilter
public class MOAFilter.FixedInstanceStream extends moa.AbstractMOAObject implements moa.streams.InstanceStream
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected com.yahoo.labs.samoa.instances.Instance
m_Instance
protected com.yahoo.labs.samoa.instances.Instances
m_Instances
protected int
m_Left
protected boolean
m_Single
-
Constructor Summary
Constructors Constructor Description FixedInstanceStream()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
estimatedRemainingInstances()
void
getDescription(StringBuilder sb, int indent)
com.yahoo.labs.samoa.instances.InstancesHeader
getHeader()
boolean
hasMoreInstances()
boolean
isRestartable()
moa.core.Example<com.yahoo.labs.samoa.instances.Instance>
nextInstance()
void
restart()
void
setData(com.yahoo.labs.samoa.instances.Instance instance)
void
setData(com.yahoo.labs.samoa.instances.Instances instances)
-
Methods inherited from class moa.AbstractMOAObject
copy, copy, measureByteSize, measureByteSize, toString
-
-
-
-
Method Detail
-
setData
public void setData(com.yahoo.labs.samoa.instances.Instance instance)
-
setData
public void setData(com.yahoo.labs.samoa.instances.Instances instances)
-
getHeader
public com.yahoo.labs.samoa.instances.InstancesHeader getHeader()
- Specified by:
getHeader
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
estimatedRemainingInstances
public long estimatedRemainingInstances()
- Specified by:
estimatedRemainingInstances
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
hasMoreInstances
public boolean hasMoreInstances()
- Specified by:
hasMoreInstances
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
nextInstance
public moa.core.Example<com.yahoo.labs.samoa.instances.Instance> nextInstance()
- Specified by:
nextInstance
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
isRestartable
public boolean isRestartable()
- Specified by:
isRestartable
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
restart
public void restart()
- Specified by:
restart
in interfacemoa.streams.ExampleStream<moa.core.Example<com.yahoo.labs.samoa.instances.Instance>>
-
getDescription
public void getDescription(StringBuilder sb, int indent)
- Specified by:
getDescription
in interfacemoa.MOAObject
-
-