Package org.jumpmind.symmetric.io

Class HbaseDataLoaderFactory

java.lang.Object

org.jumpmind.symmetric.load.AbstractDataLoaderFactory

org.jumpmind.symmetric.load.DefaultDataLoaderFactory

org.jumpmind.symmetric.io.HbaseDataLoaderFactory

All Implemented Interfaces:

IBuiltInExtensionPoint, IExtensionPoint, ISymmetricEngineAware, IDataLoaderFactory

public class HbaseDataLoaderFactory
extends DefaultDataLoaderFactory
implements IBuiltInExtensionPoint

Field Summary

Fields

Modifier and Type	Field	Description
protected IDataWriter	hbaseDataWriter
protected String	hbaseSiteXmlPath
protected String	typeName

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

conflictLosingParentRows, engine, log, targetTableMap

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

parameterService

Constructor Summary

Constructors

Constructor	Description
HbaseDataLoaderFactory()

Method Summary

Modifier and Type	Method	Description
IDataWriter	getDataWriter(String sourceNodeId, Channel channel, ISymmetricDialect symmetricDialect, TransformWriter transformWriter, List<IDatabaseWriterFilter> filters, List<IDatabaseWriterErrorHandler> errorHandlers, List<? extends Conflict> conflictSettings, List<ResolvedData> resolvedData)
String	getTypeName()
void	setTypeName(String typeName)

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

buildDatabaseWriterSettings, getDefaultTreatBitAsInteger, isPlatformSupported, setSymmetricEngine

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

typeName

protected String typeName

hbaseSiteXmlPath

protected String hbaseSiteXmlPath

hbaseDataWriter

protected IDataWriter hbaseDataWriter

Constructor Details

HbaseDataLoaderFactory

public HbaseDataLoaderFactory()

Method Details

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface IDataLoaderFactory

Overrides:

getTypeName in class DefaultDataLoaderFactory

setTypeName

public void setTypeName(String typeName)

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

Overrides:

getDataWriter in class DefaultDataLoaderFactory