stream.io

Class BinaryWriter

java.lang.Object

stream.AbstractProcessor

stream.io.BinaryWriter

All Implemented Interfaces:

Processor, StatefulProcessor

public class BinaryWriter
extends AbstractProcessor

Author:

chris

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	bytesWritten
(package private) File	current
(package private) SimpleDateFormat	dateFormat
(package private) File	file
(package private) SimpleDateFormat	fmt
(package private) String[]	keys
(package private) static org.slf4j.Logger	log
(package private) OutputStream	os
(package private) Time	rotate
(package private) SimpleDateFormat	timeFormat

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
BinaryWriter()

Method Summary

Methods

Modifier and Type	Method and Description
File	getFile()
String[]	getKeys()
void	init(ProcessContext ctx)
Data	process(Data input)
void	setFile(File file)
void	setKey(String key)
void	setKeys(String[] keys)

Methods inherited from class stream.AbstractProcessor

finish, resetState

Methods inherited from class java.lang.Object

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

Field Detail

log

static org.slf4j.Logger log

dateFormat

final SimpleDateFormat dateFormat

timeFormat

final SimpleDateFormat timeFormat

fmt

final SimpleDateFormat fmt

keys

String[] keys

file

File file

current

File current

os

OutputStream os

bytesWritten

long bytesWritten

rotate

Time rotate

Constructor Detail

BinaryWriter

public BinaryWriter()

Method Detail

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)

getFile

public File getFile()

Returns:

the file

setFile

public void setFile(File file)

Parameters:

file - the file to set

getKeys

public String[] getKeys()

Returns:

the keys

setKeys

public void setKeys(String[] keys)

Parameters:

keys - the keys to set

setKey

public void setKey(String key)