org.jumpmind.symmetric.extract.csv
Class CsvExtractor14

java.lang.Object
  org.jumpmind.symmetric.extract.csv.CsvExtractor14

All Implemented Interfaces:

IDataExtractor

public class CsvExtractor14
extends java.lang.Object
implements IDataExtractor

Constructor Summary

CsvExtractor14()

Method Summary

void	begin(OutgoingBatch batch, java.io.BufferedWriter writer)
void	commit(OutgoingBatch batch, java.io.BufferedWriter writer)
void	init(java.io.BufferedWriter writer, DataExtractorContext context)
void	preprocessTable(Data data, java.io.BufferedWriter out, DataExtractorContext context) Writes the table metadata out to a stream only if it hasn't already been written out before
void	setDbDialect(IDbDialect dbDialect)
void	setDictionary(java.util.Map<java.lang.String,org.jumpmind.symmetric.extract.csv.IStreamDataCommand> dictionary)
void	setNodeService(INodeService nodeService)
void	setParameterService(IParameterService parameterService)
void	write(java.io.BufferedWriter writer, Data data, DataExtractorContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

CsvExtractor14

public CsvExtractor14()

Method Detail

init

public void init(java.io.BufferedWriter writer,
                 DataExtractorContext context)
          throws java.io.IOException

Specified by:

init in interface IDataExtractor

Throws:

java.io.IOException

begin

public void begin(OutgoingBatch batch,
                  java.io.BufferedWriter writer)
           throws java.io.IOException

Specified by:

begin in interface IDataExtractor

Throws:

java.io.IOException

commit

public void commit(OutgoingBatch batch,
                   java.io.BufferedWriter writer)
            throws java.io.IOException

Specified by:

commit in interface IDataExtractor

Throws:

java.io.IOException

write

public void write(java.io.BufferedWriter writer,
                  Data data,
                  DataExtractorContext context)
           throws java.io.IOException

Specified by:

write in interface IDataExtractor

Throws:

java.io.IOException

preprocessTable

public void preprocessTable(Data data,
                            java.io.BufferedWriter out,
                            DataExtractorContext context)
                     throws java.io.IOException

Writes the table metadata out to a stream only if it hasn't already been written out before

Specified by:

preprocessTable in interface IDataExtractor

Parameters:

tableName -

out -

Throws:

java.io.IOException

setDictionary

public void setDictionary(java.util.Map<java.lang.String,org.jumpmind.symmetric.extract.csv.IStreamDataCommand> dictionary)

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setParameterService

public void setParameterService(IParameterService parameterService)

setNodeService

public void setNodeService(INodeService nodeService)