com.neurosys.etl.connectors

Interface Connector<S,T>

All Known Implementing Classes:

SimpleBufferedConnector

public interface Connector<S,T>

Connect to a Data source; use the RealTimeLineReader to parse the data and finally sink into RealTimeWriter. Each Connector can connect and write to one data source at a time.

Author:

Arjun Dhar

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.

Method Detail

connectAndStream

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

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

Type Parameters:

T -

Parameters:

parser -

writer -

Throws:

Exception