|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.pentaho.di.trans.step.BaseStep
org.pentaho.di.trans.steps.pgbulkloader.PGBulkLoader
public class PGBulkLoader
Performs a bulk load to a postgres table. Based on (copied from) Sven Boden's Oracle Bulk Loader step
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary |
---|
Fields inherited from class org.pentaho.di.trans.step.BaseStep |
---|
category_order, errorRowSet, first, init, inputRowSets, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, outputRowSets, paused, remoteInputSteps, remoteOutputSteps, statusDesc, steps, stopped, terminator, terminator_rows, thr, waiting |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
PGBulkLoader(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
String |
createCommandLine(PGBulkLoaderMeta meta,
boolean password)
Create the command line for a psql process depending on the meta information supplied. |
boolean |
execute(PGBulkLoaderMeta meta,
boolean wait)
|
String |
getCopyCommand(org.pentaho.di.core.row.RowMetaInterface rm,
Object[] r)
Get the contents of the control file as specified in the meta object |
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
Initialise and do work where other steps need to wait for... |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process one row. |
void |
run()
Run is where the action happens in a step... |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.trans.step.StepInterface |
---|
addRowListener, addStepListener, cleanup, dispose, getCopy, getErrors, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesUpdated, getLinesWritten, getOutputRowSets, getPartitionID, getRow, getRowListeners, getStepID, getStepMeta, getStepname, initBeforeStart, isAlive, isMapping, isPartitioned, isStopped, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, setErrors, setLinesRejected, setOutputDone, setPartitionID, start, stopAll, stopRunning |
Constructor Detail |
---|
public PGBulkLoader(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
Method Detail |
---|
public String getCopyCommand(org.pentaho.di.core.row.RowMetaInterface rm, Object[] r) throws org.pentaho.di.core.exception.KettleException
meta
- the meta object to model the control file after
org.pentaho.di.core.exception.KettleException
public String createCommandLine(PGBulkLoaderMeta meta, boolean password) throws org.pentaho.di.core.exception.KettleException
meta
- The meta data to create the command line frompassword
- Use the real password or not
org.pentaho.di.core.exception.KettleException
- Upon any exceptionpublic boolean execute(PGBulkLoaderMeta meta, boolean wait) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
StepInterface
processRow
in interface StepInterface
processRow
in class BaseStep
smi
- The metadata to work withsdi
- The temporary working data to work with (database connections, resultsets, caches, temporary variables, etc.)
org.pentaho.di.core.exception.KettleException
public boolean init(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
init
in interface StepInterface
init
in class BaseStep
smi
- The metadata to work withsdi
- The data to initializepublic void run()
StepInterface
run
in interface Runnable
run
in interface StepInterface
run
in class Thread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |