org.apache.samoa.topology

Class AbstractStream

java.lang.Object

org.apache.samoa.topology.AbstractStream

All Implemented Interfaces:

Stream

Direct Known Subclasses:

FlinkStream, S4Stream, SamzaStream, ThreadsStream

public abstract class AbstractStream
extends Object
implements Stream

Abstract Stream Helper for implementation of Stream. It has basic information for a Stream: streamID and source ProcessingItem. Subclass of this class needs to implement put(ContentEvent).

Author:

Anh Thu Vu

Constructor Summary

Constructors

Constructor and Description
AbstractStream()
AbstractStream(IProcessingItem sourcePi)

Method Summary

Modifier and Type	Method and Description
int	getBatchSize() Get suggested batch size
IProcessingItem	getSourceProcessingItem() Get source processing item of this stream
String	getStreamId() Get name (ID) of this stream
abstract void	put(ContentEvent event) Puts events into a platform specific data stream.
void	setBatchSize(int batchSize) Set suggested batch size
void	setStreamId(String streamID) Set the name (ID) of this stream

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractStream

public AbstractStream()

AbstractStream

public AbstractStream(IProcessingItem sourcePi)

Method Detail

getSourceProcessingItem

public IProcessingItem getSourceProcessingItem()

Get source processing item of this stream

Returns:

put

public abstract void put(ContentEvent event)

Description copied from interface: Stream

Puts events into a platform specific data stream.

Specified by:

put in interface Stream

getStreamId

public String getStreamId()

Get name (ID) of this stream

Specified by:

getStreamId in interface Stream

Returns:

the name (ID)

setStreamId

public void setStreamId(String streamID)

Set the name (ID) of this stream

Parameters:

streamID - the name (ID)

setBatchSize

public void setBatchSize(int batchSize)

Set suggested batch size

Specified by:

setBatchSize in interface Stream

Parameters:

batchSize - the suggested batch size

getBatchSize

public int getBatchSize()

Get suggested batch size

Returns:

the suggested batch size