org.pentaho.di.trans.steps.monetdbagilemart

Class MonetDBAgileMart

java.lang.Object

org.pentaho.di.trans.step.BaseStep

org.pentaho.di.trans.steps.monetdbbulkloader.MonetDBBulkLoader

org.pentaho.di.trans.steps.monetdbagilemart.MonetDBAgileMart

All Implemented Interfaces:

ExtensionDataInterface, HasLogChannelInterface, LoggingObjectInterface, TableManager, VariableSpace, StepInterface

public class MonetDBAgileMart
extends MonetDBBulkLoader
implements TableManager

Field Summary

Fields inherited from class org.pentaho.di.trans.steps.monetdbbulkloader.MonetDBBulkLoader

rowsWritten

Fields inherited from class org.pentaho.di.trans.step.BaseStep

deadLockCounter, extensionDataMap, first, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, log, metaStore, repository, rowListeners, safeStopped, terminator, terminator_rows, variables

Constructor Summary

Constructors

Constructor and Description
MonetDBAgileMart(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)

Method Summary

Modifier and Type	Method and Description
boolean	adjustSchema() Adjust schema.
boolean	dropTable() Drops the current table.
boolean	execute(MonetDBBulkLoaderMeta meta, boolean wait)
boolean	flush() Write the current buffer to the mclient.
boolean	init(StepMetaInterface smi, StepDataInterface sdi) Initialize and do work where other steps need to wait for...
void	setRowLimit(long rowLimit) Sets the row limit.
void	setTableName(String tableName) Sets the table name.
boolean	truncateTable() Truncates the current table.
protected void	writeRowToMonetDB(RowMetaInterface rowMeta, Object[] r)

Methods inherited from class org.pentaho.di.trans.steps.monetdbbulkloader.MonetDBBulkLoader

addRowToBuffer, autoAdjustSchema, dispose, drop, escapeOsPath, executeSql, executeSql, getData, getMessage, getMeta, getMonetDBConnection, getMonetDBConnection, getMonetDBConnection, processRow, setMessage, truncate, writeBufferToMonetDB

Methods inherited from class org.pentaho.di.trans.step.BaseStep

addResultFile, addRowListener, addRowSetToInputRowSets, addRowSetToOutputRowSets, addStepListener, batchComplete, buildLog, canProcessOneRow, checkFeedback, cleanup, clearInputRowSets, clearOutputRowSets, closeQuietly, copyVariablesFrom, decrementLinesRead, decrementLinesWritten, dispatch, environmentSubstitute, environmentSubstitute, fieldSubstitute, findInputRowSet, findInputRowSet, findOutputRowSet, findOutputRowSet, getBooleanValueOfVariable, getClusterSize, getContainerObjectId, getCopy, getCurrentInputRowSetNr, getCurrentOutputRowSetNr, getDispatcher, getErrorRowMeta, getErrors, getExtensionDataMap, getFilename, getFirstInputRowSet, getInputRowMeta, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesSkipped, getLinesUpdated, getLinesWritten, getLogChannel, getLogChannelId, getLogFields, getLogLevel, getMetaStore, getNextClassNr, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getOutputRowSets, getParent, getParentVariableSpace, getPartitionID, getPartitionTargets, getPreviewRowMeta, getProcessed, getRegistrationDate, getRemoteInputSteps, getRemoteOutputSteps, getRepartitioning, getRepository, getRepositoryDirectory, getResultFiles, getRow, getRowFrom, getRowHandler, getRowListeners, getRuntime, getServerSockets, getSlaveNr, getSocketRepository, getStatus, getStatusDescription, getStepDataInterface, getStepID, getStepListeners, getStepMeta, getStepMetaInterface, getStepname, getTrans, getTransMeta, getTypeId, getUniqueStepCountAcrossSlaves, getUniqueStepNrAcrossSlaves, getVariable, getVariable, handleGetRowFrom, handlePutRowTo, identifyErrorOutput, incrementLinesInput, incrementLinesOutput, incrementLinesRead, incrementLinesRejected, incrementLinesSkipped, incrementLinesUpdated, incrementLinesWritten, initBeforeStart, initializeVariablesFrom, injectVariables, isBasic, isDebug, isDetailed, isDistributed, isForcingSeparateLogging, isGatheringMetrics, isInitialising, isMapping, isPartitioned, isPaused, isRowLevel, isRunning, isSafeStopped, isStopped, isUsingThreadPriorityManagment, listVariables, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, logSummary, markStart, markStop, openRemoteInputStepSocketsOnce, openRemoteOutputStepSocketsOnce, outputIsDone, pauseRunning, putError, putRow, putRowTo, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, safeModeChecking, safeModeChecking, setCarteObjectId, setCopy, setCurrentInputRowSetNr, setCurrentOutputRowSetNr, setDistributed, setErrorRowMeta, setErrors, setForcingSeparateLogging, setGatheringMetrics, setInputRowMeta, setInputRowSets, setInternalVariables, setLinesInput, setLinesOutput, setLinesRead, setLinesRejected, setLinesSkipped, setLinesUpdated, setLinesWritten, setLogLevel, setMetaStore, setOutputDone, setOutputRowSets, setParentVariableSpace, setPartitioned, setPartitionID, setPartitionTargets, setPaused, setPaused, setPreviewRowMeta, setRepartitioning, setRepository, setRowHandler, setRunning, setSafeStopped, setServerSockets, setSocketRepository, setStepDataInterface, setStepListeners, setStepMeta, setStepMetaInterface, setStepname, setStopped, setTransMeta, setUsingThreadPriorityManagment, setVariable, shareVariablesWith, stopAll, stopRunning, stopRunning, swapFirstInputRowSetIfExists, toString, verifyInputDeadLock, waitUntilTransformationIsStarted

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.pentaho.di.core.TableManager

