Components

Image Name Description Data Integration Map/Reduce Spark Batch Spark Streaming Storm Camel
AWS
Image cAWSConnection Establishes a connection to Amazon Web Services for data storage and retrieval. Delete Delete Delete Delete Delete Apply
Image cAWSS3 Stores and retrieves objects from/to Amazon's Simple Storage Service (S3) Delete Delete Delete Delete Delete Apply
Image cAWSSES Sends emails with Amazon's Simple Email Service (SES). Delete Delete Delete Delete Delete Apply
Image cAWSSNS Sends messages to an Amazon's Simple Notification topic. Delete Delete Delete Delete Delete Apply
Image cAWSSQS Sends and receives messages to/from Amazon's Simple Queue Service (SQS). The AWS SQS FIFO Feature for Queues are supported. Delete Delete Delete Delete Delete Apply
Big Data
Image tBigQueryBulkExec Transfers given data to Google BigQuery. Apply Delete Delete Delete Delete Delete
Image tBigQueryInput Performs the queries supported by Google BigQuery. Apply Delete Apply Apply Delete Delete
Image tBigQueryOutput Transfers the data provided by its preceding component to Google BigQuery. Apply Delete Apply Apply Delete Delete
Image tBigQueryOutputBulk Creates a .txt or .csv file for the data of large size so that you can process it according to your needs before transferring it to Google BigQuery. Apply Delete Delete Delete Delete Delete
Image tBigQuerySQLRow Connects to Google BigQuery and performs queries to select data from tables row by row or create or delete tables in Google BigQuery. Apply Delete Delete Delete Delete Delete
Image tCassandraBulkExec Improves performance during Insert operations to a Cassandra column family. Apply Delete Delete Delete Delete Delete
Image tCassandraClose Disconnects a connection to a Cassandra server so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tCassandraConnection Enables the reuse of the connection it creates to a Cassandra server. Apply Delete Delete Delete Delete Delete
Image tCassandraOutput Writes data into or deletes data from a column family of a Cassandra keyspace. Apply Delete Apply Apply Delete Delete
Image tCassandraOutputBulk Prepares an SSTable of large size and processes it according to your needs before loading this SSTable into a column family of a Cassandra keyspace. Apply Delete Delete Delete Delete Delete
Image tCassandraOutputBulkExec Improves performance during Insert operations to a column family of a Cassandra keyspace. Apply Delete Delete Delete Delete Delete
Image tCassandraRow Acts on the actual DB structure or on the data, depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tDBFSConnection Connects to a given DBFS (Databricks Filesystem) system so that the other DBFS components can reuse the connection it creates to communicate with this DBFS. Apply Delete Delete Delete Delete Delete
Image tDBFSGet Copies files from a given DBFS (Databricks Filesystem) system, pastes them in a user-defined directory and if needs be, renames them. Apply Delete Delete Delete Delete Delete
Image tDBFSPut Connects to a given DBFS (Databricks Filesystem) system, copies files from an user-defined directory, pastes them in this system and if needs be, renames these files. Apply Delete Delete Delete Delete Delete
Image tDynamoDBOutput Creates, updates or deletes data in an Amazon DynamoDB table. Apply Delete Apply Apply Delete Delete
Image tGSBucketCreate Creates a new bucket which you can use to organize data and control access to data in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSBucketDelete Deletes an empty bucket in Google Cloud Storage so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSBucketExist Checks the existence of a bucket in Google Cloud Storage so as to make further operations. Apply Delete Delete Delete Delete Delete
Image tGSBucketList Retrieves a list of buckets from all projects or one specific project in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSClose Closes an active connection to Google Cloud Storage in order to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSConnection Provides the authentication information for making requests to the Google Cloud Storage system and enables the reuse of the connection it creates to Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSCopy Copies or moves objects within a bucket or between buckets in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSDelete Deletes the objects which match the specified criteria in Google Cloud Storage so as to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSGet Retrieves objects which match the specified criteria from Google Cloud Storage and outputs them to a local directory. Apply Delete Delete Delete Delete Delete
Image tGSList Retrieves a list of objects from Google Cloud Storage one by one. Apply Delete Delete Delete Delete Delete
Image tGSPut Uploads files from a local directory to Google Cloud Storage so that you can manage them with Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tHBaseClose Closes an HBase connection you have established in your Job. Apply Delete Delete Delete Delete Delete
Image tHBaseConnection Establishes an HBase connection to be reused by other HBase components in your Job. Apply Delete Delete Delete Delete Delete
Image tHCatalogInput Reads data from an HCatalog managed Hive database and send data to the component that follows. Apply Delete Delete Delete Delete Delete
Image tHCatalogLoad Reads data directly from HDFS and writes this data into an established HCatalog managed table. Apply Delete Delete Delete Delete Delete
Image tHCatalogOperation Prepares the HCatalog managed database/table/partition to be processed. Apply Delete Delete Delete Delete Delete
Image tHCatalogOutput Receives data from its incoming flow and writes this data into an HCatalog managed table. Apply Delete Delete Delete Delete Delete
Image tHDFSCompare Compares two files in HDFS and based on the read-only schema, generates a row flow that presents the comparison information. Apply Delete Delete Delete Delete Delete
Image tHDFSConnection Connects to a given HDFS so that the other Hadoop components can reuse the connection it creates to communicate with this HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSCopy Copies a source file or folder into a target directory in HDFS and removes this source if required. Apply Delete Delete Delete Delete Delete
Image tHDFSDelete Deletes a file located on a given Hadoop distributed file system (HDFS). Apply Delete Delete Delete Delete Delete
Image tHDFSExist Checks whether a file exists in a specific directory in HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSGet Copies files from Hadoop distributed file system(HDFS), pastes them in a user-defined directory and if needs be, renames them. Apply Delete Delete Delete Delete Delete
Image tHDFSInput Extracts the data in a HDFS file for other components to process it. Apply Delete Delete Delete Delete Delete
Image tHDFSList tHDFSList retrieves a list of files or folders based on a filemask pattern and iterates on each unity. Apply Delete Delete Delete Delete Delete
Image tHDFSOutput Writes data flows it receives into a given Hadoop distributed file system (HDFS). Apply Delete Delete Delete Delete Delete
Image tHDFSOutputRaw Transfers data of different formats such as hierarchical data in the form of a single column into a given HDFS file system. Apply Delete Delete Delete Delete Delete
Image tHDFSProperties Creates a single row flow that displays the properties of a file processed in HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSPut Connects to Hadoop distributed file system to load large-scale files into it with optimized performance. Apply Delete Delete Delete Delete Delete
Image tHDFSRename Renames the selected files or specified directory on HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSRowCount Reads a file in HDFS row by row in order to determine the number of rows this file contains. Apply Delete Delete Delete Delete Delete
Image tHiveClose Closes connection to a Hive database. Apply Delete Delete Delete Delete Delete
Image tHiveConnection Establishes a Hive connection to be reused by other Hive components in your Job. Apply Delete Delete Delete Delete Delete
Image tHiveCreateTable Creates Hive tables that fit a wide range of Hive data formats. Apply Delete Delete Delete Delete Delete
Image tHiveLoad Writes data of different formats into a given Hive table or to export data from a Hive table to a directory. Apply Delete Delete Delete Delete Delete
Image tHiveRow Acts on the actual DB structure or on the data without handling data itself, depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tImpalaClose Closes connection to an Impala database. Apply Delete Delete Delete Delete Delete
Image tImpalaConnection Establishes an Impala connection to be reused by other Impala components in your Job. Apply Delete Delete Delete Delete Delete
Image tImpalaCreateTable Creates Impala tables that fit a wide range of Impala data formats. Apply Delete Delete Delete Delete Delete
Image tImpalaInput Executes the select queries to extract the corresponding data and sends the data to the component that follows. Apply Delete Delete Delete Delete Delete
Image tImpalaLoad Writes data of different formats into a given Impala table or to export data from an Impala table to a directory. Apply Delete Delete Delete Delete Delete
Image tImpalaOutput Executes the action defined on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tImpalaRow Acts on the actual DB structure or on the data (although without handling data). Apply Delete Delete Delete Delete Delete
Image tMapRDBClose Closes an MapRDB connection you have established in a same Job. Apply Delete Delete Delete Delete Delete
Image tMapRDBConnection Establishes a MapRDB connection to be reused by other MapRDB components in a same Job. Apply Delete Delete Delete Delete Delete
Image tMarkLogicBulkLoad Imports local files into a MarkLogic server database in bulk mode using the MarkLogic Content Pump (MLCP) tool. Apply Delete Delete Delete Delete Delete
Image tMarkLogicClose Closes an active connection to a MarkLogic database to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tMarkLogicConnection Opens a connection to a MarkLogic database that can then be reused by other MarkLogic components. Apply Delete Delete Delete Delete Delete
Image tMarkLogicInput Searches document content in a MarkLogic database based on a string query. Apply Delete Delete Delete Delete Delete
Image tMarkLogicOutput Creates, updates or deletes document content in a MarkLogic database. Apply Delete Delete Delete Delete Delete
Image tMongoDBBulkLoad Imports data files in different formats (CSV, TSV or JSON) into the specified MongoDB database so that the data can be further processed. Apply Delete Delete Delete Delete Delete
Image tMongoDBClose Closes a connection to the MongoDB database. Apply Delete Delete Delete Delete Delete
Image tMongoDBConnection Creates a connection to a MongoDB database and reuse that connection in other components. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSDelete Automates the delete action over specific files in MongoDB GridFS. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSGet Connects to a MongoDB GridFS system to copy files from it. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSList Retrieves a list of files based on a query. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSProperties Obtains information about the properties of given files selected based on a query. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSPut Connects to a MongoDB GridFS system to load files into it. Apply Delete Delete Delete Delete Delete
Image tMongoDBOutput Executes the action defined on the collection in the MongoDB database. Apply Delete Apply Apply Delete Delete
Image tMongoDBRow Executes the commands and functions of the MongoDB database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchOutput Receives data from the preceding component and writes the data into a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchOutputRelationship Receives data from the preceding component and writes relationships in bulk into a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchSchema Defines the schema of a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jClose Close an active connection to an Neo4j database in embedded mode. Apply Delete Delete Delete Delete Delete
Image tNeo4jConnection Opens a connection to a Neo4j database to be reuse by other Neo4j components. Apply Delete Delete Delete Delete Delete
Image tNeo4jImportTool Uses Neo4j Import Tool to create a Neo4j database and import large amounts of data in bulk from CSV files to this database. Apply Delete Delete Delete Delete Delete
Image tNeo4jInput Reads data from Neo4j and sends data in the output flow. Apply Delete Delete Delete Delete Delete
Image tNeo4jRow Executes the stated Cypher query onto the specified Neo4J database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Close Closes a connection to a Neo4j version 4.x database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Connection Establishes a connection to a Neo4j version 4.x database for later use. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Input Reads data from Neo4j version 4.x and sends data in the output flow. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Output Receives data from the preceding component and writes the data into a Neo4j version 4.x database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Row Executes the stated Cypher query onto the specified Neo4J version 4.x database. Apply Delete Delete Delete Delete Delete
Image tSqoopExport Defines the arguments required by Sqoop for transferring data to a RDBMS. Apply Delete Delete Delete Delete Delete
Image tSqoopImport Defines the arguments required by Sqoop for writing the data of your interest into HDFS. Apply Delete Delete Delete Delete Delete
Image tSqoopImportAllTables Defines the arguments required by Sqoop for writing all of the tables of a database into HDFS. Apply Delete Delete Delete Delete Delete
Image tSqoopMerge Performs an incremental import that updates an older dataset with newer records. The file types of the newer and the older datasets must be the same. Apply Delete Delete Delete Delete Delete
Business
Image tBonitaDeploy Deploys a specific Bonita process to a Bonita Runtime. Apply Delete Delete Delete Delete Delete
Image tBonitaInstantiateProcess Starts an instance for a specific process deployed in a Bonita Runtime engine. Apply Delete Delete Delete Delete Delete
Image tJIRAInput Retrieves the issue information based on a JQL query or retrieve the project information based on a specified project ID from JIRA. Apply Delete Delete Delete Delete Delete
Image tJIRAOutput Inserts, updates, or deletes the issue or project information in JIRA. Apply Delete Delete Delete Delete Delete
Image tLDAPAttributesInput Analyses each object found via the LDAP query and lists a collection of attributes associated with the object. Apply Delete Delete Delete Delete Delete
Image tLDAPClose Disconnects one connection to the LDAP Directory server so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tLDAPConnection Creates a connection to an LDAP Directory server. Apply Delete Delete Delete Delete Delete
Image tLDAPInput Executes an LDAP query based on the given filter and corresponding to the schema definition. Then it passes on the field list to the next component via a Row > Main link. Apply Delete Delete Delete Delete Delete
Image tLDAPOutput Executes an LDAP query based on the given filter and corresponding to the schema definition. Then it passes on the field list to the next component via a Row > Main link. Apply Delete Delete Delete Delete Delete
Image tLDAPRenameEntry Renames ones or more entries in a specific LDAP directory. Apply Delete Delete Delete Delete Delete
Image tMarketoBulkExec Imports leads or custom objects into Marketo from a local file in the REST API mode. Apply Delete Delete Delete Delete Delete
Image tMarketoCampaign Retrieves campaign records, activity and campaign changes related data from Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoConnection Opens a connection to Marketo that can then be reused by other Marketo components. Apply Delete Delete Delete Delete Delete
Image tMarketoInput Retrieves lead records, activity history, lead changes, and custom object related data from Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoListOperation Adds/removes one or more leads to/from a list in Marketo. Also, it helps you verify the existence of one or more leads in a list in Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoOutput Writes lead records or custom object records from the incoming data flow into Marketo. Apply Delete Delete Delete Delete Delete
Image tMicrosoftCrmInput Extracts data from a Microsoft CRM database based on conditions set on specific columns. Apply Delete Delete Delete Delete Delete
Image tMicrosoftCrmOutput Writes data into a Microsoft CRM database. Apply Delete Delete Delete Delete Delete
Image tNetsuiteConnection Creates a connection to the NetSuite SOAP server so that other NetSuite components in the Job can reuse the connection. Apply Delete Delete Delete Delete Delete
Image tNetsuiteInput Invokes the NetSuite SOAP service and retrieves data according to the conditions you specify. Apply Delete Delete Delete Delete Delete
Image tNetsuiteOutput Invokes the NetSuite SOAP service and inserts, updates, or removes data on the NetSuite SOAP server. Apply Delete Delete Delete Delete Delete
Image tNetSuiteV2019Connection Creates a connection to a NetSuite SOAP server by leveraging NetSuite v2019 features so that other NetSuite V2019 components in the Job can reuse the connection. Apply Delete Delete Delete Delete Delete
Image tNetSuiteV2019Input Invokes the NetSuite SOAP service and retrieves data according to the conditions you specify by leveraging NetSuite v2019 features. Apply Delete Delete Delete Delete Delete
Image tNetSuiteV2019Output Invokes the NetSuite SOAP service and inserts, updates, or removes data on the NetSuite SOAP server by leveraging NetSuite v2019 features. Apply Delete Delete Delete Delete Delete
Image tSalesforceBulkExec Bulk-loads data in a given file into a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceConnection Opens a connection to Salesforce. Apply Delete Delete Delete Delete Delete
Image tSalesforceEinsteinBulkExec Loads data into Salesforce Analytics Cloud from a local file. Apply Delete Delete Delete Delete Delete
Image tSalesforceEinsteinOutputBulkExec Gains in performance during data operations to the Salesforce Analytics Cloud. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetDeleted Collects data deleted during a specific period of time from a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetServerTimestamp Retrieves the current date of the Salesforce server presented in a timestamp format. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetUpdated Collects data updated during a specific period of time from a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceInput Retrieves data from a Salesforce object based on a query. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutput Inserts, updates, upserts, or deletes data in a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutputBulk Generates the file to be processed by the tSalesforceBulkExec component for bulk processing. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutputBulkExec Bulk-loads data in a given file into a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSAPADSOInput Retrieves data of an active ADSO (Advanced Data Store Object) from an SAP BW system on an SAP HANA database or through SAP Java Connector. Apply Delete Delete Delete Delete Delete
Image tSAPBapi Extracts data from or loads data to an SAP server using multiple input/output parameters or the document type parameter. Apply Delete Delete Delete Delete Delete
Image tSAPCommit Commits a global transaction in one go, using a unique connection, instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSAPConnection Commits a whole Job data in one go to the SAP system as one transaction. Apply Delete Delete Delete Delete Delete
Image tSAPDataSourceOutput Writes Data Source objects into an SAP BW Data Source system. Apply Delete Delete Delete Delete Delete
Image tSAPDataSourceReceiver Retrieves data requests stored on Talend SAP RFC server and related to a specific Data Source system. Apply Delete Delete Delete Delete Delete
Image tSAPDSOInput Retrieves DSO data from an SAP BW system. Apply Delete Delete Delete Delete Delete
Image tSAPDSOOutput Creates or updates DSO data in an SAP BW table. Apply Delete Delete Delete Delete Delete
Image tSAPIDocInput Extracts IDoc data set that is used for asynchronous transactions between SAP systems or between a SAP system and another application. Apply Delete Delete Delete Delete Delete
Image tSAPIDocOutput Uploads IDoc data set in XML fomat to an SAP system. Apply Delete Delete Delete Delete Delete
Image tSAPIDocReceiver Extracts data from SAP IDocs stored on an SAP server. Apply Delete Delete Delete Delete Delete
Image tSAPInfoCubeInput Retrieves InfoCube data from an SAP BW system. Apply Delete Delete Delete Delete Delete
Image tSAPInfoObjectInput Retrieves InfoObject data from an SAP BW system. Apply Delete Delete Delete Delete Delete
Image tSAPInfoObjectOutput Writes InfoObject data into an SAP BW system. Apply Delete Delete Delete Delete Delete
Image tSAPODPInput Extracts business data from the ERP part of SAP (SAP Business application, SAP on HANA, SAP R/3, and S4/HANA) through ODP (Operational Data Provisioning). Apply Delete Delete Delete Delete Delete
Image tSAPRollback Cancels the transaction commit in the connected SAP. Apply Delete Delete Delete Delete Delete
Image tSAPTableInput Reads data from an SAP table on an SAP server. Apply Delete Delete Delete Delete Delete
Image tServiceNowConnection Opens a connection to a ServiceNow instance that can then be reused by other ServiceNow components. Apply Delete Delete Delete Delete Delete
Image tServiceNowInput Accesses ServiceNow and retrieves data from it. Apply Delete Delete Delete Delete Delete
Image tServiceNowOutput Performs the defined action on the data on ServiceNow. Apply Delete Delete Delete Delete Delete
Image tWorkdayInput Retrieves data of a Workday client based on a query or the Workday client report. Apply Delete Delete Delete Delete Delete
Business Intelligence
Image tSplunkEventCollector Sends the event data to Splunk through Splunk HTTP Event Collector. Apply Delete Delete Delete Delete Delete
Business_Intelligence
Image tBarChart Generates a bar chart from the input data to ease technical analysis. Apply Delete Delete Delete Delete Delete
Image tDB2SCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table Apply Delete Delete Delete Delete Delete
Image tDB2SCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated DB2 SCD table. Apply Delete Delete Delete Delete Delete
Image tGreenplumSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tInformixSCD Tracks and shows changes which have been made to Informix SCD dedicated tables Apply Delete Delete Delete Delete Delete
Image tJasperOutput Creates a report in rich formats using Jaspersoft's iReport. Apply Delete Delete Delete Delete Delete
Image tJasperOutputExec Creates a report in rich formats using Jaspersoft's iReport and offers a performance gain as it functions as a combination of an input component and a tJasperOutput component. Apply Delete Delete Delete Delete Delete
Image tJDBCSCDELT Tracks data changes in a source database table using SCD (Slowly Changing Dimensions) Type 1 method and/or Type 2 method and writes both the current and historical data into a specified SCD dimension table. Apply Delete Delete Delete Delete Delete
Image tLineChart Reads data from an input flow and transforms the data into a line chart in a PNG image file to ease technical analysis. Apply Delete Delete Delete Delete Delete
Image tMSSqlSCD Tracks and reflects changes in a dedicated SCD table in a Microsoft SQL Server or Azure SQL database. Apply Delete Delete Delete Delete Delete
Image tMysqlSCD Reflects and tracks changes in a dedicated MySQL SCD table. Apply Delete Delete Delete Delete Delete
Image tMysqlSCDELT Reflects and tracks changes in a dedicated MySQL SCD table through SQL queries. Apply Delete Delete Delete Delete Delete
Image tNetezzaSCD Reflects and tracks changes in a dedicated Netezza SCD table. Apply Delete Delete Delete Delete Delete
Image tOracleSCD Reflects and tracks changes in a dedicated Oracle SCD table. Apply Delete Delete Delete Delete Delete
Image tOracleSCDELT Reflects and tracks changes in a dedicated Oracle SCD table through SQL queries. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated PostgresPlus SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresqlSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresqlSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated DB2 SCD table. Apply Delete Delete Delete Delete Delete
Image tSybaseSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tSybaseSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated Sybase SCD table. Apply Delete Delete Delete Delete Delete
Image tTeradataSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tTeradataSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated Teradata SCD table. Apply Delete Delete Delete Delete Delete
Image tVerticaSCD Tracks and reflects data changes in a dedicated Vertica SCD table. Apply Delete Delete Delete Delete Delete
Cloud
Image tAmazonAuroraClose Closes an active connection to an Amazon Aurora database instance to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraConnection Opens a connection to an Amazon Aurora database instance that can then be reused by other Amazon Aurora components. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraInput Reads an Amazon Aurora database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraInvalidRows Checks Amazon Aurora database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Only MySQL is supported. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraOutput Writes, updates, makes changes or suppresses entries in an Amazon Aurora database. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraRollback Rolls back any changes made in the Amazon Aurora database to prevent partial transaction commit if an error occurs. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraRow Executes query statements on a specified Amazon Aurora database table. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraValidRows Checks Amazon Aurora database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Only MySQL is supported. Apply Delete Delete Delete Delete Delete
Image tAmazonEMRListInstances Lists the details about the instance groups in a cluster on Amazon EMR (Elastic MapReduce). Apply Delete Delete Delete Delete Delete
Image tAmazonEMRManage Launches or terminates a cluster on Amazon EMR (Elastic MapReduce). Apply Delete Delete Delete Delete Delete
Image tAmazonEMRResize Adds or resizes a task instance group in a cluster on Amazon EMR (Elastic MapReduce). Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlClose Closes the transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlConnection Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlRollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlRow Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleClose Closes the transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleConnection Apply Delete Delete Delete Delete Delete
Image tAmazonOracleInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleRollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleRow Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAmazonRedshiftManage Manages Amazon Redshift clusters and snapshots. Apply Delete Delete Delete Delete Delete
Image tAzureAdlsGen2Input Retrieves data from an ADLS Gen2 file system of an Azure storage account and passes the data to the subsequent component connected to it through a Main>Row link. Apply Delete Delete Delete Delete Delete
Image tAzureAdlsGen2Output Uploads incoming data to an ADLS Gen2 file system of an Azure storage account in the specified format. Apply Delete Delete Delete Delete Delete
Image tAzureStorageConnection Uses authentication and the protocol information to create a connection to the Microsoft Azure Storage system that can then be reused by other Azure Storage components. Apply Delete Delete Delete Delete Delete
Image tAzureStorageContainerCreate Creates a new storage container used to hold Azure blobs (Binary Large Object) for a given Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageContainerDelete Automates the removal of a given blob container from the space of a specific storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageContainerExist Automates the verification of whether a given blob container exists or not within a storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageContainerList Lists all containers in a given Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageDelete Deletes blobs from a given container for an Azure storage account according to the specified blob filters. Apply Delete Delete Delete Delete Delete
Image tAzureStorageGet Retrieves blobs from a given container for an Azure storage account according to the specified filters applied on the virtual hierarchy of the blobs and then write selected blobs in a local folder. Apply Delete Delete Delete Delete Delete
Image tAzureStorageInputTable Retrieves a set of entities that satisfy the specified filter criteria from an Azure storage table. Apply Delete Delete Delete Delete Delete
Image tAzureStorageList Lists blobs in a given container according to the specified blob filters. Apply Delete Delete Delete Delete Delete
Image tAzureStorageOutputTable Performs the defined action on a given Azure storage table and inserts, replaces, merges or deletes entities in the table based on the incoming data from the preceding component. Apply Delete Delete Delete Delete Delete
Image tAzureStoragePut Uploads local files into a given container for an Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueCreate Creates a new queue under a given Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueDelete Deletes a specified queue permanently under a given Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueInput Retrieves one or more messages from the front of an Azure queue. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueInputLoop Runs an endless loop to retrieve messages from the front of an Azure queue. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueList Returns all queues associated with the given Azure storage account. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueueOutput Adds messages to the back of an Azure queue. Apply Delete Delete Delete Delete Delete
Image tAzureStorageQueuePurge Purges messages in an Azure queue. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseBulkExec Loads data into an Azure SQL Data Warehouse table from either Azure Blob Storage or Azure Data Lake Storage. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseClose Closes an active connection to an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseCommit Commits in one go a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseConnection Opens a connection to an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseInput Reads data and extracts fields based on a query from an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseOutput Writes, updates, makes changes or suppresses entries in an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseRollback Cancels the transaction commit in the connected Azure SQL Data Warehouse database to prevent partial transaction commit if an error occurs. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseRow Executes an SQL query stated on an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tBoxConnection Creates a Box connection that the other Box components can reuse. Apply Delete Delete Delete Delete Delete
Image tBoxCopy Copies or moves a given folder or file from Box. Apply Delete Delete Delete Delete Delete
Image tBoxDelete Removes a given folder or file from Box. Apply Delete Delete Delete Delete Delete
Image tBoxGet Downloads a selected file from a Box account. Apply Delete Delete Delete Delete Delete
Image tBoxList Lists the files stored in a specified directory in Box. Apply Delete Delete Delete Delete Delete
Image tBoxPut Uploads files to a Box account. Apply Delete Delete Delete Delete Delete
Image tCloudStart Starts instances on Amazon EC2 (Amazon Elastic Compute Cloud). Apply Delete Delete Delete Delete Delete
Image tCloudStop Changes the status of a launched instance on Amazon EC2 (Amazon Elastic Compute Cloud). Apply Delete Delete Delete Delete Delete
Image tCosmosDBBulkLoad Imports data files in different formats (CSV, TSV or JSON) into the specified Cosmos database so that the data can be further processed. Apply Delete Delete Delete Delete Delete
Image tCosmosDBConnection Creates a connection to a CosmosDB database and reuse that connection in other components. Apply Delete Delete Delete Delete Delete
Image tCosmosDBInput Retrieves certain documents from a Cosmos database collection by supplying a query document containing the fields the desired documents should match. Apply Delete Delete Delete Delete Delete
Image tCosmosDBOutput Inserts, updates, upserts or deletes documents in a Cosmos database collection based on the incoming flow from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tCosmosDBRow Executes the commands of the Cosmos database. Apply Delete Delete Delete Delete Delete
Image tDropboxConnection Creates a Dropbox connection to a given account that the other Dropbox components can reuse. Apply Delete Delete Delete Delete Delete
Image tDropboxDelete Removes a given folder or file from Dropbox. Apply Delete Delete Delete Delete Delete
Image tDropboxGet Downloads a selected file from a Dropbox account to a specified local directory. Apply Delete Delete Delete Delete Delete
Image tDropboxList Lists the files stored in a specified directory on Dropbox. Apply Delete Delete Delete Delete Delete
Image tDropboxPut Uploads data to Dropbox from either a local file or a given data flow. Apply Delete Delete Delete Delete Delete
Image tGoogleCloudConfiguration Provides the connection configuration to Google Cloud Platform for a Spark Job. Delete Delete Delete Apply Delete Delete
Image tGoogleDataprocManage Creates or deletes a Dataproc cluster in the Global region on Google Cloud Platform. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveConnection Opens a Google Drive connection that can be reused by other Google Drive components. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveCopy Creates a copy of a file/folder in Google Drive. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveCreate Creates a new folder in Google Drive. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveDelete Deletes a file/folder in Google Drive. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveGet Gets a file's content and downloads the file to a local directory. Apply Delete Delete Delete Delete Delete
Image tGoogleDriveList Lists all files, or folders, or both files and folders in a specified Google Drive folder, in the domain, including both Shared Drive and My Drive, and all shared drives. Apply Delete Delete Delete Delete Delete
Image tGoogleDrivePut Uploads data from a data flow or a local file to Google Drive. Apply Delete Delete Delete Delete Delete
Image tGSBucketCreate Creates a new bucket which you can use to organize data and control access to data in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSBucketDelete Deletes an empty bucket in Google Cloud Storage so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSBucketExist Checks the existence of a bucket in Google Cloud Storage so as to make further operations. Apply Delete Delete Delete Delete Delete
Image tGSBucketList Retrieves a list of buckets from all projects or one specific project in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSClose Closes an active connection to Google Cloud Storage in order to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSConnection Provides the authentication information for making requests to the Google Cloud Storage system and enables the reuse of the connection it creates to Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSCopy Copies or moves objects within a bucket or between buckets in Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tGSDelete Deletes the objects which match the specified criteria in Google Cloud Storage so as to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tGSGet Retrieves objects which match the specified criteria from Google Cloud Storage and outputs them to a local directory. Apply Delete Delete Delete Delete Delete
Image tGSList Retrieves a list of objects from Google Cloud Storage one by one. Apply Delete Delete Delete Delete Delete
Image tGSPut Uploads files from a local directory to Google Cloud Storage so that you can manage them with Google Cloud Storage. Apply Delete Delete Delete Delete Delete
Image tMarketoBulkExec Imports leads or custom objects into Marketo from a local file in the REST API mode. Apply Delete Delete Delete Delete Delete
Image tMarketoCampaign Retrieves campaign records, activity and campaign changes related data from Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoConnection Opens a connection to Marketo that can then be reused by other Marketo components. Apply Delete Delete Delete Delete Delete
Image tMarketoInput Retrieves lead records, activity history, lead changes, and custom object related data from Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoListOperation Adds/removes one or more leads to/from a list in Marketo. Also, it helps you verify the existence of one or more leads in a list in Marketo. Apply Delete Delete Delete Delete Delete
Image tMarketoOutput Writes lead records or custom object records from the incoming data flow into Marketo. Apply Delete Delete Delete Delete Delete
Image tNetsuiteConnection Creates a connection to the NetSuite SOAP server so that other NetSuite components in the Job can reuse the connection. Apply Delete Delete Delete Delete Delete
Image tNetsuiteInput Invokes the NetSuite SOAP service and retrieves data according to the conditions you specify. Apply Delete Delete Delete Delete Delete
Image tNetsuiteOutput Invokes the NetSuite SOAP service and inserts, updates, or removes data on the NetSuite SOAP server. Apply Delete Delete Delete Delete Delete
Image tRedshiftBulkExec Loads data into Amazon Redshift from Amazon S3, Amazon EMR cluster, Amazon DynamoDB, or remote hosts. Apply Delete Delete Delete Delete Delete
Image tRedshiftClose Closes the transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tRedshiftCommit Provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tRedshiftConnection Apply Delete Delete Delete Delete Delete
Image tRedshiftInput Reads data from a database and extracts fields based on a query so that you may apply changes to the extracted data. Apply Delete Apply Delete Delete Delete
Image tRedshiftOutputBulk Prepares a delimited/CSV file that can be used by tRedshiftBulkExec to feed Amazon Redshift. Apply Delete Delete Delete Delete Delete
Image tRedshiftOutputBulkExec Executes the Insert action on the data provided. Apply Delete Delete Delete Delete Delete
Image tRedshiftRollback Cancels the transaction commit in the Redshift database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tRedshiftRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tRedshiftUnload Unloads data on Amazon Redshift to files on Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3BucketCreate Creates a bucket on Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3BucketDelete Deletes an empty bucket from Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3BucketExist Verifies if the specified bucket exists on Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3BucketList Lists all the buckets on Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3Close Shuts down a connection to Amazon S3, thus releasing the network resources. Apply Delete Delete Delete Delete Delete
Image tS3Connection Establishes a connection to Amazon S3 to store and retrieve data. Apply Delete Delete Delete Delete Delete
Image tS3Copy Copies an Amazon S3 object from a source bucket to a destination bucket. Apply Delete Delete Delete Delete Delete
Image tS3Delete Deletes a file from Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3Get Retrieves a file from Amazon S3. Apply Delete Delete Delete Delete Delete
Image tS3List Lists the files on Amazon S3 based on the bucket/file prefix settings. Apply Delete Delete Delete Delete Delete
Image tS3Put Uploads data onto Amazon S3 from a local file or from cache memory via the streaming mode. Apply Delete Delete Delete Delete Delete
Image tSalesforceBulkExec Bulk-loads data in a given file into a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceConnection Opens a connection to Salesforce. Apply Delete Delete Delete Delete Delete
Image tSalesforceEinsteinBulkExec Loads data into Salesforce Analytics Cloud from a local file. Apply Delete Delete Delete Delete Delete
Image tSalesforceEinsteinOutputBulkExec Gains in performance during data operations to the Salesforce Analytics Cloud. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetDeleted Collects data deleted during a specific period of time from a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetServerTimestamp Retrieves the current date of the Salesforce server presented in a timestamp format. Apply Delete Delete Delete Delete Delete
Image tSalesforceGetUpdated Collects data updated during a specific period of time from a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceInput Retrieves data from a Salesforce object based on a query. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutput Inserts, updates, upserts, or deletes data in a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutputBulk Generates the file to be processed by the tSalesforceBulkExec component for bulk processing. Apply Delete Delete Delete Delete Delete
Image tSalesforceOutputBulkExec Bulk-loads data in a given file into a Salesforce object. Apply Delete Delete Delete Delete Delete
Image tServiceNowConnection Opens a connection to a ServiceNow instance that can then be reused by other ServiceNow components. Apply Delete Delete Delete Delete Delete
Image tServiceNowInput Accesses ServiceNow and retrieves data from it. Apply Delete Delete Delete Delete Delete
Image tServiceNowOutput Performs the defined action on the data on ServiceNow. Apply Delete Delete Delete Delete Delete
Image tSnowflakeBulkExec Loads data from files in a folder into a Snowflake table. The folder can be in an internal Snowflake stage, an Amazon Simple Storage Service (Amazon S3) bucket, or an Azure container. Apply Delete Delete Delete Delete Delete
Image tSnowflakeClose Closes an active Snowflake connection to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tSnowflakeCommit Provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSnowflakeConnection Opens a connection to Snowflake that can then be reused by other Snowflake components. Apply Delete Delete Delete Delete Delete
Image tSnowflakeOutput Uses the data incoming from its preceding component to insert, update, upsert or delete data in a Snowflake table. Apply Delete Apply Delete Delete Delete
Image tSnowflakeOutputBulk Writes incoming data to files generated in a folder. The folder can be in an internal Snowflake stage, an Amazon Simple Storage Service (Amazon S3) bucket, or an Azure container. Apply Delete Delete Delete Delete Delete
Image tSnowflakeOutputBulkExec Writes incoming data to files generated in a folder and then loads the data into a Snowflake database table. The folder can be in an internal Snowflake stage, an Amazon Simple Storage Service (Amazon S3) bucket, or an Azure container. Apply Delete Delete Delete Delete Delete
Image tSnowflakeRollback Cancels the transaction commit in the Snowflake database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tSnowflakeRow Executes the SQL command stated onto a specified Snowflake database. Apply Delete Delete Delete Delete Delete
Image tSQSConnection Opens a connection to Amazon Simple Queue Service that can then be reused by other SQS components. Apply Delete Delete Delete Delete Delete
Image tSQSInput Retrieves one or more messages, with a maximum limit of ten messages, from an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSMessageChangeVisibility Changes the visibility timeout of a specified message in an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSMessageDelete Deletes a specified message from an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSOutput Delivers one or more messages to an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSQueueAttributes Gets attributes for a specified Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSQueueCreate Creates a new Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSQueueDelete Deletes an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tSQSQueueList Iterates and lists the URL of Amazon SQS (Simple Queue Service) queues in a specified region. Apply Delete Delete Delete Delete Delete
Image tSQSQueuePurge Purges messages in an Amazon SQS (Simple Queue Service) queue. Apply Delete Delete Delete Delete Delete
Image tWorkdayInput Retrieves data of a Workday client based on a query or the Workday client report. Apply Delete Delete Delete Delete Delete
Image tZendeskInput Reads tickets or requests from Zendesk server. Apply Delete Delete Delete Delete Delete
Image tZendeskOutput Writes tickets or requests to Zendesk server. Apply Delete Delete Delete Delete Delete
Connectivity
Image cAMQP Exchanges messages between a Route and a JMS provider using the AMQP broker. Delete Delete Delete Delete Delete Apply
Image cAWSConnection Establishes a connection to Amazon Web Services for data storage and retrieval. Delete Delete Delete Delete Delete Apply
Image cAWSS3 Stores and retrieves objects from/to Amazon's Simple Storage Service (S3) Delete Delete Delete Delete Delete Apply
Image cAWSSES Sends emails with Amazon's Simple Email Service (SES). Delete Delete Delete Delete Delete Apply
Image cAWSSNS Sends messages to an Amazon's Simple Notification topic. Delete Delete Delete Delete Delete Apply
Image cAWSSQS Sends and receives messages to/from Amazon's Simple Queue Service (SQS). The AWS SQS FIFO Feature for Queues are supported. Delete Delete Delete Delete Delete Apply
Image cFile Provides access to file systems, allowing files to be processed by any other components or messages from other components to be saved to the disk. Delete Delete Delete Delete Delete Apply
Image cFtp Provides access to remote file systems over the FTP, FTPS and SFTP protocols. Delete Delete Delete Delete Delete Apply
Image cHttp Provides HTTP-based endpoints for consuming and producing HTTP resources. Delete Delete Delete Delete Delete Apply
Image cJMS Exchanges messages between a Route and a JMS provider. Delete Delete Delete Delete Delete Apply
Image cKafka Communicates with Apache Kafka message broker. Delete Delete Delete Delete Delete Apply
Image cMail Sends or receives mails in a Route. Delete Delete Delete Delete Delete Apply
Image cMessagingEndpoint Allows two applications to communicate by either sending or receiving messages. Delete Delete Delete Delete Delete Apply
Image cMQConnectionFactory Encapsulates a set of configuration parameters to connect to a MQ server. The connection can be called by multiple cJMS, cWMQ, cAMQP or cMQTT components in a Route. Delete Delete Delete Delete Delete Apply
Image cMQTT Sends messages to, or consumes messages from MQTT compliant message brokers. Delete Delete Delete Delete Delete Apply
Image cREST Provides integration with Apache CXF for connecting to JAX-RS services. Delete Delete Delete Delete Delete Apply
Image cSOAP Provides integration with Apache CXF for connecting to JAX-WS services. Delete Delete Delete Delete Delete Apply
Image cWMQ Exchanges messages between a Route and a JMS provider using WMQ. Delete Delete Delete Delete Delete Apply
Core
Image cDirect Produces and consumes messages synchronously in different threads within a single CamelContext. Delete Delete Delete Delete Delete Apply
Image cDirectVM Produces and consumes messages synchronously in different threads within a single CamelContext and across CamelContexts in the same JVM. You can use this mechanism to communicate across Web applications. Delete Delete Delete Delete Delete Apply
Image cExchangePattern Sets the message exchange mode in a Route. Delete Delete Delete Delete Delete Apply
Image cJavaDSLProcessor Implements producers and consumers of message exchanges or implements a message translator using the Java Domain Specific Language (DSL). Delete Delete Delete Delete Delete Apply
Image cMessagingEndpoint Allows two applications to communicate by either sending or receiving messages. Delete Delete Delete Delete Delete Apply
Image cSEDA Produces and consumes messages asynchronously in different threads within a single CamelContext. Delete Delete Delete Delete Delete Apply
Image cSetBody Sets the message body in the Route. Delete Delete Delete Delete Delete Apply
Image cSetHeader Sets headers or customizes the default headers, if any, on each message sent to it for subsequent message processing. Delete Delete Delete Delete Delete Apply
Image cSetProperty Sets properties for each message sent to it for subsequent message processing. Delete Delete Delete Delete Delete Apply
Image cVM Produces and consumes messages asynchronously in different threads across CamelContext. You can use this mechanism to communicate across Web applications. Delete Delete Delete Delete Delete Apply
Custom
Image cBean Invokes a Java bean that is stored in the Code node of the Repository or registered by a cBeanRegister. Delete Delete Delete Delete Delete Apply
Image cBeanRegister Registers a Java bean in the registry to be used in message exchanges. Delete Delete Delete Delete Delete Apply
Image cConfig Sets the CamelContext using Java code. Delete Delete Delete Delete Delete Apply
Image cProcessor Implements consumers of message exchanges or implements a Message Translator. Delete Delete Delete Delete Delete Apply
Custom_Code
Image tGroovy tGroovy broadens the functionality if the Job, using the Groovy language which is a simplified Java syntax. Apply Delete Delete Delete Delete Delete
Image tGroovyFile Broadens the functionality of Jobs using the Groovy language which is a simplified Java syntax. Apply Delete Delete Delete Delete Delete
Image tJava Extends the functionalities of a Job using custom Java commands. Apply Delete Apply Apply Delete Delete
Image tJavaFlex Provides a Java code editor that lets you enter personalized code in order to integrate it in program. Apply Delete Delete Delete Delete Delete
Image tJavaRow Provides a code editor that lets you enter the Java code to be applied to each row of the flow. Apply Delete Apply Apply Delete Delete
Image tLibraryLoad Loads useable Java libraries in a Job. Apply Delete Apply Apply Delete Delete
Image tSetDynamicSchema Sets a dynamic schema that can be reused by components in the subsequent subJob or subJobs to retrieve data from unknown columns. Apply Delete Delete Delete Delete Delete
Image tSetGlobalVar Facilitates the process of defining global variables. Apply Delete Delete Delete Delete Delete
Data Quality
Image tMatchIndex Indexes a clean and deduplicated data set in ElasticSearch for continuous matching purposes. Delete Delete Apply Delete Delete Delete
Image tMatchIndexPredict Compares a new data set with a lookup data set stored in ElasticSearch, using tMatchIndex. tMatchIndexPredict outputs unique records and suspect duplicates in separate files. Delete Delete Apply Apply Delete Delete
Image tMatchModel Generates the matching model that is used by the tMatchPredict component to automatically predict the labels for the suspect pairs and groups records which match the label(s) set in the component properties. Delete Delete Apply Delete Delete Delete
Image tMatchPairing Enables you to compute pairs of suspect duplicates from any source data including large volumes in the context of machine learning on Spark. Delete Delete Apply Delete Delete Delete
Image tMatchPredict Labels suspect records automatically and groups suspect records which match the label(s) set in the component properties. Delete Delete Apply Delete Delete Delete
Databases
Image tAccessBulkExec Offers gains in performance when carrying out Insert operations in an Access database. Apply Delete Delete Delete Delete Delete
Image tAccessClose Closes an active connection to the Access database so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tAccessCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAccessConnection Apply Delete Delete Delete Delete Delete
Image tAccessInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAccessOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAccessOutputBulk Prepares the file which contains the data used to feed the Access database. Apply Delete Delete Delete Delete Delete
Image tAccessOutputBulkExec Executes an Insert action on the data provided, in an Access database. Apply Delete Delete Delete Delete Delete
Image tAccessRollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAccessRow Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraClose Closes an active connection to an Amazon Aurora database instance to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraConnection Opens a connection to an Amazon Aurora database instance that can then be reused by other Amazon Aurora components. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraInput Reads an Amazon Aurora database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraInvalidRows Checks Amazon Aurora database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Only MySQL is supported. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraOutput Writes, updates, makes changes or suppresses entries in an Amazon Aurora database. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraRollback Rolls back any changes made in the Amazon Aurora database to prevent partial transaction commit if an error occurs. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraRow Executes query statements on a specified Amazon Aurora database table. Apply Delete Delete Delete Delete Delete
Image tAmazonAuroraValidRows Checks Amazon Aurora database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Only MySQL is supported. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlClose Closes the transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlConnection Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlRollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAmazonMysqlRow Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleClose Closes the transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleCommit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleConnection Apply Delete Delete Delete Delete Delete
Image tAmazonOracleInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleRollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAmazonOracleRow Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAmazonRedshiftManage Manages Amazon Redshift clusters and snapshots. Apply Delete Delete Delete Delete Delete
Image tAS400CDC Addresses data extraction and transportation needs. Apply Delete Delete Delete Delete Delete
Image tAS400Close Closes the transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tAS400Commit Commits in one go a global transaction instead of doing that on every row or every batch, and provides gain in performance, using a unique connection. Apply Delete Delete Delete Delete Delete
Image tAS400Connection Apply Delete Delete Delete Delete Delete
Image tAS400Input Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tAS400LastInsertId Obtains the primary key value of the record that was last inserted in an AS/400 table. Apply Delete Delete Delete Delete Delete
Image tAS400Output Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tAS400Rollback Cancels the transaction commit in the connected database and avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tAS400Row Executes the SQL query stated onto the specified database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseBulkExec Loads data into an Azure SQL Data Warehouse table from either Azure Blob Storage or Azure Data Lake Storage. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseClose Closes an active connection to an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseCommit Commits in one go a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseConnection Opens a connection to an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseInput Reads data and extracts fields based on a query from an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseOutput Writes, updates, makes changes or suppresses entries in an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseRollback Cancels the transaction commit in the connected Azure SQL Data Warehouse database to prevent partial transaction commit if an error occurs. Apply Delete Delete Delete Delete Delete
Image tAzureSynapseRow Executes an SQL query stated on an Azure SQL Data Warehouse database. Apply Delete Delete Delete Delete Delete
Image tBigQueryConfiguration Provides the connection configuration to Google BigQuery and Google Cloud Storage for a Spark Job. Delete Delete Apply Apply Delete Delete
Image tCassandraConfiguration Enables the reuse of the connection configuration to a Cassandra server in the same Job. Delete Delete Apply Apply Delete Delete
Image tCassandraInput Extracts the desired data from a standard or super column family of a Cassandra keyspace so as to apply changes to the data. Apply Delete Apply Delete Delete Delete
Image tCassandraLookupInput Extracts the desired data from a standard or super column family of a Cassandra keyspace so as to apply changes to the data. Delete Delete Delete Apply Delete Delete
Image tCosmosDBBulkLoad Imports data files in different formats (CSV, TSV or JSON) into the specified Cosmos database so that the data can be further processed. Apply Delete Delete Delete Delete Delete
Image tCosmosDBConnection Creates a connection to a CosmosDB database and reuse that connection in other components. Apply Delete Delete Delete Delete Delete
Image tCosmosDBInput Retrieves certain documents from a Cosmos database collection by supplying a query document containing the fields the desired documents should match. Apply Delete Delete Delete Delete Delete
Image tCosmosDBOutput Inserts, updates, upserts or deletes documents in a Cosmos database collection based on the incoming flow from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tCosmosDBRow Executes the commands of the Cosmos database. Apply Delete Delete Delete Delete Delete
Image tCreateTable Creates a table for a specific type of database. Apply Delete Delete Delete Delete Delete
Image tDB2BulkExec Executes the Insert action on the provided data and gains in performance during Insert operations to a DB2 database. Apply Delete Delete Delete Delete Delete
Image tDB2CDC Extracts the changes done to the source operational data and makes them available to the target system(s) using database CDC views. Apply Delete Delete Delete Delete Delete
Image tDB2Close Closes a transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tDB2Commit Commits in one go a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tDB2Connection Apply Delete Delete Delete Delete Delete
Image tDB2Input Executes a DB query with a strictly defined order which must correspond to the schema definition. Then tDB2Input passes on the field list to the next component via a Row > Main link. Apply Delete Delete Delete Delete Delete
Image tDB2Output Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tDB2Rollback Avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tDB2Row Acts on the actual DB structure or on the data (although without handling data) depending on the nature of the query and the database. The SQLBuilder tool helps you write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tDB2SCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table Apply Delete Delete Delete Delete Delete
Image tDB2SCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated DB2 SCD table. Apply Delete Delete Delete Delete Delete
Image tDB2SP Offers a convenient way to call the database stored procedures. Apply Delete Delete Delete Delete Delete
Image tDBBulkExec Offers gains in performance while executing the Insert operations on a database. Apply Delete Delete Delete Delete Delete
Image tDBCDC Extracts only the changes made to the source operational data and makes them available to the target system(s) using database CDC views. Apply Delete Delete Delete Delete Delete
Image tDBCDCOutput Synchronizes data changes in database of the selected database type in the CDC mode. Apply Delete Delete Delete Delete Delete
Image tDBClose Closes the transaction committed in a connected database. Apply Delete Delete Delete Delete Delete
Image tDBColumnList Iterates on all columns of a given database table and lists column names. Apply Delete Delete Delete Delete Delete
Image tDBCommit Validates the data processed through the Job into the connected database. Apply Delete Delete Delete Delete Delete
Image tDBConnection Opens a connection to a database to be reused in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tDBInput Extracts data from a database. Apply Delete Delete Delete Delete Delete
Image tDBInvalidRows Checks database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tDBLastInsertId Obtains the primary key value of the record that was last inserted in a database table by a user. Apply Delete Delete Delete Delete Delete
Image tDBOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tDBOutputBulk Writes a file with columns based on the defined delimiter and the standards of the selected database type. Apply Delete Delete Delete Delete Delete
Image tDBOutputBulkExec Executes the Insert action in a database. Apply Delete Delete Delete Delete Delete
Image tDBRollback Cancels the transaction commit in a connected database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tDBRow Executes the stated SQL query onto a database. Apply Delete Delete Delete Delete Delete
Image tDBSCD Reflects and tracks changes in a dedicated database SCD table. Apply Delete Delete Delete Delete Delete
Image tDBSCDELT Reflects and tracks changes in a dedicated SCD table through SQL queries. Apply Delete Delete Delete Delete Delete
Image tDBSP Calls a database stored procedure. Apply Delete Delete Delete Delete Delete
Image tDBSQLRow Acts on the actual DB structure or on the data (although without handling data) depending on the nature of the query and the database. The SQLBuilder tool helps you write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tDBTableList Lists the names of specified database tables using a SELECT statement based on a WHERE clause. Apply Delete Delete Delete Delete Delete
Image tDBValidRows Checks database rows against Data Quality patterns (regular expression). Apply Delete Delete Delete Delete Delete
Image tDeltaLakeClose Closes an active DeltaLake connection to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tDeltaLakeConnection Opens a connection to the specified database that can then be reused in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tDeltaLakeInput Extracts the latest version or a given snapshot of records from the Delta Lake layer of your Data Lake system and sends the data to the next component for further processing. Apply Delete Apply Delete Delete Delete
Image tDeltaLakeOutput Writes records in the Delta Lake layer of your Data Lake system in the Parquet format. Apply Delete Apply Delete Delete Delete
Image tDeltaLakeRow Acts on the actual DB structure or on the data (although without handling data) using the SQLBuilder tool to write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tDynamoDBConfiguration Stores connection information and credentials to be reused by other DynamoDB components. Delete Delete Apply Apply Delete Delete
Image tDynamoDBInput Retrieves data from an Amazon DynamoDB table and sends them to the component that follows for transformation. Apply Delete Apply Delete Delete Delete
Image tDynamoDBLookupInput Executes a database query with a strictly defined order which must correspond to the schema definition. Delete Delete Delete Apply Delete Delete
Image tExasolBulkExec Imports data into an EXASolution database table using the IMPORT command provided by the EXASolution database in a fast way. Apply Delete Delete Delete Delete Delete
Image tExasolClose Closes an active connection to an EXASolution database instance to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tExasolCommit Validates the data processed through the Job into the connected EXASolution database. Apply Delete Delete Delete Delete Delete
Image tExasolConnection Opens a connection to an EXASolution database instance that can then be reused by other EXASolution components. Apply Delete Delete Delete Delete Delete
Image tExasolInput Retrieves data from an EXASolution database based on a query with a strictly defined order which corresponds to the schema definition, and passes the data to the next component. Apply Delete Delete Delete Delete Delete
Image tExasolOutput Writes, updates, modifies or deletes data in an EXASolution database by executing the action defined on the table and/or on the data in the table, based on the flow incoming from the preceding component. Apply Delete Delete Delete Delete Delete
Image tExasolRollback Cancels the transaction commit in the connected EXASolution database. Apply Delete Delete Delete Delete Delete
Image tExasolRow Executes SQL queries on an EXASolution database. Apply Delete Delete Delete Delete Delete
Image tFirebirdClose Closes a transaction with a Firebird database. Apply Delete Delete Delete Delete Delete
Image tFirebirdCommit Commits a global transaction instead of doing so on every row or every batch, thus providing a gain in performance. Apply Delete Delete Delete Delete Delete
Image tFirebirdConnection Apply Delete Delete Delete Delete Delete
Image tFirebirdInput Executes a database query on a Firebird database with a strictly defined order which must correspond to the schema definition then passes on the field list to the next component via a Main row link. Apply Delete Delete Delete Delete Delete
Image tFirebirdOutput Executes the action defined on the table in a Firebird database and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tFirebirdRollback Cancels the transation committed in the connected Firebird database. Apply Delete Delete Delete Delete Delete
Image tFirebirdRow Executes the stated SQL query on the specified Firebird database. Apply Delete Delete Delete Delete Delete
Image tGreenplumBulkExec Improves performance when loading data in a Greenplum database. Apply Delete Delete Delete Delete Delete
Image tGreenplumClose Closes a connection to the Greenplum database. Apply Delete Delete Delete Delete Delete
Image tGreenplumCommit Commits global transaction in one go instead of repeating the operation for every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tGreenplumConnection Apply Delete Delete Delete Delete Delete
Image tGreenplumGPLoad Bulk loads data into a Greenplum table either from an existing data file, an input flow, or directly from a data flow in streaming mode through a named-pipe. Apply Delete Delete Delete Delete Delete
Image tGreenplumInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tGreenplumOutput Executes the action defined on the table and/or on the data of a table, according to the input flow from the previous component. Apply Delete Delete Delete Delete Delete
Image tGreenplumOutputBulk Prepares the file to be used as parameter in the INSERT query to feed the Greenplum database. Apply Delete Delete Delete Delete Delete
Image tGreenplumOutputBulkExec Provides performance gains during Insert operations to a Greenplum database. Apply Delete Delete Delete Delete Delete
Image tGreenplumRollback Avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tGreenplumRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tGreenplumSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tHBaseConfiguration Enables the reuse of the connection configuration to HBase in the same Job. Delete Delete Apply Apply Delete Delete
Image tHBaseInput Reads data from a given HBase database and extracts columns of selection. Apply Delete Apply Delete Delete Delete
Image tHBaseLookupInput Provides lookup data to the main flow of a streaming Job. Delete Delete Delete Apply Delete Delete
Image tHBaseOutput Writes columns of data into a given HBase database. Apply Delete Apply Apply Delete Delete
Image tHiveClose Closes connection to a Hive database. Apply Delete Delete Delete Delete Delete
Image tHiveConfiguration Enables the reuse of the connection configuration to Hive in the same Job. Delete Delete Apply Apply Delete Delete
Image tHiveConnection Establishes a Hive connection to be reused by other Hive components in your Job. Apply Delete Delete Delete Delete Delete
Image tHiveCreateTable Creates Hive tables that fit a wide range of Hive data formats. Apply Delete Delete Delete Delete Delete
Image tHiveInput Extracts data from Hive and sends the data to the component that follows. Apply Delete Apply Apply Delete Delete
Image tHiveLoad Writes data of different formats into a given Hive table or to export data from a Hive table to a directory. Apply Delete Delete Delete Delete Delete
Image tHiveOutput Connects to a given Hive database and writes the data it receives into a given Hive table or a directory in HDFS. Delete Delete Apply Apply Delete Delete
Image tHiveRow Acts on the actual DB structure or on the data without handling data itself, depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tHiveWarehouseConfiguration Enables the reuse of the Hive Warehouse Connector connection configuration to Hive in the same Job. Delete Delete Apply Apply Delete Delete
Image tHiveWarehouseInput Extracts data from Hive and sends the data to the component that follows using Hive Warehouse Connector. Delete Delete Apply Apply Delete Delete
Image tHiveWarehouseOutput Connects to a given Hive database and writes the received data into a given Hive table or a directory in HDFS using Hive Warehouse Connector. Delete Delete Apply Apply Delete Delete
Image tHSQLDbInput Executes a DB query with a strictly defined order which must correspond to the schema definition and then it passes on the field list to the next component via a Main row link. Apply Delete Delete Delete Delete Delete
Image tHSQLDbOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tHSQLDbRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tInformixBulkExec Executes Insert operations in Informix databases. Apply Delete Delete Delete Delete Delete
Image tInformixCDC Extracts the data from a source system which has changed since the last extraction and transports it to another/other system(s). Apply Delete Delete Delete Delete Delete
Image tInformixClose Closes connection to Informix databases. Apply Delete Delete Delete Delete Delete
Image tInformixCommit Makes a global commit just once instead of commiting every row or batch of rows separately. Apply Delete Delete Delete Delete Delete
Image tInformixConnection Apply Delete Delete Delete Delete Delete
Image tInformixInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tInformixOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tInformixOutputBulk Prepares the file to be used as a parameter in the INSERT query used to feed Informix databases. Apply Delete Delete Delete Delete Delete
Image tInformixOutputBulkExec Carries out Insert operations in Informix databases using the data provided. Apply Delete Delete Delete Delete Delete
Image tInformixRollback Prevents involuntary transaction commits by canceling transactions in connected databases. Apply Delete Delete Delete Delete Delete
Image tInformixRow Acts on the actual DB structure or on the data (although without handling data) thanks to the SQLBuilder that helps you write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tInformixSCD Tracks and shows changes which have been made to Informix SCD dedicated tables Apply Delete Delete Delete Delete Delete
Image tInformixSP Centralises and calls multiple and complex queries in a database. Apply Delete Delete Delete Delete Delete
Image tJavaDBInput Reads a database and extracts fields based on a query Apply Delete Delete Delete Delete Delete
Image tJavaDBOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tJavaDBRow Acts on the actual database structure or on the data (although without handling data) using the SQLBuilder tool to write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tJDBCClose Closes an active JDBC connection to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tJDBCColumnList Lists all column names of a given JDBC table. Apply Delete Delete Delete Delete Delete
Image tJDBCCommit Commits in one go a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tJDBCConfiguration Stores connection information and credentials to be reused by other JDBC components. Delete Delete Apply Apply Delete Delete
Image tJDBCConnection Apply Delete Delete Delete Delete Delete
Image tJDBCInput Reads any database using a JDBC API connection and extracts fields based on a query. Apply Delete Apply Delete Delete Delete
Image tJDBCLookupInput Reads a database and extracts fields based on a query. Delete Delete Delete Apply Delete Delete
Image tJDBCOutput Executes the action defined on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Apply Apply Delete Delete
Image tJDBCRollback Avoids commiting part of a transaction accidentally by canceling the transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tJDBCRow Acts on the actual DB structure or on the data (although without handling data) using the SQLBuilder tool to write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tJDBCSCDELT Tracks data changes in a source database table using SCD (Slowly Changing Dimensions) Type 1 method and/or Type 2 method and writes both the current and historical data into a specified SCD dimension table. Apply Delete Delete Delete Delete Delete
Image tJDBCSP Centralizes multiple or complex queries in a database in order to call them easily. Apply Delete Delete Delete Delete Delete
Image tJDBCTableList Lists the names of a given set of JDBC tables using a select statement based on a Where clause. Apply Delete Delete Delete Delete Delete
Image tKuduConfiguration Enables the reuse of the connection configuration to Cloudera Kudu in the same Job. Delete Delete Apply Delete Delete Delete
Image tKuduInput Retrieves data from a Cloudera Kudu table and sends them to the component that follows for transformation. Delete Delete Apply Delete Delete Delete
Image tKuduOutput Creates, updates or deletes data in a Cloudera Kudu table. Delete Delete Apply Delete Delete Delete
Image tMapRDBConfiguration Stores connection information and credentials to be reused by other MapRDB components. Delete Delete Apply Apply Delete Delete
Image tMapRDBInput Reads data from a given MapRDB database and extracts columns of selection. Apply Delete Apply Delete Delete Delete
Image tMapRDBLookupInput Provides lookup data to the main flow of a streaming Job. Delete Delete Delete Apply Delete Delete
Image tMapRDBOutput Writes columns of data into a given MapRDB database. Apply Delete Apply Apply Delete Delete
Image tMaxDBInput Reads a database and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tMaxDBOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Delete Delete Delete Delete
Image tMaxDBRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tMongoDBConfiguration Stores connection information and credentials to be reused by other MongoDB components. Delete Delete Apply Apply Delete Delete
Image tMongoDBInput Retrieves records from a collection in the MongoDB database and transfers them to the following component for display or storage. Apply Delete Apply Apply Delete Delete
Image tMongoDBLookupInput Executes a database query with a strictly defined order which must correspond to the schema definition. Delete Delete Delete Apply Delete Delete
Image tMSSqlBulkExec Offers gains in performance while executing the Insert operations to a Microsoft SQL Server database. Apply Delete Delete Delete Delete Delete
Image tMSSqlCDC Extracts the changes made to the source operational data and makes them available to the target system(s) using database CDC views. Apply Delete Delete Delete Delete Delete
Image tMSSqlClose Closes a transaction in the MSSql databases. Apply Delete Delete Delete Delete Delete
Image tMSSqlColumnList Lists all column names of a given MSSql table. Apply Delete Delete Delete Delete Delete
Image tMSSqlCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tMSSqlConnection Apply Delete Delete Delete Delete Delete
Image tMSSqlInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Apply Delete Delete Delete Delete Delete
Image tMSSqlInvalidRows Extracts DB rows that match a given data quality business rule. You can then implement any required correction. Apply Delete Delete Delete Delete Delete
Image tMSSqlLastInsertId Retrieves the last primary keys added by a user to a MSSql table. Apply Delete Delete Delete Delete Delete
Image tMSSqlOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tMSSqlOutputBulk Prepares the file to be used as parameter in the INSERT query to feed the MSSql database. Apply Delete Delete Delete Delete Delete
Image tMSSqlOutputBulkExec Gains in performance during Insert operations to a Microsoft SQL Server database. Apply Delete Delete Delete Delete Delete
Image tMSSqlRollback Cancels the transaction commit in the MSSql database and thus avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tMSSqlRow Acts on the actual DB structure or on the data (although without handling data). Apply Delete Delete Delete Delete Delete
Image tMSSqlSCD Tracks and reflects changes in a dedicated SCD table in a Microsoft SQL Server or Azure SQL database. Apply Delete Delete Delete Delete Delete
Image tMSSqlSP Offers a convenient way to centralize multiple or complex queries in a database and calls them easily. Apply Delete Delete Delete Delete Delete
Image tMSSqlTableList Lists the names of a given set of MSSql tables using a select statement based on a Where clause. Apply Delete Delete Delete Delete Delete
Image tMSSqlValidRows Extracts DB rows that match a given data quality business rule. Apply Delete Delete Delete Delete Delete
Image tMysqlBulkExec Offers gains in performance while executing the Insert operations on a MySQL or Aurora database. Apply Delete Delete Delete Delete Delete
Image tMysqlCDC Extracts only the changes made to the source operational data and makes them available to the target system(s) using database CDC views. Apply Delete Delete Delete Delete Delete
Image tMysqlClose Closes the transaction committed in a Mysql database. Apply Delete Delete Delete Delete Delete
Image tMysqlColumnList Iterates on all columns of a given Mysql table and lists column names. Apply Delete Delete Delete Delete Delete
Image tMysqlCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tMysqlConfiguration Stores connection information and credentials to be reused by other MySQL components. Delete Delete Apply Apply Delete Delete
Image tMysqlConnection Opens a connection to the specified MySQL database for reuse in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tMysqlInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Apply Delete Apply Delete Delete Delete
Image tMySQLInvalidRows Checks MySQL database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tMysqlLastInsertId Obtains the primary key value of the record that was last inserted in a Mysql table by a user. Apply Delete Delete Delete Delete Delete
Image tMysqlLookupInput Reads a MySQL database and extracts fields based on a query. Delete Delete Delete Apply Delete Delete
Image tMysqlOutput Writes, updates, makes changes or suppresses entries in a database. Apply Delete Apply Apply Delete Delete
Image tMysqlOutputBulk Writes a file with columns based on the defined delimiter and the MySQL or Aurora standards. Apply Delete Delete Delete Delete Delete
Image tMysqlOutputBulkExec Executes the Insert action in the specified MySQL or Aurora database. Apply Delete Delete Delete Delete Delete
Image tMysqlRollback Cancels the transaction commit in the connected MySQL database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tMysqlRow Executes the stated SQL query on the specified MySQL database. Apply Delete Delete Delete Delete Delete
Image tMysqlSCD Reflects and tracks changes in a dedicated MySQL SCD table. Apply Delete Delete Delete Delete Delete
Image tMysqlSCDELT Reflects and tracks changes in a dedicated MySQL SCD table through SQL queries. Apply Delete Delete Delete Delete Delete
Image tMysqlSP Calls a MySQL database stored procedure. Apply Delete Delete Delete Delete Delete
Image tMysqlTableList Lists the names of a given set of Mysql tables using a select statement based on a Where clause. Apply Delete Delete Delete Delete Delete
Image tMySQLValidRows Checks MySQL database rows against Data Quality patterns (regular expression). Apply Delete Delete Delete Delete Delete
Image tNetezzaBulkExec Offers gains in performance while carrying out the Insert operations to a Netezza database. Apply Delete Delete Delete Delete Delete
Image tNetezzaClose Closes the transaction committed in the connected Netazza database. Apply Delete Delete Delete Delete Delete
Image tNetezzaCommit Validates the data processed through the Job into the connected Netezza database. Apply Delete Delete Delete Delete Delete
Image tNetezzaConnection Opens a connection to a Netezza database to be reused in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tNetezzaInput Reads a database and extracts fields from a Netezza database based on a query. Apply Delete Delete Delete Delete Delete
Image tNetezzaNzLoad Inserts data into a Netezza database table using Netezza's nzload utility. Apply Delete Delete Delete Delete Delete
Image tNetezzaOutput Writes, updates, makes changes or suppresses entries in a Netezza database. Apply Delete Delete Delete Delete Delete
Image tNetezzaRollback Cancels the transaction committed in the connected Netezza database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tNetezzaRow Executes the SQL query stated onto the specified Netezza database. Apply Delete Delete Delete Delete Delete
Image tNetezzaSCD Reflects and tracks changes in a dedicated Netezza SCD table. Apply Delete Delete Delete Delete Delete
Image tOracleBulkExec Offers gains in performance during operations performed on data of an Oracle database. Apply Delete Delete Delete Delete Delete
Image tOracleCDC Extracts source system data that has changed since the last extraction and transports it to another/other system(s). Apply Delete Delete Delete Delete Delete
Image tOracleCDCOutput Synchronizes data changes in the Oracle XStream CDC mode. Apply Delete Delete Delete Delete Delete
Image tOracleClose Closes the transaction committed in the connected Oracle database. Apply Delete Delete Delete Delete Delete
Image tOracleCommit Validates the data processed through the Job into the connected Oracle database Apply Delete Delete Delete Delete Delete
Image tOracleConfiguration Stores connection information and credentials to be reused by other Oracle components. Delete Delete Apply Apply Delete Delete
Image tOracleConnection Opens a connection to the specified Oracle database for reuse in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tOracleInput Reads an Oracle database and extracts fields based on a query. Apply Delete Apply Delete Delete Delete
Image tOracleInvalidRows Checks Oracle database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tOracleLookupInput Reads a database and extracts fields based on a query. Delete Delete Delete Apply Delete Delete
Image tOracleOutput Writes, updates, makes changes or suppresses entries in an Oracle database. Apply Delete Apply Apply Delete Delete
Image tOracleOutputBulk Writes a file with columns based on the defined delimiter and the Oracle standards. Apply Delete Delete Delete Delete Delete
Image tOracleOutputBulkExec Executes the Insert action in the specified Oracle database. Apply Delete Delete Delete Delete Delete
Image tOracleRollback Cancels the transaction commit in the connected Oracle database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tOracleRow Executes the stated SQL query on the specified Oracle database. Apply Delete Delete Delete Delete Delete
Image tOracleSCD Reflects and tracks changes in a dedicated Oracle SCD table. Apply Delete Delete Delete Delete Delete
Image tOracleSCDELT Reflects and tracks changes in a dedicated Oracle SCD table through SQL queries. Apply Delete Delete Delete Delete Delete
Image tOracleSP Calls an Oracle database stored procedure. Apply Delete Delete Delete Delete Delete
Image tOracleTableList Lists the names of specified Oracle tables using a SELECT statement based on a WHERE clause. Apply Delete Delete Delete Delete Delete
Image tOracleValidRows Checks Oracle database rows against Data Quality patterns (regular expression). Apply Delete Delete Delete Delete Delete
Image tParseRecordSet Parses a recordset rather than individual records from a table. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusBulkExec Improves performance during Insert operations to a DB2 database. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusClose Closes the transaction committed in the connected PostgresPlus database. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusCommit Commits in one go a global transaction, using a unique connection, instead of doing that on every row or every batch and thus improves performance. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusConnection Apply Delete Delete Delete Delete Delete
Image tPostgresPlusInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Then it passes on the field list to the next component via a Main row link. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the job. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusOutputBulk Prepares the file to be used as parameter in the INSERT query to feed the PostgresPlus database. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusOutputBulkExec Improves performance during Insert operations to a PostgresPlus database. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusRollback Avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. The SQLBuilder tool helps you write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated PostgresPlus SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresqlBulkExec Improves performance while carrying out the Insert operations to a Postgresql database. Apply Delete Delete Delete Delete Delete
Image tPostgresqlCDC Addresses data extraction and transportation needs, only extracts the changes made to the source operational data and makes them available to the target system(s) using database CDC views. Apply Delete Delete Delete Delete Delete
Image tPostgresqlClose Closes the transaction committed in the connected Postgresql database. Apply Delete Delete Delete Delete Delete
Image tPostgresqlCommit Commits in one go a global transaction, using a unique connection, instead of doing that on every row or every batch and thus improves performance. Apply Delete Delete Delete Delete Delete
Image tPostgresqlConnection Apply Delete Delete Delete Delete Delete
Image tPostgresqlInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Then it passes on the field list to the next component via a Main row link. Apply Delete Delete Delete Delete Delete
Image tPostgresqlInvalidRows Extracts DB rows that do not match a given data quality pattern, you can then implement any required correction. Apply Delete Delete Delete Delete Delete
Image tPostgresqlOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the job. Apply Delete Delete Delete Delete Delete
Image tPostgresqlOutputBulk Prepares the file to be used as parameters in the INSERT query to feed the Postgresql database. Apply Delete Delete Delete Delete Delete
Image tPostgresqlOutputBulkExec Improves performance during Insert operations to a Postgresql database. Apply Delete Delete Delete Delete Delete
Image tPostgresqlRollback Avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tPostgresqlRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. The SQLBuilder tool helps you write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tPostgresqlSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresqlSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated DB2 SCD table. Apply Delete Delete Delete Delete Delete
Image tPostgresqlValidRows Extracts DB rows that match a given data quality pattern. Apply Delete Delete Delete Delete Delete
Image tRedshiftBulkExec Loads data into Amazon Redshift from Amazon S3, Amazon EMR cluster, Amazon DynamoDB, or remote hosts. Apply Delete Delete Delete Delete Delete
Image tRedshiftClose Closes the transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tRedshiftCommit Provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tRedshiftConfiguration Reuses the connection configuration to a Redshift database in the same Job. Delete Delete Apply Apply Delete Delete
Image tRedshiftConnection Apply Delete Delete Delete Delete Delete
Image tRedshiftInput Reads data from a database and extracts fields based on a query so that you may apply changes to the extracted data. Apply Delete Apply Delete Delete Delete
Image tRedshiftLookupInput Reads a Redshift database and extracts fields based on a query. Delete Delete Delete Apply Delete Delete
Image tRedshiftOutput Writes, updates, modifies or deletes the data in a database. Apply Delete Apply Apply Delete Delete
Image tRedshiftOutputBulk Prepares a delimited/CSV file that can be used by tRedshiftBulkExec to feed Amazon Redshift. Apply Delete Delete Delete Delete Delete
Image tRedshiftOutputBulkExec Executes the Insert action on the data provided. Apply Delete Delete Delete Delete Delete
Image tRedshiftRollback Cancels the transaction commit in the Redshift database to avoid committing part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tRedshiftRow Acts on the actual DB structure or on the data (although without handling data), depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tRedshiftUnload Unloads data on Amazon Redshift to files on Amazon S3. Apply Delete Delete Delete Delete Delete
Image tSAPHanaClose Closes a connection to a SAP HANA database. Apply Delete Delete Delete Delete Delete
Image tSAPHanaCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSAPHanaConnection Establishes a SAP HANA connection to be reused by other SAP HANA components in your Job. Apply Delete Delete Delete Delete Delete
Image tSAPHanaInput Executes a database query with a defined command which must correspond to the schema definition. Apply Delete Delete Delete Delete Delete
Image tSAPHanaInvalidRows Checks SAP Hana database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tSAPHanaOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tSAPHanaRollback Avoids to commit part of a transaction involuntarily. Apply Delete Delete Delete Delete Delete
Image tSAPHanaRow Acts on the actual database structure or on the data (although without handling data). Apply Delete Delete Delete Delete Delete
Image tSAPHanaUnload Offloads massive data from the SAP HANA database to a third party system. Apply Delete Delete Delete Delete Delete
Image tSAPHanaValidRows Checks SAP Hana database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tSingleStoreBulkExec Loads data from a file into a table of a database connected through JDBC API. Apply Delete Delete Delete Delete Delete
Image tSingleStoreClose Closes an active SingleStore connection to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tSingleStoreCommit Commits in one go a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSingleStoreConnection Apply Delete Delete Delete Delete Delete
Image tSingleStoreInput Reads any database using a JDBC API connection and extracts fields based on a query. Apply Delete Delete Delete Delete Delete
Image tSingleStoreOutput Executes the action defined on the data contained in the table, based on the flow incoming from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tSingleStoreOutputBulk Prepares the bulk file to be used as a parameter to feed the database connected. Apply Delete Delete Delete Delete Delete
Image tSingleStoreOutputBulkExec Provides performance gain when loading data from a file into a table of a database connected through JDBC API. Apply Delete Delete Delete Delete Delete
Image tSingleStoreRollback Avoids commiting part of a transaction accidentally by canceling the transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tSingleStoreRow Acts on the actual DB structure or on the data (although without handling data) using the SQLBuilder tool to write easily your SQL statements. Apply Delete Delete Delete Delete Delete
Image tSingleStoreSP Centralizes multiple or complex queries in a database in order to call them easily. Apply Delete Delete Delete Delete Delete
Image tSnowflakeConfiguration Stores connection information and credentials to be reused by other Snowflake components in the Apache Spark Batch framework. Delete Delete Apply Delete Delete Delete
Image tSnowflakeInput Reads data from a Snowflake table into the data flow of your Job based on an SQL query. Apply Delete Apply Delete Delete Delete
Image tSQLiteClose Closes a transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tSQLiteCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSQLiteConnection Opens a connection to the database for a current transaction. Apply Delete Delete Delete Delete Delete
Image tSQLiteInput Executes a DB query with a defined command which must correspond to the schema definition. It passes on rows to the next component via a Main row link. Apply Delete Delete Delete Delete Delete
Image tSQLiteOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the job. Apply Delete Delete Delete Delete Delete
Image tSQLiteRollback Cancels the transaction committed in the SQLite database. Apply Delete Delete Delete Delete Delete
Image tSQLiteRow Executes the defined query onto the specified database and uses the parameters bound with the column. Apply Delete Delete Delete Delete Delete
Image tSybaseBulkExec Gains in performance during Insert operations to a Sybase database. Apply Delete Delete Delete Delete Delete
Image tSybaseCDC Extracts source system data that has changed since the last extraction and transports it to another/other system(s). Apply Delete Delete Delete Delete Delete
Image tSybaseClose Closes a transaction committed in the connected database. Apply Delete Delete Delete Delete Delete
Image tSybaseCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tSybaseConnection Opens a connection to the database for a current transaction. Apply Delete Delete Delete Delete Delete
Image tSybaseInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Apply Delete Delete Delete Delete Delete
Image tSybaseIQBulkExec Loads data into a Sybase database table from a flat file or other database table. Apply Delete Delete Delete Delete Delete
Image tSybaseIQOutputBulkExec Gains in performance during Insert operations to a Sybase IQ database. Apply Delete Delete Delete Delete Delete
Image tSybaseOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the job. Apply Delete Delete Delete Delete Delete
Image tSybaseOutputBulk Prepares the file to be used as parameter in the INSERT query to feed the Sybase database. Apply Delete Delete Delete Delete Delete
Image tSybaseOutputBulkExec Gains in performance during Insert operations to a Sybase database. Apply Delete Delete Delete Delete Delete
Image tSybaseRollback Cancels the transaction committed in the Sybase database. Apply Delete Delete Delete Delete Delete
Image tSybaseRow Acts on the actual DB structure or on the data (although without handling data). Apply Delete Delete Delete Delete Delete
Image tSybaseSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tSybaseSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated Sybase SCD table. Apply Delete Delete Delete Delete Delete
Image tSybaseSP Calls a Sybase database stored procedure. Apply Delete Delete Delete Delete Delete
Image tTeradataCDC Extracts source system data that has changed since the last extraction and transports it to another system(s) using the CDC Trigger mode. Apply Delete Delete Delete Delete Delete
Image tTeradataClose Closes the transaction committed in the connected DB. Apply Delete Delete Delete Delete Delete
Image tTeradataCommit Commits in one go, using a unique connection, a global transaction instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tTeradataConfiguration Defines a connection to Teradata and enables the reuse of the connection configuration in the same Job. Delete Delete Apply Apply Delete Delete
Image tTeradataConnection Apply Delete Delete Delete Delete Delete
Image tTeradataFastExport Exports data batches from a Teradata table to a customer system or to a smaller database. Apply Delete Delete Delete Delete Delete
Image tTeradataFastLoad Executes a database query according to a strict order which must be the same as the one in the schema. Apply Delete Delete Delete Delete Delete
Image tTeradataFastLoadUtility Executes a database query according to a strict order which must be the same as the one in the schema. Apply Delete Delete Delete Delete Delete
Image tTeradataInput Executes a DB query with a strictly defined order which must correspond to the schema definition. Apply Delete Apply Delete Delete Delete
Image tTeradataLookupInput Executes a database query with a strictly defined order which must correspond to the schema definition. Delete Delete Delete Apply Delete Delete
Image tTeradataMultiLoad Executes a database query according to a strict order which must be the same as the one in the schema. Apply Delete Delete Delete Delete Delete
Image tTeradataOutput Executes the action defined on the table and/or on the data contained in the table, based on the flow incoming from the preceding component in the job. Apply Delete Apply Apply Delete Delete
Image tTeradataRollback Cancels the transaction commit in the Teradata database. Apply Delete Delete Delete Delete Delete
Image tTeradataRow Acts on the actual DB structure or on the data (although without handling data). Apply Delete Delete Delete Delete Delete
Image tTeradataSCD Addresses Slowly Changing Dimension needs, reading regularly a source of data and logging the changes into a dedicated SCD table. Apply Delete Delete Delete Delete Delete
Image tTeradataSCDELT Addresses Slowly Changing Dimension needs through SQL queries (server-side processing mode), and logs the changes into a dedicated Teradata SCD table. Apply Delete Delete Delete Delete Delete
Image tTeradataTPTExec Offers high performance in inserting data from an existing file to a table in a Teradata database. Apply Delete Delete Delete Delete Delete
Image tTeradataTPTUtility Writes the incoming data to a file and then loads the data from the file to a Teradata database. Apply Delete Delete Delete Delete Delete
Image tTeradataTPump Inserts, updates, or deletes data in the Teradata database with the TPump loading utility which allows near-real-time data to be achieved in the data warehouse. Apply Delete Delete Delete Delete Delete
Image tVerticaBulkExec Loads data into a Vertica database table from a local file using the Vertica COPY SQL statement. Apply Delete Delete Delete Delete Delete
Image tVerticaClose Closes an active connection to a Vertica database. Apply Delete Delete Delete Delete Delete
Image tVerticaCommit Commits in one go a global transaction using a unique connection instead of doing that on every row or every batch and thus provides gain in performance. Apply Delete Delete Delete Delete Delete
Image tVerticaConnection Apply Delete Delete Delete Delete Delete
Image tVerticaInput Retrieves data from a Vertica database table based on a SQL query. Apply Delete Delete Delete Delete Delete
Image tVerticaOutput Inserts, updates, deletes, or copies data from an incoming flow into a Vertica database table. Apply Delete Delete Delete Delete Delete
Image tVerticaOutputBulk Prepares a file to be used by the tVerticaBulkExec component to feed a Vertica database. Apply Delete Delete Delete Delete Delete
Image tVerticaOutputBulkExec Receives data from a preceding component, writes data into a local file, and loads data into a Vertica database from the file using the Vertica COPY SQL statement. Apply Delete Delete Delete Delete Delete
Image tVerticaRollback Cancels the transaction commit in the Vertica database. Apply Delete Delete Delete Delete Delete
Image tVerticaRow Executes a Vertica SQL statement against a database table. Apply Delete Delete Delete Delete Delete
Image tVerticaSCD Tracks and reflects data changes in a dedicated Vertica SCD table. Apply Delete Delete Delete Delete Delete
Databases NoSQL
Image tCassandraBulkExec Improves performance during Insert operations to a Cassandra column family. Apply Delete Delete Delete Delete Delete
Image tCassandraClose Disconnects a connection to a Cassandra server so as to release occupied resources. Apply Delete Delete Delete Delete Delete
Image tCassandraConnection Enables the reuse of the connection it creates to a Cassandra server. Apply Delete Delete Delete Delete Delete
Image tCassandraOutput Writes data into or deletes data from a column family of a Cassandra keyspace. Apply Delete Apply Apply Delete Delete
Image tCassandraOutputBulk Prepares an SSTable of large size and processes it according to your needs before loading this SSTable into a column family of a Cassandra keyspace. Apply Delete Delete Delete Delete Delete
Image tCassandraOutputBulkExec Improves performance during Insert operations to a column family of a Cassandra keyspace. Apply Delete Delete Delete Delete Delete
Image tCassandraRow Acts on the actual DB structure or on the data, depending on the nature of the query and the database. Apply Delete Delete Delete Delete Delete
Image tCosmosDBSQLAPIInput Retrieves data from a Cosmos database collection through SQL API. Apply Delete Delete Delete Delete Delete
Image tCosmosDBSQLAPIOutput Inserts, updates, upserts or deletes documents in a Cosmos database collection based on the incoming flow from the preceding component through SQL API. Apply Delete Delete Delete Delete Delete
Image tCouchbaseDCPInput Queries the documents from the Couchbase database, under the Database Change Protocol (DCP), a streaming protocol. Apply Delete Delete Delete Delete Delete
Image tCouchbaseDCPOutput Upserts documents in the Couchbase database based on the incoming flat data from preceding components, under the Database Change Protocol (DCP), a streaming protocol. Apply Delete Delete Delete Delete Delete
Image tCouchbaseInput Queries the documents from the Couchbase database. Apply Delete Delete Delete Delete Delete
Image tCouchbaseOutput Upserts documents in the Couchbase database based on the incoming flat data from preceding components. Apply Delete Delete Delete Delete Delete
Image tDynamoDBOutput Creates, updates or deletes data in an Amazon DynamoDB table. Apply Delete Apply Apply Delete Delete
Image tHBaseClose Closes an HBase connection you have established in your Job. Apply Delete Delete Delete Delete Delete
Image tHBaseConnection Establishes an HBase connection to be reused by other HBase components in your Job. Apply Delete Delete Delete Delete Delete
Image tMapRDBClose Closes an MapRDB connection you have established in a same Job. Apply Delete Delete Delete Delete Delete
Image tMapRDBConnection Establishes a MapRDB connection to be reused by other MapRDB components in a same Job. Apply Delete Delete Delete Delete Delete
Image tMapROjaiInput Reads documents from a MapR-DB database to load the data in a given Job. Apply Delete Delete Delete Delete Delete
Image tMapROjaiOutput Inserts, replaces or deletes documents in a MapR-DB database to be used as document database, based on the incoming flow from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tMarkLogicBulkLoad Imports local files into a MarkLogic server database in bulk mode using the MarkLogic Content Pump (MLCP) tool. Apply Delete Delete Delete Delete Delete
Image tMarkLogicClose Closes an active connection to a MarkLogic database to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tMarkLogicConnection Opens a connection to a MarkLogic database that can then be reused by other MarkLogic components. Apply Delete Delete Delete Delete Delete
Image tMarkLogicInput Searches document content in a MarkLogic database based on a string query. Apply Delete Delete Delete Delete Delete
Image tMarkLogicOutput Creates, updates or deletes document content in a MarkLogic database. Apply Delete Delete Delete Delete Delete
Image tMongoDBBulkLoad Imports data files in different formats (CSV, TSV or JSON) into the specified MongoDB database so that the data can be further processed. Apply Delete Delete Delete Delete Delete
Image tMongoDBClose Closes a connection to the MongoDB database. Apply Delete Delete Delete Delete Delete
Image tMongoDBConnection Creates a connection to a MongoDB database and reuse that connection in other components. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSDelete Automates the delete action over specific files in MongoDB GridFS. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSGet Connects to a MongoDB GridFS system to copy files from it. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSList Retrieves a list of files based on a query. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSProperties Obtains information about the properties of given files selected based on a query. Apply Delete Delete Delete Delete Delete
Image tMongoDBGridFSPut Connects to a MongoDB GridFS system to load files into it. Apply Delete Delete Delete Delete Delete
Image tMongoDBOutput Executes the action defined on the collection in the MongoDB database. Apply Delete Apply Apply Delete Delete
Image tMongoDBRow Executes the commands and functions of the MongoDB database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchOutput Receives data from the preceding component and writes the data into a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchOutputRelationship Receives data from the preceding component and writes relationships in bulk into a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jBatchSchema Defines the schema of a local Neo4j database. Apply Delete Delete Delete Delete Delete
Image tNeo4jClose Close an active connection to an Neo4j database in embedded mode. Apply Delete Delete Delete Delete Delete
Image tNeo4jConnection Opens a connection to a Neo4j database to be reuse by other Neo4j components. Apply Delete Delete Delete Delete Delete
Image tNeo4jImportTool Uses Neo4j Import Tool to create a Neo4j database and import large amounts of data in bulk from CSV files to this database. Apply Delete Delete Delete Delete Delete
Image tNeo4jInput Reads data from Neo4j and sends data in the output flow. Apply Delete Delete Delete Delete Delete
Image tNeo4jRow Executes the stated Cypher query onto the specified Neo4J database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Close Closes a connection to a Neo4j version 4.x database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Connection Establishes a connection to a Neo4j version 4.x database for later use. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Input Reads data from Neo4j version 4.x and sends data in the output flow. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Output Receives data from the preceding component and writes the data into a Neo4j version 4.x database. Apply Delete Delete Delete Delete Delete
Image tNeo4jv4Row Executes the stated Cypher query onto the specified Neo4J version 4.x database. Apply Delete Delete Delete Delete Delete
Data_Privacy
Image tDataDecrypt Decrypts data encrypted with the tDataEncrypt component. Apply Delete Apply Apply Delete Delete
Image tDataEncrypt Protects data by transforming it into unreadable cipher text. Apply Delete Apply Apply Delete Delete
Image tDataMasking Hides original data with random characters or figures to protect the actual data while having a functional substitute for occasions when it is not advisable to show sensitive real data. Apply Delete Apply Apply Delete Delete
Image tDataShuffling Shuffles the data from in an input table to protect the actual data while having a functional data set. Data will remain usable for purposes such as testing and training. Apply Delete Apply Delete Delete Delete
Image tDataUnmasking Unmasks data masked with the tDataMasking component to retrieve the original data. Apply Delete Apply Apply Delete Delete
Image tDuplicateRow Creates duplicates with meaningful data for data quality functional testing purposes. Apply Delete Delete Delete Delete Delete
Image tPatternMasking Masks data that follows a specific pattern and can transform the original data in consistent manner, if needed. Apply Delete Apply Apply Delete Delete
Image tPatternUnmasking Unmasks data masked with the tPatternMasking component to retrieve the original data. Apply Delete Apply Apply Delete Delete
Data_Quality
Image tAddCRCRow Provides a unique ID which helps improving the quality of processed data. CRC stands for Cyclical Redundancy Checking. Apply Delete Delete Delete Delete Delete
Image tAddressRowCloud Verifies and formats international addresses in the Cloud by using online services. Apply Delete Delete Delete Delete Delete
Image tBatchAddressRowCloud Uses batch processing to parse address data and get formatted addresses quickly, accurately and without installing any software. Apply Delete Delete Delete Delete Delete
Image tChangeFileEncoding Transforms the character encoding of a given file and generates a new file with the transformed character encoding. Apply Delete Delete Delete Delete Delete
Image tDqReportRun Launches the analyses listed in a report and save the results in the data quality data mart. Apply Delete Delete Delete Delete Delete
Image tDuplicateRow Creates duplicates with meaningful data for data quality functional testing purposes. Apply Delete Delete Delete Delete Delete
Image tFindRegexlibExpressions Returns a dataset holding information about all of the regular expressions that match the request sent to the web server. Apply Delete Delete Delete Delete Delete
Image tFirstnameMatch Matches first names against a reference index in order to standardize data. Apply Delete Delete Delete Delete Delete
Image tFuzzyMatch Compares a column from the main flow with a reference column from the lookup flow and outputs the main flow data displaying the distance. Apply Delete Delete Delete Delete Delete
Image tFuzzyUniqRow Compares columns in the input flow by using a defined matching method and collects the encountered duplicates. Apply Delete Delete Delete Delete Delete
Image tGenKey Generates a functional key from the input columns, by applying different types of algorithms on each column and grouping the computed results in one key, then outputs this key with the input columns. Apply Delete Apply Apply Delete Delete
Image tGoogleAddressRow Converts human-readable addresses into geographic coordinates and other geographic information. Apply Delete Delete Delete Delete Delete
Image tGoogleGeocoder Converts human-readable addresses into geographic coordinates. Apply Delete Delete Delete Delete Delete
Image tGoogleMapLookup Obtains detailed geographic information using geographic coordinates and address information. Apply Delete Delete Delete Delete Delete
Image tIntervalMatch Returns a value based on a Join relation. Apply Delete Delete Delete Delete Delete
Image tJapaneseNumberNormalize Normalizes Japanese numbers (kansuji) to regular Arabic numbers. Apply Delete Apply Apply Delete Delete
Image tJapaneseTokenize Splits Japanese text into tokens. Apply Delete Apply Apply Delete Delete
Image tJapaneseTransliterate Converts textual data in Japanese to kana and Latin scripts. Apply Delete Apply Apply Delete Delete
Image tLastRegexlibExpressions Returns a dataset holding information about the N most recent regular expressions added to the library and that match the query at http://regexlib.com. Apply Delete Delete Delete Delete Delete
Image tLoqateAddressRow Parses, verifies, cleanses, standardizes, transliterates, and formats international addresses. Apply Delete Delete Delete Delete Delete
Image tMatchGroup Creates groups of similar data records in any source data including large volumes of data by using one or several match rules. Apply Delete Delete Delete Delete Delete
Image tMelissaDataAddress Verifies if an address is properly formatted and corrects any formatting or spelling errors in each row. Apply Delete Delete Delete Delete Delete
Image tMSSqlInvalidRows Extracts DB rows that match a given data quality business rule. You can then implement any required correction. Apply Delete Delete Delete Delete Delete
Image tMSSqlValidRows Extracts DB rows that match a given data quality business rule. Apply Delete Delete Delete Delete Delete
Image tMultiPatternCheck Checks all existing data in multiple columns against a given Java regular expression. Apply Delete Delete Delete Delete Delete
Image tMySQLInvalidRows Checks MySQL database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tMySQLValidRows Checks MySQL database rows against Data Quality patterns (regular expression). Apply Delete Delete Delete Delete Delete
Image tOracleInvalidRows Checks Oracle database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tOracleValidRows Checks Oracle database rows against Data Quality patterns (regular expression). Apply Delete Delete Delete Delete Delete
Image tPatternCheck Gives two output flows: Matching Data and Non-Matching Data. The first collects all data that match a given pattern, and the second collects all data that do not match a given pattern. You can then implement any required corrections. Apply Delete Delete Delete Delete Delete
Image tPatternExtract Outputs all data that match a given pattern. You can then implement any required operation on the extracted data. Apply Delete Delete Delete Delete Delete
Image tPersonator Ensures the quality of a US and Canadian contact database by checking, verifying, moving and appending contact data. Apply Delete Delete Delete Delete Delete
Image tPostgresqlInvalidRows Extracts DB rows that do not match a given data quality pattern, you can then implement any required correction. Apply Delete Delete Delete Delete Delete
Image tPostgresqlValidRows Extracts DB rows that match a given data quality pattern. Apply Delete Delete Delete Delete Delete
Image tQASAddressRow Corrects any formatting or spelling errors and gives the verification status for each row. Apply Delete Delete Delete Delete Delete
Image tQASBatchAddressRow Corrects any formatting or spelling errors, adds missing data and gives the verification status for each row. Apply Delete Delete Delete Delete Delete
Image tRecordMatching Ensures the data quality of any source data against a reference data source. Apply Delete Delete Delete Delete Delete
Image tReplaceList Cleanses all files before further processing. Apply Delete Delete Delete Delete Delete
Image tReservoirSampling Extracts a random sample data from a big data set. Apply Delete Apply Delete Delete Delete
Image tRuleSurvivorship Creates the single representation of an entity according to business rules and can create a master copy of data for Master Data Management. Apply Delete Apply Delete Delete Delete
Image tSAPHanaInvalidRows Checks SAP Hana database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tSAPHanaValidRows Checks SAP Hana database rows against specific Data Quality patterns (regular expression) or Data Quality rules (business rule). Apply Delete Delete Delete Delete Delete
Image tSchemaComplianceCheck Ensures the data quality of any source data against a reference data source. Apply Delete Apply Apply Delete Delete
Image tStandardizePhoneNumber Standardizes phone numbers according to given formats. Apply Delete Apply Apply Delete Delete
Image tStandardizeRow Normalizes the incoming data in a separate XML or JSON data flow to separate or standardize the rule-compliant data from the non-compliant data. Apply Delete Apply Apply Delete Delete
Image tStem Enables to standardize data in columns before matching this data. Apply Delete Delete Delete Delete Delete
Image tSurviveFields Centralizes data from various and heterogeneous sources to create a master copy of data for MDM. Apply Delete Delete Delete Delete Delete
Image tSynonymOutput Creates a Lucene index and feeds it with entries and the related synonyms it receives. Apply Delete Delete Delete Delete Delete
Image tSynonymSearch Searches a given index for the reference entries matching the data you input. Apply Delete Apply Apply Delete Delete
Image tThresholdViolationAlert Alerts to any threshold violations regarding the thresholds set on indicators in different quality analyses created in the Studio. Apply Delete Delete Delete Delete Delete
Image tTransliterate Converts strings from many languages of the world to a standard set of characters (Universal Coded Character Set, UCS). Apply Delete Apply Apply Delete Delete
Image tVerifyEmail Verifies if email addresses comply with specific rules and corrects addresses that do not match the rules by using the content from specific columns. Apply Delete Apply Apply Delete Delete
Deprecated
Image tBlockedFuzzyJoin Helps ensuring the data quality of any source data against a reference data source. Apply Delete Delete Delete Delete Delete
Image tFlumeInput Acts as interface to integrate Flume and the Spark Streaming Job developed with the Studio to continuously read data from a given Flume agent. Delete Delete Delete Apply Delete Delete
Image tFlumeOutput Acts as interface to integrate Flume and the Spark Streaming Job developed with the Studio to continuously send data to a given Flume agent. Delete Delete Delete Apply Delete Delete
Image tFuzzyJoin Joins two tables by doing a fuzzy match on several columns, comparing columns from the main flow with reference columns from the lookup flow and outputting the main flow data and/or the rejected data. Apply Delete Delete Delete Delete Delete
Image tQASAddressIncomplete Gives two output flows: Incomplete and Reject. Apply Delete Delete Delete Delete Delete
Image tQASAddressUnknown Gives one output flow: Unknown which collects all addresses that do not match to deliverable results in the QuickAddress data. Apply Delete Delete Delete Delete Delete
Image tQASAddressVerified Gives three output flows: Verified, Interaction required, and Reject. Apply Delete Delete Delete Delete Delete
Image tUniservBTGeneric Executes a process created with the Uniserv product DQ Batch Suite. Apply Delete Delete Delete Delete Delete
Image tUniservRTConvertName Analyzes the name elements in an address . Apply Delete Delete Delete Delete Delete
Image tUniservRTMailBulk Creates the index pool for duplicate search. Apply Delete Delete Delete Delete Delete
Image tUniservRTMailOutput Synchronizes the index pool that is used for duplicate search. Apply Delete Delete Delete Delete Delete
Image tUniservRTMailSearch Searches for duplicate values based on a given input record and adds additional data to each record. Apply Delete Delete Delete Delete Delete
Image tUniservRTPost Improves the addresses quality, which is extremely important for CRM and e-business as it is directly related to postage and advertising costs. Apply Delete Delete Delete Delete Delete
DotNET
Image tDotNETInstantiate Invokes the constructor of a .NET object that is intended for later reuse. Apply Delete Delete Delete Delete Delete
Image tDotNETRow Facilitates data transform by utilizing custom or built-in .NET classes. Apply Delete Delete Delete Delete Delete
ElasticSearch
Image tElasticSearchConfiguration Enables the reuse of the connection configuration to ElasticSearch in the same Job. Delete Delete Apply Apply Delete Delete
Image tElasticSearchInput Reads documents from a given Elasticsearch system based on a user-defined query. Delete Delete Apply Delete Delete Delete
Image tElasticSearchLookupInput Executes a ElasticSearch query with a strictly defined order which must correspond to the schema definition. Delete Delete Delete Apply Delete Delete
Image tElasticSearchOutput Writes datasets into a given Elasticsearch system. Delete Delete Apply Apply Delete Delete
ELT
Image tAccessConnection Apply Delete Delete Delete Delete Delete
Image tAS400Connection Apply Delete Delete Delete Delete Delete
Image tCombinedSQLAggregate Provides a set of matrix based on values or calculations. Apply Delete Delete Delete Delete Delete
Image tCombinedSQLFilter Filters data by reorganizing, deleting or adding columns based on the source table and to filter the given data source using the filter conditions. Apply Delete Delete Delete Delete Delete
Image tCombinedSQLInput Extracts fields from a database table based on its schema definition. Apply Delete Delete Delete Delete Delete
Image tCombinedSQLOutput Inserts records from the incoming flow to an existing database table. Apply Delete Delete Delete Delete Delete
Image tDB2Connection Apply Delete Delete Delete Delete Delete
Image tDeltaLakeConnection Opens a connection to the specified database that can then be reused in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tELTGreenplumInput Adds as many Input tables as required for the most complicated Insert statement. Apply Delete Delete Delete Delete Delete
Image tELTGreenplumMap Uses the tables provided as input to feed the parameter in the built statement. The statement can include inner or outer joins to be implemented between tables or between one table and its aliases. Apply Delete Delete Delete Delete Delete
Image tELTGreenplumOutput Executes the SQL Insert, Update and Delete statement to the Greenplum database Apply Delete Delete Delete Delete Delete
Image tELTHiveInput Replicates the schema, which the tELTHiveMap component that follows will use, of the input Hive table. Apply Delete Delete Delete Delete Delete
Image tELTHiveMap Builds graphically the Hive QL statement in order to transform data. Apply Delete Delete Delete Delete Delete
Image tELTHiveOutput Works alongside tELTHiveMap to write data into the Hive table. Apply Delete Delete Delete Delete Delete
Image tELTInput Adds as many Input tables as required for the SQL statement to be executed. Apply Delete Delete Delete Delete Delete
Image tELTMap Uses the tables provided as input to feed the parameter in the built SQL statement. The statement can include inner or outer joins to be implemented between tables or between one table and its aliases. Apply Delete Delete Delete Delete Delete
Image tELTMSSqlInput Adds as many Input tables as required for the most complicated Insert statement. Apply Delete Delete Delete Delete Delete
Image tELTMSSqlMap Uses the tables provided as input to feed the parameter in the built statement. The statement can include inner or outer joins to be implemented between tables or between one table and its aliases. Apply Delete Delete Delete Delete Delete
Image tELTMSSqlOutput Executes the SQL Insert, Update and Delete statement to the MSSql database Apply Delete Delete Delete Delete Delete
Image tELTMysqlInput Adds as many Input tables as required for the most complicated Insert statement. Apply Delete Delete Delete Delete Delete
Image tELTMysqlMap Uses the tables provided as input to feed the parameter in the built statement. The statement can include inner or outer joins to be implemented between tables or between one table and its aliases. Apply Delete Delete Delete Delete Delete
Image tELTMysqlOutput tELTMysqlOutput executes the SQL Insert, Update and Delete statement to the Mysql database Apply Delete Delete Delete Delete Delete
Image tELTNetezzaInput Allows you to add as many Input tables as required for the most complicated Insert statement. Apply Delete Delete Delete Delete Delete
Image tELTNetezzaMap Uses the tables provided as input, to feed the parameter in the built statement. The statement can include inner or outer joins to be implemented between tables or between one table and its aliases. Apply Delete Delete Delete Delete Delete
Image tELTNetezzaOutput Performs the action (insert, update or delete) on data in the specified Netezza table through the SQL statement generated by the tELTNetezzaMap component. Apply Delete Delete Delete Delete Delete
Image tELTOracleInput Provides the Oracle table schema that will be used by the tELTOracleMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTOracleMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTOracleInput components. Apply Delete Delete Delete Delete Delete
Image tELTOracleOutput Performs the action (insert, update, delete, or merge) on data in the specified Oracle table through the SQL statement generated by the tELTOracleMap component. Apply Delete Delete Delete Delete Delete
Image tELTOutput Carries out the action on the table specified and inserts the data according to the output schema defined in the ELT Mapper. Apply Delete Delete Delete Delete Delete
Image tELTPostgresqlInput Provides the Postgresql table schema that will be used by the tELTPostgresqlMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTPostgresqlMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTPostgresqlInput components. Apply Delete Delete Delete Delete Delete
Image tELTPostgresqlOutput Performs the action (insert, update or delete) on data in the specified Postgresql table through the SQL statement generated by the tELTPostgresqlMap component. Apply Delete Delete Delete Delete Delete
Image tELTSAPInput Provides the SAP table schema that will be used by the tELTSAPMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTSAPMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTSAPInput components. Apply Delete Delete Delete Delete Delete
Image tELTSybaseInput Provides the Sybase table schema that will be used by the tELTSybaseMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTSybaseMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTSybaseInput components. Apply Delete Delete Delete Delete Delete
Image tELTSybaseOutput Performs the action (insert, update or delete) on data in the specified Sybase table through the SQL statement generated by the tELTSybaseMap component. Apply Delete Delete Delete Delete Delete
Image tELTTeradataInput Provides the Teradata table schema that will be used by the tELTTeradataMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTTeradataMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTTeradataInput components. Apply Delete Delete Delete Delete Delete
Image tELTTeradataOutput Performs the action (insert, update or delete) on data in the specified Teradata table through the SQL statement generated by the tELTTeradataMap component. Apply Delete Delete Delete Delete Delete
Image tELTVerticaInput Provides the Vertica table schema that will be used by the tELTVerticaMap component to generate the SQL SELECT statement. Apply Delete Delete Delete Delete Delete
Image tELTVerticaMap Builds the SQL SELECT statement using the table schema(s) provided by one or more tELTVerticaInput components. Apply Delete Delete Delete Delete Delete
Image tELTVerticaOutput Performs the action (insert, update or delete) on data in the specified Vertica table through the SQL statement generated by the tELTVerticaMap component. Apply Delete Delete Delete Delete Delete
Image tExasolConnection Opens a connection to an EXASolution database instance that can then be reused by other EXASolution components. Apply Delete Delete Delete Delete Delete
Image tFirebirdConnection Apply Delete Delete Delete Delete Delete
Image tGreenplumConnection Apply Delete Delete Delete Delete Delete
Image tJDBCConnection Apply Delete Delete Delete Delete Delete
Image tMSSqlConnection Apply Delete Delete Delete Delete Delete
Image tMysqlConnection Opens a connection to the specified MySQL database for reuse in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tNetezzaConnection Opens a connection to a Netezza database to be reused in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tOracleConnection Opens a connection to the specified Oracle database for reuse in the subsequent subJob or subJobs. Apply Delete Delete Delete Delete Delete
Image tPostgresPlusConnection Apply Delete Delete Delete Delete Delete
Image tPostgresqlConnection Apply Delete Delete Delete Delete Delete
Image tSAPHanaConnection Establishes a SAP HANA connection to be reused by other SAP HANA components in your Job. Apply Delete Delete Delete Delete Delete
Image tSingleStoreConnection Apply Delete Delete Delete Delete Delete
Image tSQLiteConnection Opens a connection to the database for a current transaction. Apply Delete Delete Delete Delete Delete
Image tSQLTemplate Executes the common database actions or customized SQL statement templates, for example to drop/create a table. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateAggregate Provides a set of matrix based on values or calculations. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateCommit Commits a global action in one go using a single connection, instead of doing so for every row or every batch of rows separately. This provides a gain in performance. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateFilterColumns Homogenizes schemas by reorganizing, deleting or adding new columns. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateFilterRows Sets row filters for any given data source, based on a WHERE clause. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateMerge Merges data into a database table directly on the DBMS by creating and executing a MERGE statement. Apply Delete Delete Delete Delete Delete
Image tSQLTemplateRollback Cancels the transaction committed in the SQLTemplate database. Apply Delete Delete Delete Delete Delete
Image tSybaseConnection Opens a connection to the database for a current transaction. Apply Delete Delete Delete Delete Delete
Image tTeradataConnection Apply Delete Delete Delete Delete Delete
ESB
Image tESBConsumer Calls the defined method from the invoked Web service and returns the class as defined, based on the given parameters. Apply Delete Delete Delete Delete Delete
Image tESBProviderFault Serves a Job cycle result as a Fault message of the Web service in case of a request response communication style. Apply Delete Delete Delete Delete Delete
Image tESBProviderRequest Wraps Job as web service. Apply Delete Delete Delete Delete Delete
Image tESBProviderResponse Serves a Job cycle result as a response message. Apply Delete Delete Delete Delete Delete
Image tRESTClient Interacts with RESTful Web service providers by sending HTTP and HTTPS requests using CXF (JAX-RS) getting the corresponding responses. Apply Delete Delete Delete Delete Delete
Image tRESTRequest Receives GET/POST/PUT/PATCH/DELETE requests from the clients on the server end. Apply Delete Delete Delete Delete Delete
Image tRESTResponse Returns a specific HTTP status code to the client end as a response to the HTTP and/or HTTP requests. Apply Delete Delete Delete Delete Delete
Image tRouteFault Sends messages from a Data Integration Job to a Mediation Route and mark the message as fault. Apply Delete Delete Delete Delete Delete
Image tRouteInput Accepts messages in a Data Integration Job from a Mediation Route. Apply Delete Delete Delete Delete Delete
Image tRouteOutput Sends messages from a Data Integration Job to a Mediation Route. Apply Delete Delete Delete Delete Delete
Exception Handling
Image cErrorHandler Processes errors in the message routing. Delete Delete Delete Delete Delete Apply
Image cIntercept Intercepts each message sub-route and redirects it in another sub-route without modifying the original one. When this detour is complete, message routing to the originally intended target endpoints continues. This can be useful at testing time to simulate error handling. Delete Delete Delete Delete Delete Apply
Image cOnException Catches the exceptions defined and triggers certain actions which are then performed on these exceptions and the message routing. Delete Delete Delete Delete Delete Apply
Image cTry Offers the Java equivalent exception handling abilities by building Try/Catch/Finally blocks to isolate the part of your Route likely to generate an error, catch the errors, and execute final instructions regardless of the errors. Delete Delete Delete Delete Delete Apply
File
Image tAdvancedFileOutputXML Writes an XML file with separated data values according to an XML tree structure. Apply Delete Delete Delete Delete Delete
Image tApacheLogInput Reads the access-log file for an Apache HTTP server. Apply Delete Delete Delete Delete Delete
Image tAvroInput Extracts records from any given Avro format files for other components to process the records. Delete Delete Apply Apply Delete Delete
Image tAvroOutput Receives data flows from the processing component placed ahead of it and writes the data into Avro format files in a given distributed file system. Delete Delete Apply Apply Delete Delete
Image tAvroStreamInput Listens on a given directory, reads data from Avro files once they are created and sends this data to the component that follows. Delete Delete Delete Apply Delete Delete
Image tChangeFileEncoding Transforms the character encoding of a given file and generates a new file with the transformed character encoding. Apply Delete Delete Delete Delete Delete
Image tCreateTemporaryFile Creates a temporary file in a specified directory. This component allows you to either keep the temporary file or delete it after the Job execution. Apply Delete Delete Delete Delete Delete
Image tFileArchive Creates a new zip, gzip, or tar.gz archive file from one or more files or folders. Apply Delete Delete Delete Delete Delete
Image tFileCompare Compares two files and provides comparison data based on a read-only schema. Apply Delete Delete Delete Delete Delete
Image tFileCopy Copies a source file or folder into a target directory. Apply Delete Delete Delete Delete Delete
Image tFileDelete Deletes files from a given directory. Apply Delete Delete Delete Delete Delete
Image tFileExist Checks if a file exists or not. Apply Delete Delete Delete Delete Delete
Image tFileInputARFF Reads an ARFF file row by row to split them up into fields and then sends the fields as defined in the schema to the next component. Apply Delete Delete Delete Delete Delete
Image tFileInputDelimited Reads a delimited file row by row to split them up into fields and then sends the fields as defined in the schema to the next component. Apply Delete Apply Apply Delete Delete
Image tFileInputExcel Reads an Excel file row by row to split them up into fields using regular expressions and then sends the fields as defined in the schema to the next component. Apply Delete Delete Delete Delete Delete
Image tFileInputFullRow Reads a file row by row and sends complete rows of data as defined in the schema to the next component via a Row link. Apply Delete Apply Apply Delete Delete
Image tFileInputJSON Extracts JSON data from a file and transfers the data to a file, a database table, etc. Apply Delete Apply Apply Delete Delete
Image tFileInputLDIF Reads an LDIF file row by row to split them up into fields and sends the fields as defined in the schema to the next component using a Row connection. Apply Delete Delete Delete Delete Delete
Image tFileInputMail Reads the standard key data of a given MIME or MSG email file. Apply Delete Delete Delete Delete Delete
Image tFileInputMSDelimited Reads the data structures (schemas) of a multi-structured delimited file and sends the fields as defined in the different schemas to the next components using Row connections. Apply Delete Delete Delete Delete Delete
Image tFileInputMSPositional Reads the data structures (schemas) of a multi-structured positional file and sends the fields as defined in the different schemas to the next components using Row connections. Apply Delete Delete Delete Delete Delete
Image tFileInputMSXML Reads the data structures (schemas) of a multi-structured XML file and sends the fields as defined in the different schemas to the next components using Row connections. Apply Delete Delete Delete Delete Delete
Image tFileInputORC Extracts records from a given ORC format file and sends the data to the next component for further processing. Apply Delete Delete Delete Delete Delete
Image tFileInputParquet Extracts records from a given Parquet format file and sends the data to the next component for further processing. Apply Delete Apply Apply Delete Delete
Image tFileInputPositional Reads a positional file row by row to split them up into fields based on a given pattern and then sends the fields as defined in the schema to the next component. Apply Delete Apply Apply Delete Delete
Image tFileInputProperties Reads a text file row by row and separates the fields according to the model key = value. Apply Delete Delete Delete Delete Delete
Image tFileInputRaw Reads all data in a raw file and sends it to a single output column for subsequent processing by another component. Apply Delete Delete Delete Delete Delete
Image tFileInputRegex Reads a file row by row to split them up into fields using regular expressions and sends the fields as defined in the schema to the next component. Apply Delete Apply Apply Delete Delete
Image tFileInputXML Reads an XML structured file row by row to split them up into fields and sends the fields as defined in the schema to the next component. Apply Delete Apply Apply Delete Delete
Image tFileList Iterates a set of files or folders in a given directory based on a filemask pattern. Apply Delete Delete Delete Delete Delete
Image tFileOutputARFF Writes an ARFF file that holds data organized according to the defined schema. Apply Delete Delete Delete Delete Delete
Image tFileOutputDelimited Outputs the input data to a delimited file according to the defined schema. Apply Delete Apply Apply Delete Delete
Image tFileOutputExcel Writes an MS Excel file with separated data values according to a defined schema. Apply Delete Delete Delete Delete Delete
Image tFileOutputJSON Receives data and rewrites it in a JSON structured data block in an output file. Apply Delete Apply Apply Delete Delete
Image tFileOutputLDIF Writes or modifies an LDIF file with data separated in respective entries based on the schema defined, or else deletes content from an LDIF file. Apply Delete Delete Delete Delete Delete
Image tFileOutputMSDelimited Creates a complex multi-structured delimited file, using data structures (schemas) coming from several incoming Row flows. Apply Delete Delete Delete Delete Delete
Image tFileOutputMSPositional Creates a complex multi-structured file, using data structures (schemas) coming from several incoming Row flows. Apply Delete Delete Delete Delete Delete
Image tFileOutputMSXML Creates a complex multi-structured XML file, using data structures (schemas) coming from several incoming Row flows. Apply Delete Delete Delete Delete Delete
Image tFileOutputORC Receives records from the processing component placed ahead of it and writes the records into ORC format files. Apply Delete Delete Delete Delete Delete
Image tFileOutputParquet Receives records from the processing component placed ahead of it and writes the records into Parquet format files. Apply Delete Apply Apply Delete Delete
Image tFileOutputPositional Writes a file row by row according to the length and the format of the fields or columns in a row. Apply Delete Apply Apply Delete Delete
Image tFileOutputProperties Writes a configuration file, of the type .ini or .properties, containing text data organized according to the model key = value. Apply Delete Delete Delete Delete Delete
Image tFileOutputRaw Provides data coming from another component, in the form of a single column of output data. Apply Delete Delete Delete Delete Delete
Image tFileOutputXML Writes an XML file with separated data values according to a defined schema. Apply Delete Apply Apply Delete Delete
Image tFileProperties Creates a single row flow that displays the main properties of the processed file. Apply Delete Delete Delete Delete Delete
Image tFileRowCount Opens a file and reads it row by row in order to determine the number of rows inside. Apply Delete Delete Delete Delete Delete
Image tFileStreamInputDelimited Reads data continuously, row by row, to split it into fields, then sends fields defined in its schema to the next Job component, via a Row > Main link. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputFullRow Reads data in a newly-created file row by row and sends the entire rows within one single field to the next Job component, via a Row > Main link. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputJSON Extracts JSON data from a file, then transfers the data to, for instance, a file or a database table. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputParquet Extracts records from a given Parquet format file for other components to process the records. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputPositional Listens on a given directory for new files, reads data from them row by row and extracts fields based on a specific pattern. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputRegex Listens on a given directory for new files, then reads data from these files, row by row, in order to split the data into fields using regular expressions. Delete Delete Delete Apply Delete Delete
Image tFileStreamInputXML Opens a structured XML file and reads it row by row to split the data into fields, then sends these fields as defined in the Schema to the next component. Delete Delete Delete Apply Delete Delete
Image tFileTouch Creates an empty file or, if the specified file already exists, updates its date of modification and of last access while keeping the contents unchanged. Apply Delete Delete Delete Delete Delete
Image tFileUnarchive Decompresses an archive file for further processing, in one of the following formats: *.tar.gz , *.tgz, *.tar, *.gz and *.zip. Apply Delete Delete Delete Delete Delete
Image tGPGDecrypt Calls the gpg -d command to decrypt a GnuPG-encrypted file and saves the decrypted file in the specified directory. Apply Delete Delete Delete Delete Delete
Image tHDFSCompare Compares two files in HDFS and based on the read-only schema, generates a row flow that presents the comparison information. Apply Delete Delete Delete Delete Delete
Image tHDFSConnection Connects to a given HDFS so that the other Hadoop components can reuse the connection it creates to communicate with this HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSCopy Copies a source file or folder into a target directory in HDFS and removes this source if required. Apply Delete Delete Delete Delete Delete
Image tHDFSDelete Deletes a file located on a given Hadoop distributed file system (HDFS). Apply Delete Delete Delete Delete Delete
Image tHDFSExist Checks whether a file exists in a specific directory in HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSGet Copies files from Hadoop distributed file system(HDFS), pastes them in a user-defined directory and if needs be, renames them. Apply Delete Delete Delete Delete Delete
Image tHDFSInput Extracts the data in a HDFS file for other components to process it. Apply Delete Delete Delete Delete Delete
Image tHDFSList tHDFSList retrieves a list of files or folders based on a filemask pattern and iterates on each unity. Apply Delete Delete Delete Delete Delete
Image tHDFSOutput Writes data flows it receives into a given Hadoop distributed file system (HDFS). Apply Delete Delete Delete Delete Delete
Image tHDFSOutputRaw Transfers data of different formats such as hierarchical data in the form of a single column into a given HDFS file system. Apply Delete Delete Delete Delete Delete
Image tHDFSProperties Creates a single row flow that displays the properties of a file processed in HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSPut Connects to Hadoop distributed file system to load large-scale files into it with optimized performance. Apply Delete Delete Delete Delete Delete
Image tHDFSRename Renames the selected files or specified directory on HDFS. Apply Delete Delete Delete Delete Delete
Image tHDFSRowCount Reads a file in HDFS row by row in order to determine the number of rows this file contains. Apply Delete Delete Delete Delete Delete
Image tNamedPipeClose Closes a named-pipe at the end of a process. Apply Delete Delete Delete Delete Delete
Image tNamedPipeOpen Opens a named-pipe for writing data into it. Apply Delete Delete Delete Delete Delete
Image tNamedPipeOutput Writes data into an existing open named-pipe. Apply Delete Delete Delete Delete Delete
Image tPivotToColumnsDelimited Fine-tunes the selection of data to output. Apply Delete Delete Delete Delete Delete
Image tSqoopExport Defines the arguments required by Sqoop for transferring data to a RDBMS. Apply Delete Delete Delete Delete Delete
Image tSqoopImport Defines the arguments required by Sqoop for writing the data of your interest into HDFS. Apply Delete Delete Delete Delete Delete
Image tSqoopImportAllTables Defines the arguments required by Sqoop for writing all of the tables of a database into HDFS. Apply Delete Delete Delete Delete Delete
Image tSqoopMerge Performs an incremental import that updates an older dataset with newer records. The file types of the newer and the older datasets must be the same. Apply Delete Delete Delete Delete Delete
Internet
Image tCyberarkInput Retrieves the password of an application from a CyberArk vault at runtime. Apply Delete Delete Delete Delete Delete
Image tFileFetch Retrieves a file through the given protocol (HTTP, HTTPS, FTP, or SMB). Apply Delete Delete Delete Delete Delete
Image tFTPClose Closes an active FTP connection to release the occupied resources. Apply Delete Delete Delete Delete Delete
Image tFTPConnection Opens an FTP connection to transfer files in a single transaction. Apply Delete Delete Delete Delete Delete
Image tFTPDelete Deletes files or folders in a specified directory on an FTP server. Apply Delete Delete Delete Delete Delete
Image tFTPFileExist Checks if a file or a directory exists on an FTP server. Apply Delete Delete Delete Delete Delete
Image tFTPFileList Lists all files and folders directly under a specified directory based on a filemask pattern. Apply Delete Delete Delete Delete Delete
Image tFTPFileProperties Retrieves the properties of a specified file on an FTP server. Apply Delete Delete Delete Delete Delete
Image tFTPGet Downloads files to a local directory from an FTP directory. Apply Delete Delete Delete Delete Delete
Image tFTPPut Uploads files from a local directory to an FTP directory. Apply Delete Delete Delete Delete Delete
Image tFTPRename Renames files in an FTP directory. Apply Delete Delete Delete Delete Delete
Image tFTPTruncate Truncates files in an FTP directory. Apply Delete Delete Delete Delete Delete
Image tHttpRequest Sends an HTTP request to the server and outputs the response information locally. Apply Delete Delete Delete Delete Delete
Image tJBossESBInput Retrieves a message from a JBossESB server to process it as a flow that can be used in a Job. Apply Delete Delete Delete Delete Delete
Image tJBossESBOutput Transforms the data used in a Job into a JBossESB message. Apply Delete Delete Delete Delete Delete
Image tKafkaConnection Opens a reusable Kafka connection. Apply Delete Delete Delete Delete Delete
Image tKafkaCreateTopic Creates a Kafka topic that the other Kafka components can use. Apply Delete Delete Delete Delete Delete
Image tKafkaInput Transmits messages you need to process to the components that follow in the Job you are designing. Apply Delete Delete Apply Delete Delete
Image tKafkaOutput Publishes messages into a Kafka system. Apply Delete Delete Apply Delete Delete
Image tMapRStreamsCommit Connects to a given tMapRStreamsInput to perform a consumer offset commit. Apply Delete Delete Delete Delete Delete
Image tMapRStreamsConnection Opens a reusable connection to a given MapR Streams cluster so that the other MapR Streams components can reuse this connection. Apply Delete Delete Delete Delete Delete
Image tMapRStreamsCreateStream Creates a MapR Streams stream or topic that the other MapR Streams components can use. Apply Delete Delete Delete Delete Delete
Image tMapRStreamsInput Transmits messages to the Job that runs transformations over these messages. Only MapR V5.2 onwards is supported by this component. Apply Delete Delete Apply Delete Delete
Image tMapRStreamsOutput Publishes messages into a MapR Streams system. Only MapR V5.2 onwards is supported by this component. Apply Delete Delete Apply Delete Delete
Image tMicrosoftMQInput Retrieves the first message in a given Microsoft message queue (only support String). Apply Delete Delete Delete Delete Delete
Image tMicrosoftMQOutput Writes a defined column of given inflow data to Microsoft message queue (only support String type). Apply Delete Delete Delete Delete Delete
Image tMomCommit Commits data on the MQ Server. Apply Delete Delete Delete Delete Delete
Image tMomConnection Opens a connection to the MQ Server for communication. Apply Delete Delete Delete Delete Delete
Image tMomInput Fetches a message from a queue on a Message-Oriented Middleware (MOM) system and passes it on to the next component. Apply Delete Delete Delete Delete Delete
Image tMomMessageIdList Fetches a message ID list from a queue on a Message-Oriented middleware system and passes it to the next component. Apply Delete Delete Delete Delete Delete
Image tMomOutput Adds a message to a Message-Oriented Middleware system queue in order for it to be fetched asynchronously. Apply Delete Delete Delete Delete Delete
Image tMomRollback Cancels the transaction committed in the MQ Server. Apply Delete Delete Delete Delete Delete
Image tPOP Fetches one or more email messages from a server using the POP3 or IMAP protocol. Apply Delete Delete Delete Delete Delete
Image tRabbitMQClose Closes a connection to a message queue. Apply Delete Delete Delete Delete Delete
Image tRabbitMQConnection Establishes a connection to a message queue for later use. Apply Delete Delete Delete Delete Delete
Image tRabbitMQInput Reads messages from a message queue and passes the messages in the output flow. Apply Delete Delete Delete Delete Delete
Image tRabbitMQOutput Receives data from the preceding component as messages and adds the messages to queues in the specified way. Apply Delete Delete Delete Delete Delete
Image tREST Serves as a REST Web service client. Apply Delete Delete Delete Delete Delete
Image tRSSInput Reads RSS-Feeds using URLs. Apply Delete Delete Delete Delete Delete
Image tRSSOutput Creates and writes XML files that hold RSS or Atom feeds. Apply Delete Delete Delete Delete Delete
Image tSCPClose Closes a connection to an SCP protocol. Apply Delete Delete Delete Delete Delete
Image tSCPConnection Opens an SCP connection to transfer files in one transaction. Apply Delete Delete Delete Delete Delete
Image tSCPDelete Removes a file from the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPFileExists Verifies the existence of a file on the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPFileList Lists files from the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPGet Copies files from the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPPut Copies files to the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPRename Renames file(s) on the defined SCP server. Apply Delete Delete Delete Delete Delete
Image tSCPTruncate Removes data from file(s) on the defined SCP server via an SCP connection. Apply Delete Delete Delete Delete Delete
Image tSendMail Notifies recipients about a particular state of a Job or possible errors. Apply Delete Delete Delete Delete Delete
Image tSetKerberosConfiguration Sets the relevant information for Kerberos authentication. Apply Delete Delete Delete Delete Delete
Image tSetKeystore Sets the authentication data type between PKCS 12 and JKS. Apply Delete Apply Apply Delete Delete
Image tSetProxy Sets the relevant information for proxy setup. Apply Delete Delete Delete Delete Delete
Image tSOAP Calls a method via a Web service in order to retrieve the values of the parameters defined in the component editor. Apply Delete Delete Delete Delete Delete
Image tSocketInput Opens the socket port and listens for the incoming data. Apply Delete Delete Delete Delete Delete
Image tSocketOutput Sends out the data from the incoming flow to a listening socket port. Apply Delete Delete Delete Delete Delete
Image tSVNLogInput Retrieves the information of a specified revision or range of revisions from an SVN repository. Apply Delete Delete Delete Delete Delete
Image tWebService Calls a method via a Web service in order to retrieve the values of the parameters defined in the component editor. Apply Delete Delete Delete Delete Delete
Image tWebServiceInput Invokes a Method through a Web service. Apply Delete Delete Delete Delete Delete
Image tXMLRPCInput Invokes a Method through a Web service and for the described purpose. Apply Delete Delete Delete Delete Delete
Logs_Errors
Image tAssert Generates the boolean evaluation on the concern for the Job execution status and provides the Job status messages to tAssertCatcher. Apply Delete Delete Delete Delete Delete
Image tAssertCatcher Generates a data flow consolidating the status information of a job execution and transfer the data into defined output files. Apply Delete Delete Delete Delete Delete
Image tChronometerStart Operates as a chronometer device that starts calculating the processing time of one or more subJobs in the main Job, or that starts calculating the processing time of part of your subJob. Apply Delete Delete Delete Delete Delete
Image tChronometerStop Operates as a chronometer device that stops calculating the processing time of one or more subJobs in the main Job, or that stops calculating the processing time of part of your subJob. tChronometerStop displays the total execution time. Apply Delete Delete Delete Delete Delete
Image tDie Triggers the tLogCatcher component for exhaustive log before killing the Job. Apply Delete Delete Delete Delete Delete
Image tFlowMeter Counts the number of rows processed in the defined flow, so this number can be caught by the tFlowMeterCatcher component for logging purposes. Apply Delete Delete Delete Delete Delete
Image tFlowMeterCatcher Operates as a log function triggered by the use of a tFlowMeter component in the Job. Apply Delete Delete Delete Delete Delete
Image tLogCatcher Operates as a log function triggered by one of the three: Java exception, tDie or tWarn, to collect and transfer log data. Apply Delete Delete Delete Delete Delete
Image tStatCatcher Gathers the Job processing metadata at the Job level and at the component level and transfers the log data to the subsequent component for display or storage. Apply Delete Delete Delete Delete Delete
Image tWarn Triggers a warning often caught by the tLogCatcher component for exhaustive log. Apply Delete Delete Delete Delete Delete
Machine Learning
Image tALSModel Generates an user-ranking-product associated matrix, based on given user-product interactive data. Delete Delete Apply Delete Delete Delete
Image tClassify Predicts which class an element belongs to, based on the classifier model generated by a model training component. Delete Delete Apply Apply Delete Delete
Image tClassifySVM Predicts which class an element belongs to, based on the classifier model generated by tSVMModel. Delete Delete Apply Apply Delete Delete
Image tDecisionTreeModel Analyzes feature vectors usually prepared and provided by tModelEncoder to generate a classifier model that is used by tPredict to classify given elements. Delete Delete Apply Delete Delete Delete
Image tGradientBoostedTreeModel Analyzes feature vectors usually prepared and provided by tModelEncoder to generate a classifier model that is used by tPredict to classify given elements. Delete Delete Apply Delete Delete Delete
Image tKMeansModel Analyzes incoming datasets based on applying the K-Means algorithm. Delete Delete Apply Delete Delete Delete
Image tKMeansStrModel Analyzes incoming datasets in near real-time, based on applying the K-Means algorithm. Delete Delete Delete Apply Delete Delete
Image tLinearRegressionModel Builds a linear regression model using a training dataset. Delete Delete Apply Delete Delete Delete
Image tLogisticRegressionModel Analyzes feature vectors usually pre-processed by tModelEncoder to generate a classifier model that is used by tPredict to classify given elements. Delete Delete Apply Delete Delete Delete
Image tModelEncoder Performs featurization operations to transform data into the format expected by the model training components such as tLogisticRegressionModel or tKMeansModel. Delete Delete Apply Apply Delete Delete
Image tNaiveBayesModel Generates a classifier model that is used by tPredict to classify given elements. Delete Delete Apply Delete Delete Delete
Image tPredict Predicts the situation of an element. Delete Delete Apply Apply Delete Delete
Image tPredictCluster Predicts the cluster of an element. Delete Delete Apply Apply Delete Delete
Image tRandomForestModel Analyzes feature vectors. Delete Delete Apply Delete Delete Delete
Image tRecommend Recommends products to users known to this model, based on the user-product recommender model generated by tASLModel. Delete Delete Apply Apply Delete Delete
Image tSVMModel Generates an SVM-based classifier model that can be used by tPredict to classify given elements. Delete Delete Apply Delete Delete Delete
Messaging
Image tJMSInput Creates an interface between a Java application and a Message-Oriented middleware system. Apply Delete Delete Apply Delete Delete
Image tJMSOutput Creates an interface between a Java application and a Message-Oriented middleware system. Apply Delete Delete Apply Delete Delete
Image tKafkaCommit Saves the current state of the tKafkaInput to which it is connected. Apply Delete Delete Apply Delete Delete
Image tKafkaInputAvro Transmits Avro-formatted messages you need to process to its following component in the Job you are designing. Delete Delete Delete Apply Delete Delete
Image tKinesisInput Acts as consumer of an Amazon Kinesis stream to pull messages from this Kinesis stream. Delete Delete Delete Apply Delete Delete
Image tKinesisInputAvro Acts as consumer of an Amazon Kinesis stream to pull messages from this Kinesis stream. Delete Delete Delete Apply Delete Delete
Image tKinesisOutput Acts as data producer to put data to an Amazon Kinesis stream for real-time ingestion. Delete Delete Delete Apply Delete Delete
Image tMapRStreamsInputAvro Transmits messages in the Avro format to the Job that runs transformations over these messages. Only MapR V5.2 onwards is supported by this component. Delete Delete Delete Apply Delete Delete
Image tMQTTInput Acts as consumer of a MQTT topic to stream messages from this topic. Delete Delete Delete Apply Delete Delete
Image tMQTTOutput Acts as publisher to a MQTT topic to stream messages to this topic in real time. Delete Delete Delete Apply Delete Delete
Image tPubSubInput Connects to the Google Cloud PubSub service that transmits messages to the components that run transformations over these messages. Delete Delete Delete Apply Delete Delete
Image tPubSubInputAvro Connects to Google Cloud Pub/Sub to receive messages in the Avro format for the components that run transformations over these messages. Delete Delete Delete Apply Delete Delete
Image tPubSubOutput Receives messages serialized into byte arrays by its preceding component and issues these messages into a given PubSub service. Delete Delete Delete Apply Delete Delete
Misc
Image tAddLocationFromIP Replaces IP addresses with geographical locations. Apply Delete Delete Delete Delete Delete
Image tBufferInput Retrieves data bufferized via a tBufferOutput component, for example, to process it in another subJob. Apply Delete Delete Delete Delete Delete
Image tBufferOutput Collects data in a buffer in order to access it later via webservice for example. Apply Delete Delete Delete Delete Delete
Image tContextDump Copies the context setup of the current Job to a flat file, a database table, etc., which can then be used by tContextLoad. Apply Delete Delete Delete Delete Delete
Image tContextLoad Loads a context from a flow. Apply Delete Delete Delete Delete Delete
Image tFixedFlowInput Generates a fixed flow from internal variables. Apply Delete Apply Apply Delete Delete
Image tLogRow Displays data or results in the Run console to monitor data processed. Apply Delete Apply Apply Delete Delete
Image tMemorizeRows Memorizes a sequence of rows that passes through and allows the following component(s) to perform operations of your choice on the memorized rows. Apply Delete Delete Delete Delete Delete
Image tMsgBox Opens a dialog box with an OK button requiring action from the user. Apply Delete Delete Delete Delete Delete
Image tRowGenerator Creates an input flow in a Job for testing purposes, in particular for boundary test sets. Apply Delete Apply Apply Delete Delete
Image tServerAlive Validates the status of the connection to a specified host. Apply Delete Delete Delete Delete Delete
Image tSocketTextStreamInput Creates a textual input stream by connecting to a network. Delete Delete Delete Apply Delete Delete
Miscellaneous
Image cLog Logs message exchanges in a Route. Delete Delete Delete Delete Delete Apply
Image cStop Stops a message routing to which it is connected. Delete Delete Delete Delete Delete Apply
Orchestration
Image cDelayer Delays the delivery of messages. Delete Delete Delete Delete Delete Apply
Image cLoop Processes messages repetitively and possibly in different ways. Delete Delete Delete Delete Delete Apply
Image cTimer Schedules message exchanges in a Route. Delete Delete Delete Delete Delete Apply
Image tCollector Feeds the parallel execution processes with the threads generated by tPartitioner. Apply Delete Delete Delete Delete Delete
Image tDepartitioner Assembles the outputs of the parallel execution processes so that tRecollector can capture those outputs. Apply Delete Delete Delete Delete Delete
Image tFileList Iterates a set of files or folders in a given directory based on a filemask pattern. Apply Delete Delete Delete Delete Delete
Image tFlowToIterate Reads data line by line from the input flow and stores the data entries in iterative global variables. Apply Delete Delete Delete Delete Delete
Image tForeach Creates a loop on a list for an iterate link. Apply Delete Delete Delete Delete Delete
Image tInfiniteLoop Executes a task or a Job automatically, based on a loop. Apply Delete Delete Delete Delete Delete
Image tIterateToFlow Transforms non processable data into a processable flow. Apply Delete Delete Delete Delete Delete
Image tLoop Executes a task or a Job automatically, based on a loop Apply Delete Apply Delete Delete Delete
Image tParallelize Manages complex Job systems. It executes several subJobs simultaneously and synchronizes the execution of a subJob with other subJobs within the main Job. Apply Delete Delete Delete Delete Delete
Image tPartitioner Partitions the input data before tCollector can transfer them to the parallel execution processes. Apply Delete Delete Delete Delete Delete
Image tPostjob Triggers a task required after the execution of a Job Apply Delete Delete Delete Delete Delete
Image tPrejob Triggers a task required for the execution of a Job Apply Delete Delete Delete Delete Delete
Image tRecollector Outputs of the parallel execution results, depending on tDepartitioner. Apply Delete Delete Delete Delete Delete
Image tRunJob Manages complex Job systems which need to execute one Job after another. Apply Delete Apply Delete Delete Delete
Image tSleep Identifies possible bottlenecks using a time break in the Job for testing or tracking purpose. Apply Delete Delete Delete Delete Delete
Image tWaitForFile Iterates on a directory and triggers the next component when the defined condition is met. Apply Delete Delete Delete Delete Delete
Image tWaitForSocket Triggers a Job based on a defined condition. Apply Delete Delete Delete Delete Delete
Image tWaitForSqlData Iterates on a given connection for insertion or deletion of rows and triggers a subJob when a condition linked to SQL data presence is met. Apply Delete Delete Delete Delete Delete
Processing
Image tAggregateRow Receives a flow and aggregates it based on one or more columns. Apply Delete Apply Apply Delete Delete
Image tAggregateSortedRow Aggregates the sorted input data for output column based on a set of operations. Each output column is configured with many rows as required, the operations to be carried out and the input column from which the data will be taken for better data aggregation. Apply Delete Delete Delete Delete Delete
Image tBRMS Applies Drools business rules to an incoming flow and writes the output data to an XML file. Apply Delete Delete Delete Delete Delete
Image tCacheIn Offers faster access to the persistent data. Delete Delete Apply Apply Delete Delete
Image tCacheOut Persists the input RDDs depending on the specific storage level you define in order to offer faster access to these datasets later. Delete Delete Apply Apply Delete Delete
Image tConvertType Converts one java type to another automatically, and thus avoid compiling errors. Apply Delete Apply Apply Delete Delete
Image tDenormalize Denormalizes the input flow based on one column. Apply Delete Apply Apply Delete Delete
Image tDenormalizeSortedRow Synthesizes sorted input flow to save memory. Apply Delete Delete Delete Delete Delete
Image tExternalSortRow Sorts input data based on one or several columns, by sort type and order, using an external sort application. Apply Delete Delete Delete Delete Delete
Image tExtractDelimitedFields Generates multiple columns from a delimited string column. Apply Delete Apply Apply Delete Delete
Image tExtractDynamicFields Parses a Dynamic column to create standard output columns. Apply Delete Delete Delete Delete Delete
Image tExtractJSONFields Extracts the desired data from JSON fields based on the JSONPath or XPath query. Apply Delete Apply Apply Delete Delete
Image tExtractPositionalFields Extracts data and generates multiple columns from a formatted string using positional fields. Apply Delete Apply Apply Delete Delete
Image tExtractRegexFields Extracts data and generates multiple columns from a formatted string using regex matching. Apply Delete Apply Apply Delete Delete
Image tExtractXMLField Reads the XML structured data from an XML field and sends the data as defined in the schema to the following component. Apply Delete Apply Apply Delete Delete
Image tFilterColumns Homogenizes schemas either by ordering the columns, removing unwanted columns or adding new columns. Apply Delete Apply Apply Delete Delete
Image tFilterRow Filters input rows by setting one or more conditions on the selected columns. Apply Delete Apply Apply Delete Delete
Image tHConvertFile Uses structures to perform a conversion from one representation to another, as a Spark Batch execution. Delete Delete Apply Delete Delete Delete
Image tHMap Executes transformations (called maps) between different sources and destinations by harnessing the capabilities of , available in the Mapping perspective. Apply Delete Delete Delete Delete Delete
Image tHMapFile Runs a map where input and output structures may differ, as a Spark batch execution. Delete Delete Apply Delete Delete Delete
Image tHMapInput Runs a map where input and output structures may differ, as a Spark batch execution, and sends the data for use by a downstream component. Delete Delete Apply Delete Delete Delete
Image tHMapRecord Runs a map where input and output structures may differ, as a Spark streaming execution. Delete Delete Delete Apply Delete Delete
Image tJoin Performs inner or outer joins between the main data flow and the lookup flow. Apply Delete Delete Delete Delete Delete
Image tMap Transforms and routes data from single or multiple sources to single or multiple destinations. Apply Delete Apply Apply Delete Delete
Image tNormalize Normalizes the input flow following SQL standard to help improve data quality and thus eases the data update. Apply Delete Apply Apply Delete Delete
Image tPartition Allows you to visually define how an input dataset is partitioned. Delete Delete Apply Delete Delete Delete
Image tReplace Cleanses all files before further processing. Apply Delete Apply Apply Delete Delete
Image tReplicate Duplicates the incoming schema into two identical output flows. Apply Delete Apply Apply Delete Delete
Image tRules Uses business rules defined in a Drools file of .xls or .drl format in order to filter data. Apply Delete Delete Delete Delete Delete
Image tSample Returns a sample subset of the data being processed. Delete Delete Apply Delete Delete Delete
Image tSampleRow Selects rows according to a list of single lines and/or a list of groups of lines. Apply Delete Delete Delete Delete Delete
Image tSortRow Helps creating metrics and classification table. Apply Delete Apply Apply Delete Delete
Image tSplitRow Splits one input row into several output rows. Apply Delete Delete Delete Delete Delete
Image tSqlRow Performs SQL queries over input datasets. Delete Delete Apply Apply Delete Delete
Image tSurviveFields Centralizes data from various and heterogeneous sources to create a master copy of data for MDM. Apply Delete Delete Delete Delete Delete
Image tTop Sorts data and outputs several rows from the first one of this data. Delete Delete Apply Apply Delete Delete
Image tTopBy Groups and sorts data and outputs several rows from the first one of the data in each group. Delete Delete Apply Apply Delete Delete
Image tUniqRow Ensures data quality of input or output flow in a Job. Apply Delete Apply Apply Delete Delete
Image tUnite Centralizes data from various and heterogeneous sources. Apply Delete Apply Apply Delete Delete
Image tWindow Applies a given Spark window on the incoming RDDs and sends the window-based RDDs to its following component. Delete Delete Delete Apply Delete Delete
Image tWriteAvroFields Transforms the incoming data into Avro files. Delete Delete Delete Apply Delete Delete
Image tWriteDelimitedFields Converts records into byte arrays. Delete Delete Delete Apply Delete Delete
Image tWriteDynamicFields Creates a dynamic schema from input columns in the component. Apply Delete Delete Delete Delete Delete
Image tWriteJSONField Transforms the incoming data into JSON fields and transfers them to a file, a database table, etc. Apply Delete Apply Apply Delete Delete
Image tWritePositionalFields Converts records into byte arrays. Delete Delete Delete Apply Delete Delete
Image tWriteXMLField Reads an input XML file and extracts the structure to insert it in defined fields of the output XML file. Apply Delete Delete Delete Delete Delete
Image tWriteXMLFields Converts records into byte arrays. Delete Delete Delete Apply Delete Delete
Image tXMLMap Transforms and routes data from single or multiple sources to single or multiple destinations. Apply Delete Delete Delete Delete Delete
Routing
Image cAggregate Combines a number of messages together into a single message. Delete Delete Delete Delete Delete Apply
Image cDynamicRouter Routes a message or messages to different endpoints on specified conditions. Delete Delete Delete Delete Delete Apply
Image cIdempotentConsumer Identifies messages that have already been sent to the receiver and eliminates them. Messages are still sent by the sender but are ignored by the receiver at the delivery stage. Delete Delete Delete Delete Delete Apply
Image cLoadBalancer Distributes the messages it received to multiple endpoints according to the load balancing policy. Delete Delete Delete Delete Delete Apply
Image cMessageFilter Filters the content of messages according to the specified criterion and routes the filtered messages to the specified output channel. All messages that do not match the criteria will be dropped. Delete Delete Delete Delete Delete Apply
Image cMessageRouter Creates different channels for each filtered message type according to specified conditions so that messages can later on be treated more accurately in each new channel. Delete Delete Delete Delete Delete Apply
Image cMulticast Routes messages to a number of endpoints at one go and process them in different ways. Delete Delete Delete Delete Delete Apply
Image cPipesAndFilters Splits message routing into a series of independent processing stages. Delete Delete Delete Delete Delete Apply
Image cRecipientList Routes messages to a number of dynamically specified recipients. Delete Delete Delete Delete Delete Apply
Image cRoutingSlip Routes the message consecutively through a series of processing steps, with the sequence of steps unknown at design time and variable for each message. Delete Delete Delete Delete Delete Apply
Image cSplitter Splits a message into several sub-messages so that they can be handled and treated differently in individual routes. Delete Delete Delete Delete Delete Apply
Image cThrottler Limits the number of messages flowing to a specific endpoint in order to prevent it from getting overloaded. Delete Delete Delete Delete Delete Apply
Image cWireTap Wiretaps messages to a user defined URI while they are sent to their original endpoint. cWireTap also allows you to populate a new message to this wiretap URI concurrently. Delete Delete Delete Delete Delete Apply
Storage
Image tAzureFSConfiguration Provides authentication information for Spark to connect to a given Azure file system. Delete Delete Apply Apply Delete Delete
Image tBigQueryConfiguration Provides the connection configuration to Google BigQuery and Google Cloud Storage for a Spark Job. Delete Delete Apply Apply Delete Delete
Image tCassandraConfiguration Enables the reuse of the connection configuration to a Cassandra server in the same Job. Delete Delete Apply Apply Delete Delete
Image tDynamoDBConfiguration Stores connection information and credentials to be reused by other DynamoDB components. Delete Delete Apply Apply Delete Delete
Image tGSConfiguration Provides the connection configuration to Google Cloud Storage for a Spark Job. Delete Delete Apply Apply Delete Delete
Image tHBaseConfiguration Enables the reuse of the connection configuration to HBase in the same Job. Delete Delete Apply Apply Delete Delete
Image tHDFSConfiguration Enables the reuse of the connection configuration to HDFS in the same Job. Delete Delete Apply Apply Delete Delete
Image tJDBCConfiguration Stores connection information and credentials to be reused by other JDBC components. Delete Delete Apply Apply Delete Delete
Image tKuduConfiguration Enables the reuse of the connection configuration to Cloudera Kudu in the same Job. Delete Delete Apply Delete Delete Delete
Image tMapRDBConfiguration Stores connection information and credentials to be reused by other MapRDB components. Delete Delete Apply Apply Delete Delete
Image tMysqlConfiguration Stores connection information and credentials to be reused by other MySQL components. Delete Delete Apply Apply Delete Delete
Image tOracleConfiguration Stores connection information and credentials to be reused by other Oracle components. Delete Delete Apply Apply Delete Delete
Image tRedshiftConfiguration Reuses the connection configuration to a Redshift database in the same Job. Delete Delete Apply Apply Delete Delete
Image tS3Configuration Reuses the connection configuration to S3 in the same Job. The Spark cluster to be used reads this configuration to eventually connect to S3. Delete Delete Apply Apply Delete Delete
Image tSnowflakeConfiguration Stores connection information and credentials to be reused by other Snowflake components in the Apache Spark Batch framework. Delete Delete Apply Delete Delete Delete
Image tTachyonConfiguration Defines a connection to Tachyon storage system and enables the reuse of the configuration in the same Job. Delete Delete Apply Apply Delete Delete
Image tTeradataConfiguration Defines a connection to Teradata and enables the reuse of the connection configuration in the same Job. Delete Delete Apply Apply Delete Delete
System
Image tRunJob Manages complex Job systems which need to execute one Job after another. Apply Delete Apply Delete Delete Delete
Image tSetEnv Adds variables temporarily to system environment during the execution of a Job. Apply Delete Delete Delete Delete Delete
Image tSSH Establishes a communication with distant server and returns securely sensible information. Apply Delete Delete Delete Delete Delete
Image tSystem Calls other system processing commands, already up and running in a larger Job. Apply Delete Delete Delete Delete Delete
Talend
Image cTalendJob Exchanges messages between a Data Integration Job and a Mediation Route. Delete Delete Delete Delete Delete Apply
Talend Cloud
Image tJobFailure Throws an exception and prompts a message when an error occurs. Apply Delete Delete Delete Delete Delete
Image tJobLog Collects and shows exception data during the execution of the Job in or the task in . Apply Delete Delete Delete Delete Delete
Image tJobReject Receives data rejected after task processing. Apply Delete Delete Delete Delete Delete
Talend Data Preparation
Image tDataprepRun Applies a preparation made using in a standard Data Integration Job. Apply Delete Apply Apply Delete Delete
Image tDatasetInput Creates a flow with data from a dataset. Apply Delete Delete Delete Delete Delete
Image tDatasetOutput Creates a dataset in . Apply Delete Delete Delete Delete Delete
Talend Data Stewardship
Image tDataStewardshipTaskDelete Connects to and deletes the data stored in campaigns in the form of tasks. Apply Delete Delete Delete Delete Delete
Image tDataStewardshipTaskInput Connects to and retrieves the data stored in campaigns in the form of tasks. Apply Delete Delete Delete Delete Delete
Image tDataStewardshipTaskOutput Connects to and loads data into campaigns in the form of tasks. The tasks must have the same schema defined in the campaign. Apply Delete Delete Delete Delete Delete
Talend MDM
Image tMDMBulkLoad Uses bulk mode to write XML structured master data into the MDM server. Apply Delete Delete Delete Delete Delete
Image tMDMClose Terminates an open MDM server connection after the execution of the proceeding subJob. Apply Delete Delete Delete Delete Delete
Image tMDMCommit Commits all changes to the database made within the scope of a transaction in MDM. Apply Delete Delete Delete Delete Delete
Image tMDMConnection Opens an MDM server connection for convenient reuse in the current Job or transaction. Apply Delete Delete Delete Delete Delete
Image tMDMDelete Deletes master data records from specific entities in the MDM Hub. Apply Delete Delete Delete Delete Delete
Image tMDMInput Reads data in an MDM Hub and thus makes it possible to process this data. Apply Delete Delete Delete Delete Delete
Image tMDMOutput Writes data into or removes data from the MDM server. Apply Delete Delete Delete Delete Delete
Image tMDMReceive Decodes a context parameter holding MDM XML data and transforms it into a flat schema. Apply Delete Delete Delete Delete Delete
Image tMDMRestInput Reads data through the REST API from the MDM Hub for further processing. Apply Delete Delete Delete Delete Delete
Image tMDMRollback Rolls back any changes made in the database rather than definitively committing them, for example to prevent partial commits if an error occurs. Apply Delete Delete Delete Delete Delete
Image tMDMRouteRecord Helps Event Manager to identify the changes you have made on your data so that correlative actions can be triggered. Apply Delete Delete Delete Delete Delete
Image tMDMSP Offers a convenient way to centralize multiple or complex queries in an MDM Hub and calls the stored procedure easily. Apply Delete Delete Delete Delete Delete
Image tMDMTriggerInput Reads the XML message (Document type) sent by MDM and passes the information to the component that follows. Apply Delete Delete Delete Delete Delete
Image tMDMTriggerOutput Receives an XML flow (Document type) from the preceding component in the Job. Apply Delete Delete Delete Delete Delete
Image tMDMViewSearch Retrieves the MDM records from an MDM hub by applying filtering criteria you have created in a specific view and puts out results in XML structure. Apply Delete Delete Delete Delete Delete
Technical
Image tBoundedStreamInput Provides a data stream for the component to be tested and is suitable for use in a test case only. Delete Delete Delete Apply Delete Delete
Image tCollectAndCheck Shows and validates the result of a component test. Delete Delete Apply Apply Delete Delete
Image tHashInput Reads from the cache memory data loaded by tHashOutput to offer high-speed data feed, facilitating transactions involving a large amount of data. Apply Delete Delete Delete Delete Delete
Image tHashOutput Loads data to the cache memory to offer high-speed access, facilitating transactions involving a large amount of data. Apply Delete Delete Delete Delete Delete
Testing
Image cDataset Creates a new dataset or reference an existing dataset to send or receive messages. Delete Delete Delete Delete Delete Apply
Image cMock Simulates message generation and message endpoints for testing Routes and mediation rules. Delete Delete Delete Delete Delete Apply
Transformation
Image cContentEnricher Uses a consumer or producer to obtain additional data, respectively intended for event messaging and request/reply messaging. Delete Delete Delete Delete Delete Apply
Image cConvertBodyTo Converts the message body to the given class type. Delete Delete Delete Delete Delete Apply
Image cFlatPack Processes fixed width or delimited files or messages using the FlatPack library Delete Delete Delete Delete Delete Apply
Image cMap Executes transformations (called maps) between different sources and destinations by harnessing the capabilities of , available in the perspective. Delete Delete Delete Delete Delete Apply
Unstructured
Image tEDIFACTtoXML Transforms an EDIFACT message file into the XML format for better readability to users and compatibility with processing tools. Apply Delete Delete Delete Delete Delete
Image tExtractEDIField Reads the EDI structured data from an EDIFACT message file, generates an XML according to the EDIFACT family and the EDIFACT type, extracts data by parsing the generated XML using the XPath queries manually defined or coming from the Repository wizard, and finally sends the data to the next component via a Row connection. Apply Delete Delete Delete Delete Delete
Webservice
Image tRestWebServiceLookupInput Retrieves messages from a REpresentational State Transfer (REST) Web service provider and gets responses accordingly. Delete Delete Delete Apply Delete Delete
Image tRestWebServiceOutput Serves as a REpresentational State Transfer (REST) Web service client that continuously sends HTTP requests to a REST Web service provider in real time and gets the responses. Delete Delete Delete Apply Delete Delete
XML
Image tAdvancedFileOutputXML Writes an XML file with separated data values according to an XML tree structure. Apply Delete Delete Delete Delete Delete
Image tDTDValidator Helps at controlling data and structure quality of the file to be processed Apply Delete Delete Delete Delete Delete
Image tEDIFACTtoXML Transforms an EDIFACT message file into the XML format for better readability to users and compatibility with processing tools. Apply Delete Delete Delete Delete Delete
Image tWriteXMLField Reads an input XML file and extracts the structure to insert it in defined fields of the output XML file. Apply Delete Delete Delete Delete Delete
Image tXMLMap Transforms and routes data from single or multiple sources to single or multiple destinations. Apply Delete Delete Delete Delete Delete
Image tXSDValidator Helps at controlling data and structure quality of the file or flow to be processed. Apply Delete Delete Delete Delete Delete
Image tXSLT Helps to transform data structure to another structure. Apply Delete Delete Delete Delete Delete