Package org.jumpmind.symmetric.io

Class HbaseDatabaseWriter

java.lang.Object

org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

org.jumpmind.symmetric.io.HbaseDatabaseWriter

All Implemented Interfaces:

IDataResource, IDataWriter

public class HbaseDatabaseWriter
extends AbstractDatabaseWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

AbstractDatabaseWriter.LoadStatus

Field Summary

Fields inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

batch, CONFLICT_ERROR, CONFLICT_IGNORE, conflictResolver, context, isRequiresSavePointsInTransaction, lastApplyChangesOnly, lastData, lastUseConflictDetection, missingTables, sourceTable, statistics, targetTable, targetTables, TRANSACTION_ABORTED, uncommittedCount, writerSettings

Constructor Summary

Constructors

Constructor	Description
HbaseDatabaseWriter(String hbaseSiteXmlPath)

Method Summary

Modifier and Type	Method	Description
protected boolean	create(CsvData data)
protected AbstractDatabaseWriter.LoadStatus	delete(CsvData data, boolean useConflictDetection)
protected AbstractDatabaseWriter.LoadStatus	insert(CsvData data)
protected void	logFailureDetails(Throwable e, CsvData data, boolean logLastDmlDetails)
protected AbstractDatabaseWriter.LoadStatus	put(CsvData data)
protected void	setup()
protected boolean	sql(CsvData data)
protected AbstractDatabaseWriter.LoadStatus	update(CsvData data, boolean applyChangesOnly, boolean useConflictDetection)

Methods inherited from class org.jumpmind.symmetric.io.data.writer.AbstractDatabaseWriter

allowInsertIntoAutoIncrementColumns, bindVariables, checkForEarlyCommit, close, commit, end, end, filterAfter, filterBefore, filterError, getBatch, getConflictResolver, getContext, getLookupDataMap, getPkDataFor, getRowData, getSourceTable, getStatistics, getTargetTable, getWriterSettings, hasFilterThatHandlesMissingTable, lookupTableAtTarget, notifyFiltersBatchCommitted, notifyFiltersBatchComplete, notifyFiltersBatchRolledback, notifyFiltersEarlyCommit, open, rollback, script, setConflictResolver, start, start, targetTableWasChangedByFilter, write

Methods inherited from class java.lang.Object

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

Constructor Details

HbaseDatabaseWriter

public HbaseDatabaseWriter(String hbaseSiteXmlPath)

Method Details

setup

protected void setup()

put

protected AbstractDatabaseWriter.LoadStatus put(CsvData data)

insert

protected AbstractDatabaseWriter.LoadStatus insert(CsvData data)

Specified by:

insert in class AbstractDatabaseWriter

delete

protected AbstractDatabaseWriter.LoadStatus delete(CsvData data,
 boolean useConflictDetection)

Specified by:

delete in class AbstractDatabaseWriter

update

protected AbstractDatabaseWriter.LoadStatus update(CsvData data,
 boolean applyChangesOnly,
 boolean useConflictDetection)

Specified by:

update in class AbstractDatabaseWriter

create

protected boolean create(CsvData data)

Specified by:

create in class AbstractDatabaseWriter

sql

protected boolean sql(CsvData data)

Specified by:

sql in class AbstractDatabaseWriter

logFailureDetails

protected void logFailureDetails(Throwable e,
 CsvData data,
 boolean logLastDmlDetails)

Specified by:

logFailureDetails in class AbstractDatabaseWriter