Operators

• Workflow control operators
  • call>: Calls another workflow
  • http_call>: Call workflow fetched by HTTP
  • require>: Depends on another workflow
  • loop>: Repeat tasks
  • for_each>: Repeat tasks for values
  • for_range>: Repeat tasks for a range
  • if>: Conditional execution
  • fail>: Makes the workflow failed
  • echo>: Shows a message
• Treasure Data operators
  • td>: Treasure Data queries
  • td_run>: Treasure Data saved queries
  • td_ddl>: Treasure Data operations
  • td_load>: Treasure Data bulk loading
  • td_for_each>: Repeat using Treasure Data queries
  • td_wait>: Waits for data arriving at Treasure Data table
  • td_wait_table>: Waits for data arriving at Treasure Data table
  • td_partial_delete>: Delete range of Treasure Data table
  • td_table_export>: Treasure Data table export to S3
• Database operators
  • pg>: PostgreSQL operations
• Network operators
  • mail>: Sending email
  • http>: Making HTTP requests
• Amazon Web Services operators
  • s3_wait>: Wait for a file in Amazon S3
  • redshift>: Redshift operations
  • redshift_load>: Redshift load operations
  • redshift_unload>: Redshift unload operations
  • emr>: Amazon Elastic Map Reduce
• Google Cloud Platform operators
  • gcs_wait>: Wait for a file in Google Cloud Storage
  • bq>: Running Google BigQuery queries
  • bq_ddl>: Managing Google BigQuery Datasets and Tables
  • bq_extract>: Exporting Data from Google BigQuery
  • bq_load>: Importing Data into Google BigQuery
• Scripting operators
  • sh>: Shell scripts
  • py>: Python scripts
  • rb>: Ruby scripts
  • embulk>: Embulk data transfer
• Param operators
  • param_get>: Get persistent data from ParamServer and set it as a value of store parameters
  • param_set>: Set a value into a ParamServer as persistent data