stream.io

Class DataObjectWriter

java.lang.Object

stream.AbstractProcessor

stream.io.DataObjectWriter

All Implemented Interfaces:

Processor, StatefulProcessor

public class DataObjectWriter
extends AbstractProcessor

Author:

chris

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	cnt
(package private) File	file
(package private) ObjectOutputStream	out
(package private) Integer	reset

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
DataObjectWriter()

Method Summary

Methods

Modifier and Type	Method and Description
void	finish()
File	getFile()
Integer	getReset()
void	init(ProcessContext ctx)
Data	process(Data input)
void	setFile(File file)
void	setReset(Integer reset)

Methods inherited from class stream.AbstractProcessor

resetState

Methods inherited from class java.lang.Object

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

Field Detail

file

File file

out

ObjectOutputStream out

cnt

long cnt

reset

Integer reset

Constructor Detail

DataObjectWriter

public DataObjectWriter()

Method Detail

getFile

public File getFile()

Returns:

the file

setFile

public void setFile(File file)

Parameters:

file - the file to set

init

public void init(ProcessContext ctx)
          throws Exception

Specified by:

init in interface StatefulProcessor

Overrides:

init in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.init(stream.ProcessContext)

process

public Data process(Data input)

See Also:

Processor.process(stream.Data)

finish

public void finish()
            throws Exception

Specified by:

finish in interface StatefulProcessor

Overrides:

finish in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.finish()

getReset

public Integer getReset()

Returns:

the reset

setReset

public void setReset(Integer reset)

Parameters:

reset - the reset to set