com.neurosys.etl.writers

Interface RealTimeWriter<T>

All Superinterfaces:

Writer

All Known Implementing Classes:

AreaPersistTransformer, EntityBabyPersistTransformer, EntityPersistTransformer, ModeAwareProductPersistTransformer, ModeAwareProductPersistTransformer, ProductPersistTransformer, ProductPersistTransformer, RelatedEntityPersistTransformer

public interface RealTimeWriter<T>
extends Writer

Accepts a feed of Records from a source and writes it onto a specific format.
The writing operation could be synchronous or Asynchronous.

Author:

Arjun Dhar

Method Summary

Modifier and Type	Method and Description
void	close() Any cleanup
boolean	isInitialized() Check if Writer is already Initialized
Collection<T>	write(Collection<T> records) Write a Buffer of records at a given time.
T	write(T record) Write a record

Method Detail

write

Collection<T> write(Collection<T> records)
             throws Exception

Write a Buffer of records at a given time. Multiple write() may be called in sequence to append to end Sink/File.

Parameters:

records - as Collection of records to be written to sink.

Throws:

Exception

write

T write(T record)
 throws Exception

Write a record

Parameters:

records - as Collection of records to be written to sink.

Throws:

Exception

close

void close()
    throws Exception

Any cleanup

Throws:

Exception

isInitialized

boolean isInitialized()

Check if Writer is already Initialized

Returns: