| Modifier and Type | Class and Description |
|---|---|
class |
AbstractStep |
| Modifier and Type | Method and Description |
|---|---|
org.pentaho.di.core.BlockingRowSet |
RemoteStep.openReaderSocket(BaseStep baseStep) |
void |
RemoteStep.openServerSocket(BaseStep baseStep) |
| Constructor and Description |
|---|
AbstractFileErrorHandler(Date date,
String destinationDirectory,
String fileExtension,
String encoding,
BaseStep baseStep) |
FileErrorHandlerContentLineNumber(Date date,
String destinationDirectory,
String fileExtension,
String encoding,
BaseStep baseStep) |
FileErrorHandlerMissingFiles(Date date,
String destinationDirectory,
String fileExtension,
String encoding,
BaseStep baseStep) |
| Modifier and Type | Class and Description |
|---|---|
class |
Abort
Step that will abort after having seen 'x' number of rows on its input.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AccessInput
Read all Access files, convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AccessOutput
Writes rows to a database table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AddSequence
Adds a sequential number to a stream of rows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AnalyticQuery
Performs analytic queries (LEAD/LAG, etc) based on a group
|
| Modifier and Type | Class and Description |
|---|---|
class |
Append
Read all rows from a hop until the end, and then read the rows from another hop.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AutoDoc
Reads a set of transformation and job filenames and documents those.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BlockingStep
A step that blocks throughput until the input ends, then it will either output the last row or the complete input.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BlockUntilStepsFinish
Block all incoming rows until defined steps finish processing rows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Calculator
Calculate new field values using pre-defined functions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ChangeFileEncoding
Change file encoding *
|
| Modifier and Type | Class and Description |
|---|---|
class |
CheckSum
Caculate a checksum for each row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CloneRow
Clone input row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClosureGenerator
Reads information from a database table by using freehand SQL
|
| Modifier and Type | Class and Description |
|---|---|
class |
ColumnExists
Check if a column exists in table on a specified connection *
|
| Modifier and Type | Class and Description |
|---|---|
class |
CombinationLookup
Manages or looks up information in a Type 1 or junk dimension.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConcatFields |
| Modifier and Type | Class and Description |
|---|---|
class |
Constant
Generates a number of (empty or the same) rows
|
| Modifier and Type | Class and Description |
|---|---|
class |
CreditCardValidator
Check if a Credit Card is valid *
|
| Modifier and Type | Class and Description |
|---|---|
class |
CsvInput
Read a simple CSV file Just output Strings found in the file...
|
| Modifier and Type | Class and Description |
|---|---|
class |
CubeInput |
| Modifier and Type | Class and Description |
|---|---|
class |
CubeOutput
Outputs a stream/series of rows to a file, effectively building a sort of (compressed) microcube.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DatabaseJoin
Use values from input streams to joins with values in a database.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DatabaseLookup
Looks up values in a database using keys from input streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DataGrid
Generates a number of (empty or the same) rows
|
| Modifier and Type | Class and Description |
|---|---|
class |
DBProc
Retrieves values from a database by calling database stored procedures or functions
|
| Modifier and Type | Class and Description |
|---|---|
class |
Delay
Delay input row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Delete
Delete data in a database table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Denormaliser
Denormalises data based on key-value pairs
|
| Modifier and Type | Class and Description |
|---|---|
class |
DetectEmptyStream
Detect empty stream.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DetectLastRow
Detect last row in a stream
|
| Modifier and Type | Class and Description |
|---|---|
class |
DimensionLookup
Manages a slowly changing dimension (lookup or update)
|
| Modifier and Type | Class and Description |
|---|---|
class |
DummyTrans
Do nothing.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DynamicSQLRow
Run dynamic SQL.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Edi2Xml |
| Modifier and Type | Class and Description |
|---|---|
class |
ExcelInput
This class reads data from one or more Microsoft Excel files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExcelOutput
Converts input rows to excel cells and then writes this information to one or more files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExcelWriterStep |
| Modifier and Type | Class and Description |
|---|---|
class |
ExecProcess
Execute a process *
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExecSQLRow
Execute one or more SQL statements in a script, one time or parameterised (for every row)
|
| Modifier and Type | Class and Description |
|---|---|
class |
FieldsChangeSequence
Add sequence to each input row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FieldSplitter
Split a single String fields into multiple parts based on certain conditions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileExists
Check if a table exists in a Database *
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseFileInputStep<M extends BaseFileInputStepMeta,D extends BaseFileInputStepData>
This class contains base functionality for file-based input steps.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileLocked
Check if a file is locked *
|
| Modifier and Type | Class and Description |
|---|---|
class |
FilesFromResult
Reads results from a previous transformation in a Job
|
| Modifier and Type | Class and Description |
|---|---|
class |
FilesToResult
Writes filenames to a next job entry in a Job
|
| Modifier and Type | Class and Description |
|---|---|
class |
FilterRows
Filters input rows base on conditions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FixedInput
Read a simple fixed width file Just output fields found in the file...
|
| Modifier and Type | Class and Description |
|---|---|
class |
Flattener
Pivots data based on key-value pairs
|
| Modifier and Type | Class and Description |
|---|---|
class |
Formula
Calculate new field values using pre-defined functions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FuzzyMatch
Performs a fuzzy match for each main stream field row An approximative match is done in a lookup stream
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetFileNames
Read all sorts of text files, convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetFilesRowsCount
Read all files, count rows number
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetRepositoryNames
Read all sorts of text files, convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetSlaveSequence
Adds a sequential number to a stream of rows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetSubFolders
Read all subfolder inside a specified folder and convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetTableNames
Return tables name list from Database connection *
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetVariable
Get information from the System or the supervising transformation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GroupBy
Groups informations based on aggregation rules.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HTTP
Retrieves values from a database by calling database stored procedures or functions
|
| Modifier and Type | Class and Description |
|---|---|
class |
HTTPPOST
Make a HTTP Post call
|
| Modifier and Type | Class and Description |
|---|---|
class |
IfNull
Sets a field value to a constant if it is null
|
| Modifier and Type | Class and Description |
|---|---|
class |
InfobrightLoader
Uses named pipe capability to load Kettle-sourced data into an Infobright table.
|
| Constructor and Description |
|---|
KettleEtlLogger(BaseStep step) |
| Modifier and Type | Class and Description |
|---|---|
class |
Injector
Executor class to allow a java program to inject rows of data into a transformation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
InsertUpdate
Performs a lookup in a database table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IngresVectorwiseLoader
Performs a streaming bulk load to a VectorWise table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Janino
Calculate new field values using pre-defined functions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JavaFilter
Calculate new field values using pre-defined functions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JobExecutor
Execute a job for every input row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JoinRows
Performs a cartesian product between 2 or more input streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LDAPInput
Read LDAP Host, convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LDAPOutput
Write to LDAP.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LDIFInput
Read all LDIF files, convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LoadFileInput
Read files, parse them and convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Mail
Send mail step.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MailInput
Read data from POP3/IMAP server and input data to the next steps.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MailValidator
Check if an email address is valid *
|
| Modifier and Type | Class and Description |
|---|---|
class |
Mapping
Execute a mapping: a re-usuable transformation
|
| Modifier and Type | Class and Description |
|---|---|
class |
MappingInput
Do nothing.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MappingOutput
Do nothing.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MemoryGroupBy
Groups information based on aggregation rules.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MergeJoin
Merge rows from 2 sorted streams and output joined rows with matched key fields.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MergeRows
Merge rows from 2 sorted streams to detect changes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MondrianInput
Reads information from a database table by using freehand SQL
|
| Modifier and Type | Class and Description |
|---|---|
class |
MonetDBAgileMart |
| Modifier and Type | Class and Description |
|---|---|
class |
MonetDBBulkLoader
Performs a bulk load to a MonetDB table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MultiMergeJoin
Merge rows from 2 sorted streams and output joined rows with matched key fields.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MySQLBulkLoader
Performs a streaming bulk load to a MySQL table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Normaliser
Normalise de-normalised input data.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NullIf
NullIf step, put null as value when the original field matches a specific value.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NumberRange
Business logic for the NumberRange
|
| Modifier and Type | Class and Description |
|---|---|
class |
OlapInput
Reads information from an OLAP datasource using MDX
|
| Modifier and Type | Class and Description |
|---|---|
class |
OraBulkLoader
Performs a bulk load to an oracle table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ParGzipCsvInput
Read a simple CSV file Just output Strings found in the file...
|
| Modifier and Type | Class and Description |
|---|---|
class |
PentahoReportingOutput
Outputs a stream/series of rows to a file, effectively building a sort of (compressed) microcube.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PGBulkLoader
Performs a bulk load to a postgres table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PGPDecryptStream
Decrypt a stream with GPG *
|
| Modifier and Type | Class and Description |
|---|---|
class |
PGPEncryptStream
Encrypt a stream with GPG *
|
| Modifier and Type | Class and Description |
|---|---|
class |
PrioritizeStreams
Prioritize INPUT Streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ProcessFiles
Copy, move or delete file *
|
| Modifier and Type | Class and Description |
|---|---|
class |
PropertyInput
Read all Properties files (& INI files) , convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PropertyOutput
Output rows to Properties file and create a file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RandomCCNumberGenerator
Generate random credit card number.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RandomValue
Get random value.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RegexEval
Use regular expression to validate a field or capture new fields out of an existing field.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ReplaceString
Search and replace in string.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ReservoirSampling |
| Modifier and Type | Class and Description |
|---|---|
class |
Rest |
| Modifier and Type | Class and Description |
|---|---|
class |
RowGenerator
Generates a number of (empty or the same) rows
|
| Modifier and Type | Class and Description |
|---|---|
class |
RowsFromResult
Reads results from a previous transformation in a Job
|
| Modifier and Type | Class and Description |
|---|---|
class |
RowsToResult
Writes results to a next transformation in a Job
|
| Modifier and Type | Class and Description |
|---|---|
class |
RssInput
Read data from RSS and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RssOutput
Output rows to RSS feed and create a file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SampleRows
Sample rows.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SasInput
Reads data from a SAS file in SAS7BAT format.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Script
Executes a JavaScript on the values in the input stream.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ScriptValuesMod
Executes a JavaScript on the values in the input stream.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SelectValues
Select, re-order, remove or change the meta-data of the fields in the inputstreams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SetValueConstant
Replace Field value by a constant value.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SetValueField
Set value field with another value field.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SetVariable
Convert Values in a certain fields to other values
|
| Modifier and Type | Class and Description |
|---|---|
class |
SFTPPut
Send file to SFTP host.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SimpleMapping
Execute a mapping: a re-usuable transformation
|
| Modifier and Type | Class and Description |
|---|---|
class |
SingleThreader
Execute a mapping: a re-usuable transformation
|
| Modifier and Type | Class and Description |
|---|---|
class |
SocketReader
Read data from a TCP/IP socket supplied by SocketWriter.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SocketWriter
Write data to a TCP/IP socket read by SocketReader.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SortRows
Sort the rows in the input-streams based on certain criteria
|
| Modifier and Type | Class and Description |
|---|---|
class |
SortedMerge
Do nothing.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SplitFieldToRows |
| Modifier and Type | Class and Description |
|---|---|
class |
ExecSQL
Execute one or more SQL statements in a script, one time or parameterised (for every row)
|
| Modifier and Type | Class and Description |
|---|---|
class |
SQLFileOutput
Writes rows to a sql file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SSH
Write commands to SSH *
|
| Modifier and Type | Class and Description |
|---|---|
class |
StepMetastructure
Return the structure of the stream
|
| Modifier and Type | Class and Description |
|---|---|
class |
StepsMetrics
Ouptu step metrics
|
| Modifier and Type | Class and Description |
|---|---|
class |
StreamLookup
Looks up information by first reading data into a hash table (in memory)
TODO: add warning with conflicting types OR modify the lookup values to the input row type.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StringCut
Cut strings.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StringOperations
Apply certain operations too string.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SwitchCase
Filters input rows base on conditions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SecretKeyGenerator
Generate secret key.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SymmetricCryptoTrans
Symmetric algorithm Executes a SymmetricCryptoTrans on the values in the input stream.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SynchronizeAfterMerge
Performs an insert/update/delete depending on the value of a field.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SyslogMessage
Write message to SyslogMessage *
|
| Modifier and Type | Class and Description |
|---|---|
class |
SystemData
Get information from the System or the supervising transformation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TableAgileMart |
| Modifier and Type | Class and Description |
|---|---|
class |
TableCompare |
| Modifier and Type | Class and Description |
|---|---|
class |
TableExists
Check if a table exists in a Database *
|
| Modifier and Type | Class and Description |
|---|---|
class |
TableInput
Reads information from a database table by using freehand SQL
|
| Modifier and Type | Class and Description |
|---|---|
class |
TableOutput
Writes rows to a database table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TeraFast |
| Modifier and Type | Class and Description |
|---|---|
class |
TextFileInput
Deprecated.
replaced by implementation in the ...steps.fileinput.text package
|
| Modifier and Type | Class and Description |
|---|---|
class |
TextFileOutput
Converts input rows to text and then writes this text to one or more files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TransExecutor
Execute a transformation for every input row, set parameters.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniqueRows
Removes the same consequetive rows from the input stream(s).
|
| Modifier and Type | Class and Description |
|---|---|
class |
UniqueRowsByHashSet |
| Modifier and Type | Class and Description |
|---|---|
class |
UnivariateStats
Calculate univariate statistics based on one column of the input data.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Update
Update data in a database table, does NOT ever perform an insert.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UserDefinedJavaClass |
| Modifier and Type | Class and Description |
|---|---|
class |
Validator
Calculate new field values using pre-defined functions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ValueMapper
Convert Values in a certain fields to other values
|
| Modifier and Type | Class and Description |
|---|---|
class |
WebServiceAvailable
Check if a webservice is available *
|
| Modifier and Type | Class and Description |
|---|---|
class |
WebService |
| Modifier and Type | Class and Description |
|---|---|
class |
WriteToLog
Write data to log.
|
| Modifier and Type | Class and Description |
|---|---|
class |
XBaseInput
Reads data from an XBase (dBase, foxpro, ...) file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
YamlInput
Read YAML files, parse them and convert them to rows and writes these to one or more output streams.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ZipFile
Zip file *
|