getMessage

Methods inherited from interface org.pentaho.di.trans.step.StepInterface

addRowListener, addRowSetToInputRowSets, addRowSetToOutputRowSets, addStepListener, batchComplete, canProcessOneRow, cleanup, getCopy, getCurrentInputRowSetNr, getCurrentOutputRowSetNr, getErrors, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesUpdated, getLinesWritten, getLogChannel, getMetaStore, getOutputRowSets, getPartitionID, getProcessed, getRepository, getResultFiles, getRow, getRowListeners, getRuntime, getStatus, getStepID, getStepMeta, getStepname, getTrans, identifyErrorOutput, initBeforeStart, isMapping, isPartitioned, isPaused, isRunning, isSafeStopped, isStopped, isUsingThreadPriorityManagment, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, setCurrentInputRowSetNr, setCurrentOutputRowSetNr, setErrors, setLinesRejected, setMetaStore, setOutputDone, setPartitioned, setPartitionID, setRepartitioning, setRepository, setRunning, setSafeStopped, setStopped, setUsingThreadPriorityManagment, stopAll, stopRunning, subStatuses

Methods inherited from interface org.pentaho.di.core.variables.VariableSpace

copyVariablesFrom, environmentSubstitute, environmentSubstitute, fieldSubstitute, getBooleanValueOfVariable, getParentVariableSpace, getVariable, getVariable, initializeVariablesFrom, injectVariables, listVariables, setParentVariableSpace, setVariable, shareVariablesWith

Constructor Detail

MonetDBAgileMart

public MonetDBAgileMart(StepMeta stepMeta,
                        StepDataInterface stepDataInterface,
                        int copyNr,
                        TransMeta transMeta,
                        Trans trans)

Method Detail

init

public boolean init(StepMetaInterface smi,
                    StepDataInterface sdi)

Description copied from interface: StepInterface

Initialize and do work where other steps need to wait for...

Specified by:

init in interface StepInterface

Overrides:

init in class MonetDBBulkLoader

Parameters:

smi - The metadata to work with

sdi - The data to initialize

execute

public boolean execute(MonetDBBulkLoaderMeta meta,
                       boolean wait)
                throws KettleException

Overrides:

execute in class MonetDBBulkLoader

Throws:

KettleException

writeRowToMonetDB

protected void writeRowToMonetDB(RowMetaInterface rowMeta,
                                 Object[] r)
                          throws KettleException

Overrides:

writeRowToMonetDB in class MonetDBBulkLoader

Throws:

KettleException

setRowLimit

public void setRowLimit(long rowLimit)

Description copied from interface: TableManager

Sets the row limit. This is used to limit the data loaded during a specific execution. This value might change every time the transformation is executed.

Specified by:

setRowLimit in interface TableManager

flush

public boolean flush()

Write the current buffer to the mclient. This is called when a data load is cancelled

Specified by:

flush in interface TableManager

Returns:

truncateTable

public boolean truncateTable()

Description copied from interface: TableManager

Truncates the current table. This is used during management operations.

Specified by:

truncateTable in interface TableManager

Returns:

true if the operation succeeded

setTableName

public void setTableName(String tableName)

Description copied from interface: TableManager

Sets the table name. If the name of the database table is determined programatically this method can be used to set the table name.

Specified by:

setTableName in interface TableManager

adjustSchema

public boolean adjustSchema()

Description copied from interface: TableManager

Adjust schema. This is used to change the schema when the input fields change.

Specified by:

adjustSchema in interface TableManager

Returns:

true if the operation succeeded

dropTable

public boolean dropTable()

Description copied from interface: TableManager

Drops the current table. This is used during management operations.

Specified by:

dropTable in interface TableManager

Returns:

true if the operation succeeded