com.neurosys.etl.connectors

Class SimpleBufferedConnector<S,T>

java.lang.Object

com.neurosys.etl.connectors.SimpleBufferedConnector<S,T>

All Implemented Interfaces:

BufferedConnector, Connector<S,T>

public class SimpleBufferedConnector<S,T>
extends Object
implements Connector<S,T>, BufferedConnector

Simple program that reads from a Source Tuple by Tuple and Writes it to the Sink real time with a in memory Buffer.

Author:

Arjun Dhar

Constructor Summary

Constructors

Constructor and Description
SimpleBufferedConnector()

Method Summary

Modifier and Type	Method and Description
void	connectAndStream(RealTimeLineReader<T> parser, RealTimeWriter<T> writer) Synchronous call to connect to the source , parse and write it.
int	getWriteBufferSize()
void	setBufferSize(int writeBufferSize) Read Buffer size number of records before committing to DataStore/Out

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleBufferedConnector

public SimpleBufferedConnector()

Method Detail

getWriteBufferSize

public int getWriteBufferSize()

setBufferSize

public void setBufferSize(int writeBufferSize)

Description copied from interface: BufferedConnector

Read Buffer size number of records before committing to DataStore/Out

Specified by:

setBufferSize in interface BufferedConnector

connectAndStream

public void connectAndStream(RealTimeLineReader<T> parser,
                             RealTimeWriter<T> writer)
                      throws Exception

Description copied from interface: Connector

Synchronous call to connect to the source , parse and write it. Internally the writing may be asychronous, but the complete operation is blocking.

Specified by:

connectAndStream in interface Connector<S,T>

Throws:

Exception