|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.trans.step.BaseStep org.pentaho.di.trans.steps.gpbulkloader.GPBulkLoader
public class GPBulkLoader
Performs a bulk load to an Greenplum table. Based on (copied from) Sven Boden's Oracle Bulk Loader step
Field Summary |
---|
Fields inherited from class org.pentaho.di.trans.step.BaseStep |
---|
first, linesInput, linesOutput, linesRead, linesRejected, linesSkipped, linesUpdated, linesWritten, terminator, terminator_rows |
Constructor Summary | |
---|---|
GPBulkLoader(StepMeta stepMeta,
StepDataInterface stepDataInterface,
int copyNr,
TransMeta transMeta,
Trans trans)
|
Method Summary | |
---|---|
String |
createCommandLine(GPBulkLoaderMeta meta,
boolean password)
Create the command line for a psql process depending on the meta information supplied. |
void |
createControlFile(String filename,
Object[] row,
GPBulkLoaderMeta meta)
Create a control file. |
void |
dispose(StepMetaInterface smi,
StepDataInterface sdi)
Dispose of this step: close files, empty logs, etc. |
boolean |
execute(GPBulkLoaderMeta meta,
boolean wait)
|
String |
getControlFileContents(GPBulkLoaderMeta meta,
RowMetaInterface rm,
Object[] r)
Get the contents of the control file as specified in the meta object |
boolean |
init(StepMetaInterface smi,
StepDataInterface sdi)
Initialize and do work where other steps need to wait for... |
boolean |
processRow(StepMetaInterface smi,
StepDataInterface sdi)
Perform the equivalent of processing one row. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.core.variables.VariableSpace |
---|
copyVariablesFrom, environmentSubstitute, environmentSubstitute, getBooleanValueOfVariable, getParentVariableSpace, getVariable, getVariable, initializeVariablesFrom, injectVariables, listVariables, setParentVariableSpace, setVariable, shareVariablesWith |
Constructor Detail |
---|
public GPBulkLoader(StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta, Trans trans)
Method Detail |
---|
public String getControlFileContents(GPBulkLoaderMeta meta, RowMetaInterface rm, Object[] r) throws KettleException
meta
- the meta object to model the control file after
KettleException
public void createControlFile(String filename, Object[] row, GPBulkLoaderMeta meta) throws KettleException
filename
- meta
-
KettleException
public String createCommandLine(GPBulkLoaderMeta meta, boolean password) throws KettleException
meta
- The meta data to create the command line frompassword
- Use the real password or not
KettleException
- Upon any exceptionpublic boolean execute(GPBulkLoaderMeta meta, boolean wait) throws KettleException
KettleException
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
StepInterface
processRow
in interface StepInterface
processRow
in class BaseStep
smi
- The steps metadata to work withsdi
- The steps temporary working data to work with (database connections, result sets, caches, temporary variables, etc.)
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 dispose(StepMetaInterface smi, StepDataInterface sdi)
StepInterface
dispose
in interface StepInterface
dispose
in class BaseStep
smi
- The metadata to work withsdi
- The data to dispose of
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |