Package org.jumpmind.symmetric.load

Class DefaultDataLoaderFactory

java.lang.Object

org.jumpmind.symmetric.load.AbstractDataLoaderFactory

org.jumpmind.symmetric.load.DefaultDataLoaderFactory

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, ISymmetricEngineAware, IDataLoaderFactory

Direct Known Subclasses:

HbaseDataLoaderFactory

public class DefaultDataLoaderFactory
extends AbstractDataLoaderFactory
implements IDataLoaderFactory, IBuiltInExtensionPoint, ISymmetricEngineAware

Field Summary

Fields

Modifier and Type	Field	Description
protected Set<String>	conflictLosingParentRows
protected ISymmetricEngine	engine
protected final org.slf4j.Logger	log
protected Map<String,Table>	targetTableMap

Fields inherited from class org.jumpmind.symmetric.load.AbstractDataLoaderFactory

parameterService

Constructor Summary

Constructors

Constructor	Description
DefaultDataLoaderFactory()
DefaultDataLoaderFactory(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected DatabaseWriterSettings	buildDatabaseWriterSettings(List<IDatabaseWriterFilter> filters, List<IDatabaseWriterErrorHandler> errorHandlers, List<? extends Conflict> conflictSettings, List<ResolvedData> resolvedDatas)
IDataWriter	getDataWriter(String sourceNodeId, Channel channel, ISymmetricDialect symmetricDialect, TransformWriter transformWriter, List<IDatabaseWriterFilter> filters, List<IDatabaseWriterErrorHandler> errorHandlers, List<? extends Conflict> conflictSettings, List<ResolvedData> resolvedData)
protected boolean	getDefaultTreatBitAsInteger()
String	getTypeName()
boolean	isPlatformSupported(IDatabasePlatform platform)
void	setSymmetricEngine(ISymmetricEngine engine)

Methods inherited from class org.jumpmind.symmetric.load.AbstractDataLoaderFactory

buildParameterDatabaseWriterSettings

Methods inherited from class java.lang.Object

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

Field Details

log

protected final org.slf4j.Logger log

engine

protected ISymmetricEngine engine

conflictLosingParentRows

protected Set<String> conflictLosingParentRows

targetTableMap

protected Map<String,Table> targetTableMap

Constructor Details

DefaultDataLoaderFactory

public DefaultDataLoaderFactory()

DefaultDataLoaderFactory

public DefaultDataLoaderFactory(ISymmetricEngine engine)

Method Details

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface IDataLoaderFactory

getDataWriter

public IDataWriter getDataWriter(String sourceNodeId,
 Channel channel,
 ISymmetricDialect symmetricDialect,
 TransformWriter transformWriter,
 List<IDatabaseWriterFilter> filters,
 List<IDatabaseWriterErrorHandler> errorHandlers,
 List<? extends Conflict> conflictSettings,
 List<ResolvedData> resolvedData)

Specified by:

getDataWriter in interface IDataLoaderFactory

isPlatformSupported

public boolean isPlatformSupported(IDatabasePlatform platform)

Specified by:

isPlatformSupported in interface IDataLoaderFactory

buildDatabaseWriterSettings

protected DatabaseWriterSettings buildDatabaseWriterSettings(List<IDatabaseWriterFilter> filters,
 List<IDatabaseWriterErrorHandler> errorHandlers,
 List<? extends Conflict> conflictSettings,
 List<ResolvedData> resolvedDatas)

getDefaultTreatBitAsInteger

protected boolean getDefaultTreatBitAsInteger()

Overrides:

getDefaultTreatBitAsInteger in class AbstractDataLoaderFactory

setSymmetricEngine

public void setSymmetricEngine(ISymmetricEngine engine)

Specified by:

setSymmetricEngine in interface ISymmetricEngineAware