Abort job

Utility

ABORT

Abort the job

opdje.abort.JobEntryAbort

Add filenames to result

File management

ADD_RESULT_FILENAMES

Add filenames to result

opdje.addresultfilenames.JobEntryAddResultFilenames

Amazon EMR Job Executor

Big Data

EMRJobExecutorPlugin

Execute MapReduce jobs in Amazon EMR

org.pentaho.amazon.emr.job.AmazonElasticMapReduceJobExecutor

Amazon Hive Job Executor

Big Data

HiveJobExecutorPlugin

Execute Hive jobs in Amazon EMR

org.pentaho.amazon.hive.job. AmazonHiveJobExecutor

BulkLoad from Mysql into file

Bulk loading

MYSQL_BULK_FILE

Load from a mysql table into a file

opdje.mysqlbulkfile.JobEntryMysqlBulkFile

BulkLoad into MSSQL

Bulk loading

MSSQL_BULK_LOAD

Load data from a file into a MSSQL table

opdje.mssqlbulkload.JobEntryMssqlBulkLoad

BulkLoad into Mysql

Bulk loading

MYSQL_BULK_LOAD

Load data from a file into a Mysql table

opdje.mysqlbulkload.JobEntryMysqlBulkLoad

Check Db connections

Conditions

CHECK_DB_CONNECTIONS

Check if we can connect to one or several databases.

opdje.checkdbconnection.JobEntryCheckDbConnections

Check files locked

Conditions

CHECK_FILES_LOCKED

Check if one or several files are locked by another process

opdje.checkfilelocked.JobEntryCheckFilesLocked

Check if a folder is empty

Conditions

FOLDER_IS_EMPTY

Check if a folder is empty

opdje.folderisempty.JobEntryFolderIsEmpty

Check if connected to repository

Repository

CONNECTED_TO_REPOSITORY

Return true if we are connected to a repository

opdje.connectedtorepository.JobEntryConnectedToRepository

Check if XML file is well formed

XML

XML_WELL_FORMED

Check if one or several XML files is/are well formed

opdje.xmlwellformed.JobEntryXMLWellFormed

Check webservice availability

Conditions

WEBSERVICE_AVAILABLE

Check if a webservice is available

opdje.webserviceavailable.JobEntryWebServiceAvailable

Checks if files exist

Conditions

FILES_EXIST

Checks if files exists

opdje.filesexist.JobEntryFilesExist

Columns exist in a table

Conditions

COLUMNS_EXIST

Check if one or several columns exist in a table on a specified connection

opdje.columnsexist.JobEntryColumnsExist

Compare folders

File management

FOLDERS_COMPARE

compare two folders (or two files)

opdje.folderscompare.JobEntryFoldersCompare

Convert file between Windows and Unix

File management

DOS_UNIX_CONVERTER

Convert file content between Windows and Unix. Converting to Unix will replace CRLF (Carriage Return and line Feed) by LF (Line Feed)

opdje.dostounix.JobEntryDosToUnix

Copy Files

File management

COPY_FILES

Copy Files

opdje.copyfiles.JobEntryCopyFiles

Copy or Move result filenames

File management

COPY_MOVE_RESULT_FILENAMES

Copy or Move result filenames (since version 5.0, this job entry has been renamed to Process result filenames and handles Delete as well)

opdje.copymoveresultfilenames.JobEntryCopyMoveResultFilenames

Create a folder

File management

CREATE_FOLDER

Create a folder

opdje.createfolder.JobEntryCreateFolder

Create file

File management

CREATE_FILE

Create (an empty) file

opdje.createfile.JobEntryCreateFile

Decrypt files with PGP

File encryption

PGP_DECRYPT_FILES

Decrypt files encrypted with PGP (Pretty Good Privacy). This job entry need GnuPG to work properly.

opdje.pgpdecryptfiles.JobEntryPGPDecryptFiles

Delete file

File management

DELETE_FILE

Delete a file

opdje.deletefile.JobEntryDeleteFile

Delete filenames from result

File management

DELETE_RESULT_FILENAMES

Delete filenames from result

opdje.deleteresultfilenames.JobEntryDeleteResultFilenames

Delete files

File management

DELETE_FILES

Delete files

opdje.deletefiles.JobEntryDeleteFiles

Delete folders

File management

DELETE_FOLDERS

Delete specified folders. Attention : if a the folder contains files, PDI will delete them all!

opdje.deletefolders.JobEntryDeleteFolders

Display Msgbox Info

Utility

MSGBOX_INFO

Display a simple Message box Information

opdje.msgboxinfo.JobEntryMsgBoxInfo

DTD Validator

XML

DTD_VALIDATOR

DTD Validator

opdje.dtdvalidator.JobEntryDTDValidator

Dummy

General

DUMMY (internal: SPECIAL)

Use the Dummy job entry to do nothing in a job.

