com.continuent.tungsten.replicator.applier.batch
Class VerticaStreamBatchApplier

java.lang.Object
  com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier
      com.continuent.tungsten.replicator.applier.batch.VerticaStreamBatchApplier

All Implemented Interfaces:

RawApplier, ReplicatorPlugin

public class VerticaStreamBatchApplier
extends SimpleBatchApplier

Implements an applier that bulk loads data into a Vertica database via stream interface.

Version:

1.0

Author:

Linas Virbalas

Field Summary

Fields inherited from class com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier

charset, cleanUpFiles, commitSeqnoTable, conn, consistencySelect, consistencyTable, dateFormatter, DELETE, driver, heartbeatTable, ignoreSessionPattern, INSERT, metadataSchema, onLoadMismatch, password, showCommands, stageColumnPrefix, stageDirectory, stageMergeScript, stagePkeyColumn, stageSchemaPrefix, stageTablePrefix, startupScript, statement, timezone, url, user

Constructor Summary

VerticaStreamBatchApplier()

Method Summary

protected void

load(CsvInfo info)

Methods inherited from class com.continuent.tungsten.replicator.applier.batch.SimpleBatchApplier

apply, assertNotNull, clearStageTable, commit, configure, getCsvString, getLastEvent, initializeGenerator, prepare, release, rollback, setCharset, setCleanUpFiles, setDriver, setOnLoadMismatch, setPassword, setShowCommands, setStageColumnPrefix, setStageDirectory, setStageMergeScript, setStagePkeyColumn, setStageSchemaPrefix, setStageTablePrefix, setStartupScript, setTaskId, setTimezone, setUrl, setUser

Methods inherited from class java.lang.Object

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

Constructor Detail

VerticaStreamBatchApplier

public VerticaStreamBatchApplier()

Method Detail

load

protected void load(CsvInfo info)
             throws ReplicatorException

Throws:

ReplicatorException