opdje.special.JobEntrySpecial

Encrypt files with PGP

File encryption

PGP_ENCRYPT_FILES

Encrypt files with PGP (Pretty Good Privacy). This job entry need GnuPG to work properly.

opdje.pgpencryptfiles.JobEntryPGPEncryptFiles

Evaluate files metrics

Conditions

EVAL_FILES_METRICS

Evaluate files size or files count

opdje.evalfilesmetrics.JobEntryEvalFilesMetrics

Evaluate rows number in a table

Conditions

EVAL_TABLE_CONTENT

Evaluate the content of a table. You can also specify a SQL query.

opdje.evaluatetablecontent.JobEntryEvalTableContent

Example plugin

General

DummyJob

This is an example test job entry for a plugin

pdi.jobentry.dummy.JobEntryDummy

Export repository to XML file

Repository

EXPORT_REPOSITORY

Export repository to XML file

opdje.exportrepository.JobEntryExportRepository

File Compare

File management

FILE_COMPARE

Compare 2 files

opdje.filecompare.JobEntryFileCompare

File Exists

Conditions

FILE_EXISTS

Checks if a file exists

opdje.fileexists.JobEntryFileExists

FTP Delete

File transfer

FTP_DELETE

Delete files in a remote host

opdje.ftpdelete.JobEntryFTPDelete

Get a file with FTP

File transfer

FTP

Get files using FTP (File Transfer Protocol)

opdje.ftp.JobEntryFTP

Get a file with FTPS

File transfer

FTPS_GET

Get a file with FTP secure

opdje.ftpsget.JobEntryFTPSGet

Get a file with SFTP

File transfer

SFTP

Get files using Secure FTP (Secure File Transfer Protocol)

opdje.sftp.JobEntrySFTP

Get mails (POP3/IMAP)

Mail

GET_POP

Get mails (POP3/IMAP) server and save into a local folder

opdje.getpop.JobEntryGetPOP

Hadoop Copy Files

Big Data

Hadoop job executor

Big Data

HadoopJobExecutorPlugin

Execute a map/reduce job contained in a jar file

opdje.hadoopjobexecutor.JobEntryHadoopJobExecutor

HL7 MLLP Acknowledge

Utility

HL7 MLLP Input

Utility

HTTP

File management

HTTP

Gets or uploads a file using HTTP (HyperText Transfer Protocol)

opdje.http.JobEntryHTTP

JavaScript

Scripting

EVAL

Evaluates the result of the execution of a previous job entry

opdje.eval.JobEntryEval

Job

General

JOB

Executes a job

opdje.job.JobEntryJob

Mail

Mail

MAIL

Sends an e-Mail

opdje.mail.JobEntryMail

Mail validator

Mail

JobCategory.Category.Mail_VALIDATOR

Check the validity of an email address ( SNMP trap to a target host

opdje.mailvalidator.JobEntryMailValidator

Move Files

File management

MOVE_FILES

Move Files

opdje.movefiles.JobEntryMoveFiles

MS Access Bulk Load

Deprecated

MS_ACCESS_BULK_LOAD

Load data into a Microsoft Access table from CSV file format. ATTENTION, at the moment only the insertion is available! If target table exists, a new one will be created and data inserted.

opdje.msaccessbulkload.JobEntryMSAccessBulkLoad

Oozie Job Executor

Big Data

Palo Cube Create (Deprecated)

Deprecated

PALO_CUBE_CREATE

Creates a cube on a Palo server

opdje.palo.JobEntryCubeCreate

Palo Cube Delete (Deprecated)

Deprecated

PALO_CUBE_DELETE

Deletes a cube on a Palo server

opdje.palo.JobEntryCubeDelete

Pentaho MapReduce

Big Data

HadoopTransJobExecutorPlugin

Execute Transformation Based MapReduce Jobs in Hadoop

opdjw.hadooptransjobexecutor.JobEntryHadoopTransJobExecutor

Pig Script Executor

Big Data

HadoopPigScriptExecutorPlugin

Execute a Pig script on a Hadoop cluster

opdje.pig.JobEntryPigScriptExecutor

Ping a host

Utility

PING

Ping a host

opdje.ping.JobEntryPing

Put a file with FTP

File transfer

FTP_PUT

Put a file with FTP

opdje.ftpput.JobEntryFTPPUT

Process result filenames

File management

COPY_MOVE_RESULT_FILENAMES

Copy, Move or Delete result filenames

opdje.copymoveresultfilenames.JobEntryCopyMoveResultFilenames

Put a file with SFTP

File transfer

SFTPPUT

Put files using SFTP (Secure File Transfer Protocol)

opdje.sftpput.JobEntrySFTPPUT

Send information using Syslog

Utility

SYSLOG

Sends information to another server using the Syslog protocol.

opdje.syslog.JobEntrySys