Embulk plugins

Embulk plugins by category

List of Plugins by Category

This list is no longer automatically updated. Pull Requests are welcome directly to this site if you have updates!

INPUT

Star Name Author About
mysql
$ embulk gem install embulk-input-mysql
Sadayuki Furuhashi Selects records from a table.
s3
$ embulk gem install embulk-input-s3
Sadayuki Furuhashi Reads files stored on Amazon S3
postgresql
$ embulk gem install embulk-input-postgresql
Sadayuki Furuhashi Selects records from a table.
gcs
$ embulk gem install embulk-input-gcs
Satoshi Akama Reads files stored on Google Cloud Storage (Standard, Durable Reduced Availability or Nearline)
redshift
$ embulk gem install embulk-input-redshift
Sadayuki Furuhashi Selects records from a table.
jdbc
$ embulk gem install embulk-input-jdbc
Sadayuki Furuhashi Selects records from a table.
marketo
$ embulk gem install embulk-input-marketo
uu59, yoshihara, taikhuu Loads records from Marketo.
mongodb
$ embulk gem install embulk-input-mongodb
Kazuyuki Honda Loads records from Mongodb.
mixpanel
$ embulk gem install embulk-input-mixpanel
yoshihara, uu59 Loads records from Mixpanel.
sqlserver
$ embulk gem install embulk-input-sqlserver
Sadayuki Furuhashi Selects records from a table.
oracle
$ embulk gem install embulk-input-oracle
Sadayuki Furuhashi Selects records from a table.
hdfs
$ embulk gem install embulk-input-hdfs
Civitaspo Reads files stored on Hdfs.
google_analytics
$ embulk gem install embulk-input-google_analytics
uu59 Loads records from Google Analytics.
http
$ embulk gem install embulk-input-http
Takuma kanari Fetch data via http
jira
$ embulk gem install embulk-input-jira
uu59, yoshihara Loads records from Jira.
remote
$ embulk gem install embulk-input-remote
Shinichi Ishimura Reads files stored on Remote hosts by SCP.
zendesk
$ embulk gem install embulk-input-zendesk
uu59, muga, sakama Loads records from Zendesk.
riak_cs
$ embulk gem install embulk-input-riak_cs
Sadayuki Furuhashi Reads files stored on Riak CS
td
$ embulk gem install embulk-input-td
Muga Nishizawa Loads records from Td.
sftp
$ embulk gem install embulk-input-sftp
Satoshi Akama Reads files stored on remote server using SFTP.
google_spreadsheets
$ embulk gem install embulk-input-google_spreadsheets
Civitaspo, yang-xu Load records from Google Spreadsheets.
presto
$ embulk gem install embulk-input-presto
toyama0919 Facebook Presto input plugin for Embulk.
azure_blob_storage
$ embulk gem install embulk-input-azure_blob_storage
Satoshi Akama Reads files stored on Microsoft Azure Blob Storage.
command
$ embulk gem install embulk-input-command
Sadayuki Furuhashi Executes a command and reads a file from its STDOUT.
elasticsearch
$ embulk gem install embulk-input-elasticsearch
toyama0919 Loads records from Elasticsearch. parallel query support.
dynamodb
$ embulk gem install embulk-input-dynamodb
Daisuke Higashi "Loads records from Dynamodb."
ftp
$ embulk gem install embulk-input-ftp
Sadayuki Furuhashi Reads files stored on a FTP server.
pcapng-files
$ embulk gem install embulk-input-pcapng-files
enukane Pcapng Files input plugin for Embulk
db2
$ embulk gem install embulk-input-db2
Sadayuki Furuhashi Selects records from a table.
bigquery
$ embulk gem install embulk-input-bigquery
potato2003, Naotoshi Seo, Takeru Narita embulk input plugin from bigquery.
filesplit
$ embulk gem install embulk-input-filesplit
Hitoshi Tanaka Embulk plugin for splitting input file
lkqd
$ embulk gem install embulk-input-lkqd
Ming Liu Loads reporting data from LKQD API.
randomj
$ embulk gem install embulk-input-randomj
yuokada Embulk plugin for generate dummy records by Java.
vertica
$ embulk gem install embulk-input-vertica
Naotoshi Seo Loads records from Vertica.
yelp
$ embulk gem install embulk-input-yelp
Dai MIKURUBE Loads records from Yelp.
slack-history
$ embulk gem install embulk-input-slack-history
Akihiro YAGASAKI Embulk input plugin for Slack chat history
aster
$ embulk gem install embulk-input-aster
ebyhr Loads records from Aster.
bigquery_extract_files
$ embulk gem install embulk-input-bigquery_extract_files
jo8937 Reads files stored on Google Cloud Storage that extracted from bigquery table or query result
healthplanet
$ embulk gem install embulk-input-healthplanet
Masahiro Yoshizawa Load records from Health Planet through Health Planet API v1.
random
$ embulk gem install embulk-input-random
KUMAZAKI Hiroki Create dummy table
swift
$ embulk gem install embulk-input-swift
yuuzi41 Reads files stored on Swift.
rediskeys
$ embulk gem install embulk-input-rediskeys
dokuma Loads records from Redis.
datastore
$ embulk gem install embulk-input-datastore
syucream Loads records from datastore.
twitterarchive
$ embulk gem install embulk-input-twitterarchive
takuya sato Loads records from Twitterarchive.
redash
$ embulk gem install embulk-input-redash
ariarijp Loads records from Redash.
sql
$ embulk gem install embulk-input-sql
kakusuke "Loads records from Sql."
apache-dummy-log
$ embulk gem install embulk-input-apache-dummy-log
Hiroyuki Sato Apache Dummy Log input plugin is an Embulk plugin that loads records from Apache Dummy Log so that any output plugins can receive the records. Search the output plugins by 'embulk-output' keyword.
redis
$ embulk gem install embulk-input-redis
Mitsunori Komatsu Embulk input plugins for Redis
jstat
$ embulk gem install embulk-input-jstat
KUBOTA Yuji Embulk input plugin for Java Virtual Machine statistics by jstat command.
teradata
$ embulk gem install embulk-input-teradata
ebyhr Loads records from Teradata.
athena
$ embulk gem install embulk-input-athena
shinji19 Loads records from Athena.
parquet_hadoop
$ embulk gem install embulk-input-parquet_hadoop
Koji AGAWA Loads records from Parquet files via Hadoop FileSystem.
inline
$ embulk gem install embulk-input-inline
toyama0919 Loads records from Yaml Inline.
slack_message
$ embulk gem install embulk-input-slack_message
yuemori Loads records from Slack Message.
sequence
$ embulk gem install embulk-input-sequence
tomykaira Generate sequential number.
yahoo_ads
$ embulk gem install embulk-input-yahoo_ads
ryota.yamada Loads records from Yahoo Ads.
soracom_harvest
$ embulk gem install embulk-input-soracom_harvest
Satoshi Akama Loads records from Soracom Harvest.
intersystems_cache
$ embulk gem install embulk-input-intersystems_cache
Karri Niemelä Loads records from Cache.
spotx
$ embulk gem install embulk-input-spotx
Ming Liu Loads records from Spotx API.
search_analytics
$ embulk gem install embulk-input-search_analytics
ryota.yamada Loads records from Search Analytics.
sitemap
$ embulk gem install embulk-input-sitemap
ryota.yamada Loads records from Sitemap.
clickhouse
$ embulk gem install embulk-input-clickhouse
TAC Loads records from Clickhouse.
gmail
$ embulk gem install embulk-input-gmail
mikoto2000 Loads records from Gmail.
salesforce_bulk
$ embulk gem install embulk-input-salesforce_bulk
mikoto2000 Loads records from Salesforce Bulk.
kintone
$ embulk gem install embulk-input-kintone
giwa Loads records from Kintone app
firestore
$ embulk gem install embulk-input-firestore
syucream Loads records from Google Cloud Firestore
sendgrid
$ embulk gem install embulk-input-sendgrid
kaacun Loads records from Sendgrid
cloudwatch_logs
$ embulk gem install embulk-input-cloudwatch_logs
Hiroshi Hatake Loads records from Cloudwatch Logs.
union
$ embulk gem install embulk-input-union
Civitaspo An input plugin for Embulk (https://github.com/embulk/embulk/) that unions all data loaded by your defined embulk input & filters plugin configuration.
zendesk_guide
$ embulk gem install embulk-input-zendesk_guide
syou6162 Loads records from Zendesk Guide.
kafka
$ embulk gem install embulk-input-kafka
joker1007 Loads records from Apache Kafka.
sparql
$ embulk gem install embulk-input-sparql
Mikami, Takeshi Loads records by SPARQL.
stripe
$ embulk gem install embulk-input-stripe
Daisuke Shimamoto Loads data from Stripe.
spanner
$ embulk gem install embulk-input-spanner
Civitaspo Loads data from Spanner.
http_json
$ embulk gem install embulk-input-http_json
Civitaspo Load data from REST API (JSON) with transforming by jq.
ahrefs
$ embulk gem install embulk-input-ahrefs
guchey Load data from Ahrefs.
Snowflake
$ embulk gem install embulk-input-snowflakedb
kenkoooo Snowflake input plugin for Embulk

OUTPUT

Star Name Author About
bigquery
$ embulk gem install embulk-output-bigquery
Satoshi Akama, Naotoshi Seo Embulk plugin that insert records to Google BigQuery.
mysql
$ embulk gem install embulk-output-mysql
Sadayuki Furuhashi Inserts or updates records to a table.
redshift
$ embulk gem install embulk-output-redshift
Sadayuki Furuhashi Inserts or updates records to a table.
postgresql
$ embulk gem install embulk-output-postgresql
Sadayuki Furuhashi Inserts or updates records to a table.
td
$ embulk gem install embulk-output-td
Muga Nishizawa TreasureData output plugin is an Embulk plugin that loads records to TreasureData read by any input plugins. Search the input plugins by 'embulk-output' keyword.
s3
$ embulk gem install embulk-output-s3
Manabu Takayama Stores files on S3.
vertica
$ embulk gem install embulk-output-vertica
Naotoshi Seo, Eiji Sekiya Dump records to vertica
oracle
$ embulk gem install embulk-output-oracle
Sadayuki Furuhashi Inserts or updates records to a table.
jdbc
$ embulk gem install embulk-output-jdbc
Sadayuki Furuhashi Inserts or updates records to a table.
command
$ embulk gem install embulk-output-command
Sadayuki Furuhashi Executes commands and writes files to STDIN.
elasticsearch
$ embulk gem install embulk-output-elasticsearch
Muga Nishizawa Elasticsearch output plugin is an Embulk plugin that loads records to Elasticsearch read by any input plugins. Search the input plugins by "embulk-input" keyword.
sqlserver
$ embulk gem install embulk-output-sqlserver
Sadayuki Furuhashi Inserts or updates records to a table.
s3_per_record
$ embulk gem install embulk-output-s3_per_record
tomykaira Upload a column's value to S3 as one S3 object per row.
sftp
$ embulk gem install embulk-output-sftp
Civitaspo, Satoshi Akama Stores files on SFTP server.
mailchimp
$ embulk gem install embulk-output-mailchimp
Thang Nguyen Dumps records to MailChimp.
postgres-udf
$ embulk gem install embulk-output-postgres-udf
kakusuke Dumps records to PostgreSQL via user-defined function.
bigobject
$ embulk gem install embulk-output-bigobject
Cheng-Ching Huang Dumps records to Bigobject.
hdfs
$ embulk gem install embulk-output-hdfs
Civitaspo Stores files on Hdfs.
ftp
$ embulk gem install embulk-output-ftp
Satoshi Akama Store files using FTP.
gcs
$ embulk gem install embulk-output-gcs
Kazuyuki Honda "Dumps records to Google Cloud Storage."
google_spreadsheets
$ embulk gem install embulk-output-google_spreadsheets
Noriaki Katayama Dumps records to Google Spreadsheets.
aerospike
$ embulk gem install embulk-output-aerospike
Takeru Sato Dumps records to Aerospike.
parquet
$ embulk gem install embulk-output-parquet
OKUNO Akihiro Parquet output plugin is an Embulk plugin that loads records to Parquet read by any input plugins. Search the input plugins by "embulk-input" keyword.
db2
$ embulk gem install embulk-output-db2
Sadayuki Furuhashi Inserts or updates records to a table.
azure_blob_storage
$ embulk gem install embulk-output-azure_blob_storage
Satoshi Akama Stores files on Microsoft Azure Blob Storage.
dynamodb
$ embulk gem install embulk-output-dynamodb
Satoshi Akama Dumps records to AWS DynamoDB.
salesforce
$ embulk gem install embulk-output-salesforce
Makoto Tajitsu Dumps records to Salesforce.
elasticsearch5
$ embulk gem install embulk-output-elasticsearch5
Muga Nishizawa Elasticsearch5 output plugin is an Embulk plugin that loads records to Elasticsearch read by any input plugins. Search the input plugins by "embulk-input" keyword.
elasticsearch_ruby
$ embulk gem install embulk-output-elasticsearch_ruby
toyama0919 Dumps records to Elasticsearch Ruby. Elasticsearch 1.X AND 2.X AND 5.X compatible.
orc
$ embulk gem install embulk-output-orc
yuokada Dumps records to Orc format file.
elasticsearch_1.x
$ embulk gem install embulk-output-elasticsearch_1.x
Muga Nishizawa, Shinji Ikeda Elasticsearch 1.x output plugin is an Embulk plugin that loads records to Elasticsearch read by any input plugins. Search the input plugins by "embulk-input" keyword.
influxdb
$ embulk gem install embulk-output-influxdb
joker1007 Dumps records to InfluxDB.
redis
$ embulk gem install embulk-output-redis
Mitsunori Komatsu Embulk output plugins for Redis
elasticsearch_using_url
$ embulk gem install embulk-output-elasticsearch_using_url
Yuma Murata Dumps records to Elasticsearch Using Url.
swift
$ embulk gem install embulk-output-swift
yuuzi41 Stores files on OpenStack Swift.
influxdb08
$ embulk gem install embulk-output-influxdb08
atsaki Dumps records to InfluxDB v0.8.
teradata
$ embulk gem install embulk-output-teradata
ebyhr Dumps records to Teradata.
analytics_cloud
$ embulk gem install embulk-output-analytics_cloud
Makoto Tajitsu Dumps records to Analytics Cloud.
embulk_output_domo
$ embulk gem install embulk-output-embulk_output_domo
Angelos Alexopoulos Dumps records to Embulk Output Domo.
sqlite3
$ embulk gem install embulk-output-sqlite3
Yuichi Takada SQLite3 output plugin for Embulk
cassandra
$ embulk gem install embulk-output-cassandra
joker1007 Dumps records to Apache Cassandra.
aster
$ embulk gem install embulk-output-aster
ebyhr Dumps records to Aster.
groonga
$ embulk gem install embulk-output-groonga
Hiroyuki Sato Dumps records to Groonga.
postgres-json
$ embulk gem install embulk-output-postgres-json
Sadayuki Furuhashi Embulk output for PostgreSQL json and jsonb column
zendesk_users
$ embulk gem install embulk-output-zendesk_users
Toru Takahashi Update Zendesk User's segments
trafodion
$ embulk gem install embulk-output-trafodion
Alex Peng Dumps records to Trafodion.
rediskeys
$ embulk gem install embulk-output-rediskeys
dokuma Dumps records to Redis.
documentdb
$ embulk gem install embulk-output-documentdb
Yoichi Kawasaki Dumps records to Azure DocumentDB
azuresearch
$ embulk gem install embulk-output-azuresearch
Yoichi Kawasaki Dumps records to Azure Search
utf8parquet
$ embulk gem install embulk-output-utf8parquet
Angelos Alexopoulos Parquet output plugin is an Embulk plugin that loads records to Parquet read by any input plugins. Search the input plugins by "embulk-input" keyword.
slack_file_upload
$ embulk gem install embulk-output-slack_file_upload
takumakanari Upload files to Slack.
mongodb_nest
$ embulk gem install embulk-output-mongodb_nest
focuschange Dumps records to Mongodb with subdocument
larges3
$ embulk gem install embulk-output-larges3
Angelos Alexopoulos Embulk Output Plugin: Dumps really large files to S3.
mongodb
$ embulk gem install embulk-output-mongodb
Hiroki Mizumoto Dumps records to Mongodb.
fluentd
$ embulk gem install embulk-output-fluentd
smdmts Dumps records to Fluentd.
google_analytics
$ embulk gem install embulk-output-google_analytics
ryota.yamada This plugin performs the data import and measurement protocol into Google Analytics.
google_sheets_ruby
$ embulk gem install embulk-output-google_sheets_ruby
ariarijp Dumps records to Google Sheets.
pixela
$ embulk gem install embulk-output-pixela
Toru Takahashi Dumps records to Pixela.
s3_parquet
$ embulk gem install embulk-output-s3_parquet
Civitaspo Embulk (https://github.com/embulk/embulk/) output plugin to dump records as Apache Parquet (https://parquet.apache.org/) files on S3.
kafka
$ embulk gem install embulk-output-kafka
joker1007 Embulk (https://github.com/embulk/embulk/) output plugin to dump records to Apache Kafka (https://kafka.apache.org/).
http_json
$ embulk gem install embulk-output-http_json
Civitaspo Egest records as json via http.
send_email
$ embulk gem install embulk-output-send_email
Utkarsh Panwar An output plugin for Embulk to send email with data.
snowflake
$ embulk gem install embulk-output-snowflake
giwa Embulk plugin that insert records to Snowflake Data Cloud.

FILTER

Star Name Author About
column
$ embulk gem install embulk-filter-column
Naotoshi Seo A filter plugin for Embulk to filter out columns.
add_time
$ embulk gem install embulk-filter-add_time
Muga Nishizawa Add time column to the schema
ruby_proc
$ embulk gem install embulk-filter-ruby_proc
joker1007 Filter each record by ruby proc
expand_json
$ embulk gem install embulk-filter-expand_json
Civitaspo Expand Json
row
$ embulk gem install embulk-filter-row
Naotoshi Seo A filter plugin for Embulk to filter out rows with conditions.
hash
$ embulk gem install embulk-filter-hash
Shinichi Ishimura Embulk filter plugin to convert an input to a hash value.
timestamp_format
$ embulk gem install embulk-filter-timestamp_format
Naotoshi Seo A filter plugin for Embulk to change timestamp format.
eval
$ embulk gem install embulk-filter-eval
mgi166 Eval
to_json
$ embulk gem install embulk-filter-to_json
Civitaspo To Json
flatten_json
$ embulk gem install embulk-filter-flatten_json
Civitaspo Flatten Json
insert
$ embulk gem install embulk-filter-insert
Masahiro Yoshizawa Embulk filter plugin that inserts column(s) at any position (e.g., the top/bottom of the columns, before/after the specified column name)
typecast
$ embulk gem install embulk-filter-typecast
Naotoshi Seo A filter plugin for Embulk to cast column type.
rename_with_gsub
$ embulk gem install embulk-filter-rename_with_gsub
sesame Rename With Gsub
mask
$ embulk gem install embulk-filter-mask
Tetsuo Yamabe Mask
key_in_redis
$ embulk gem install embulk-filter-key_in_redis
smdmts Key In Redis
speedometer
$ embulk gem install embulk-filter-speedometer
hata Write log message of processed bytes and throughput periodically.
json_key_joiner
$ embulk gem install embulk-filter-json_key_joiner
smdmts Json Key Joiner
kuromoji
$ embulk gem install embulk-filter-kuromoji
toyama0919 Kuromoji filter plugin for Embulk. Neologd support.
script_ruby
$ embulk gem install embulk-filter-script_ruby
shinjiikeda Script Ruby
woothee
$ embulk gem install embulk-filter-woothee
toyama0919 Woothee filter plugin for Embulk
distinct
$ embulk gem install embulk-filter-distinct
Civitaspo Distinct
query_string_ruby
$ embulk gem install embulk-filter-query_string_ruby
Yuma Murata Query String Ruby
query_string
$ embulk gem install embulk-filter-query_string
Minnano Wedding Co., Ltd. The query string filter plugin parses the column contents as query string and insert columns from that field.
icu4j
$ embulk gem install embulk-filter-icu4j
toyama0919 Unicode normalize string value. see http://site.icu-project.org/
expand_json_array
$ embulk gem install embulk-filter-expand_json_array
Naoki AINOYA Expand Json Array
base58
$ embulk gem install embulk-filter-base58
Kevin Fitzgerald Embulk filter plugin to convert a hex value to and from base58.
to_csv
$ embulk gem install embulk-filter-to_csv
Civitaspo To Csv
mysql
$ embulk gem install embulk-filter-mysql
toyama0919 Mysql filter plugin for Embulk. Execute prepared statements query.
crawler
$ embulk gem install embulk-filter-crawler
toyama0919 Crawler4J filter plugin for Embulk
split_column
$ embulk gem install embulk-filter-split_column
yskn67 A filter plugin for Embulk to split one string column to several any type columns.
calcite
$ embulk gem install embulk-filter-calcite
Muga Nishizawa Translate schema and column values by SQL-like query provided by Apache Calcite.
join_file
$ embulk gem install embulk-filter-join_file
Civitaspo Join File
timestamp_hs
$ embulk gem install embulk-filter-timestamp_hs
Matsuoka Takashi Convert string to timestamp at high speed.
json_key
$ embulk gem install embulk-filter-json_key
Civitaspo Json Key
google_translate_api
$ embulk gem install embulk-filter-google_translate_api
toyama0919 Google Translate Api filter plugin for Embulk
stdout
$ embulk gem install embulk-filter-stdout
sonots Embulk filter plugin to print embulk records to stdout
google_vision_api
$ embulk gem install embulk-filter-google_vision_api
toyama0919 Google Vision Api filter plugin for Embulk. Very easy image recognition.
encrypt
$ embulk gem install embulk-filter-encrypt
Sadayuki Furuhashi Encrypt
azure_computer_vision_api
$ embulk gem install embulk-filter-azure_computer_vision_api
toyama0919 Azure Computer Vision Api
rearrange
$ embulk gem install embulk-filter-rearrange
Tooru Okano Rearrange
base64
$ embulk gem install embulk-filter-base64
Yusuke NISHIOKA An Embulk filter plugin to encode/decode string by Base64, Base32 and Base16.
calc
$ embulk gem install embulk-filter-calc
Hiroyuki Sato Calc
amazon_rekognition
$ embulk gem install embulk-filter-amazon_rekognition
toyama0919 Amazon Rekognition
unique
$ embulk gem install embulk-filter-unique
Naohiro Aota Extract unique records
null_string
$ embulk gem install embulk-filter-null_string
Hiroyuki Sato An Embulk filter plugin to convert the matching string to NULL.
script
$ embulk gem install embulk-filter-script
SNakano Embulk filter plugin to external ruby script
copy
$ embulk gem install embulk-filter-copy
Civitaspo Copy records and run another embulk by using them as input data source.
url_encode
$ embulk gem install embulk-filter-url_encode
Minnano Wedding Co., Ltd. The encode filter plugin encodes a column in the URL encoding format.
azure_text_analytics
$ embulk gem install embulk-filter-azure_text_analytics
toyama0919 Azure Text Analytics
pherialize
$ embulk gem install embulk-filter-pherialize
cynipe Embulk plugin that deserialize PHP serialized strings to extract values as new column
forcepoint_converter
$ embulk gem install embulk-filter-forcepoint_converter
sesame Forcepoint Converter
google_natural_language_api
$ embulk gem install embulk-filter-google_natural_language_api
toyama0919 Google Natural Language Api filter plugin for Embulk
jsoncolumn
$ embulk gem install embulk-filter-jsoncolumn
dokuma Jsoncolumn
reverse_geocoding
$ embulk gem install embulk-filter-reverse_geocoding
oqrusk Reverse Geocoding
strip_html_tags
$ embulk gem install embulk-filter-strip_html_tags
SAWADA Tadashi Strip Html Tags
protobuf
$ embulk gem install embulk-filter-protobuf
Yusuke NISHIOKA An Embulk filter plugin for interconversion between Protocol Buffer message and JSON.
gsub
$ embulk gem install embulk-filter-gsub
Sawada Tadashi Embulk filter plugin to convert text column values with regular expressions
azure_translator_api
$ embulk gem install embulk-filter-azure_translator_api
toyama0919 Azure Translator Api
affix
$ embulk gem install embulk-filter-affix
imura81gt Affix
convert_unicode_sequence_to_string
$ embulk gem install embulk-filter-convert_unicode_sequence_to_string
reizist Convert unicode sequence to string.
mysql_lookup
$ embulk gem install embulk-filter-mysql_lookup
Utkarsh Panwar An Embulk filter plugin for Lookup Transformation with MySQL database.
mssql_lookup
$ embulk gem install embulk-filter-mssql_lookup
Utkarsh Panwar An Embulk filter plugin for Lookup Transformation with MS-SQL database.
postgres_lookup
$ embulk gem install embulk-filter-postgres_lookup
Utkarsh Panwar An Embulk filter plugin for Lookup Transformation with Postgres database.
oracle_lookup
$ embulk gem install embulk-filter-oracle_lookup
Utkarsh Panwar An Embulk filter plugin for Lookup Transformation with Oracle database.
csv_lookup
$ embulk gem install embulk-filter-csv_lookup
Utkarsh Panwar An Embulk filter plugin for Lookup Transformation with CSV.

FILE PARSER

Star Name Author About
jsonl
$ embulk gem install embulk-parser-jsonl
Shunsuke Mikami Parses Jsonl files read by other file input plugins.
none
$ embulk gem install embulk-parser-none
Naotoshi Seo Embulk parser plugin not to parse at all.
json
$ embulk gem install embulk-parser-json
Takuma kanari Json parser plugin is Embulk plugin to fetch entries in json format with jsonpath.
firebase_avro
$ embulk gem install embulk-parser-firebase_avro
smdmts Parses Firebase Avro files read by other file input plugins.
poi_excel
$ embulk gem install embulk-parser-poi_excel
hishidama Parses Excel files(xls, xlsx) read by other file input plugins.
avro
$ embulk gem install embulk-parser-avro
joker1007 Parses Avro files read by other file input plugins.
query_string
$ embulk gem install embulk-parser-query_string
yoshihara, uu59 Parses Query String files read by other file input plugins.
xml
$ embulk gem install embulk-parser-xml
Takuma kanari XML parser plugin is Embulk plugin to fetch entries in xml format.
msgpack
$ embulk gem install embulk-parser-msgpack
Sadayuki Furuhashi Parses files encoded in MessagePack.
regex
$ embulk gem install embulk-parser-regex
Ken Morishita Parses lines using regular-expression in files read by other file input plugins.
jsonpath
$ embulk gem install embulk-parser-jsonpath
Hiroyuki Sato, Takuma kanari Parses JSON files with JSONPath read by other file input plugins.
ltsv
$ embulk gem install embulk-parser-ltsv
toyama0919 Parses Ltsv files read by other file input plugins.
regexp
$ embulk gem install embulk-parser-regexp
sesame Parses Regexp files read by other file input plugins.
apache-custom-log
$ embulk gem install embulk-parser-apache-custom-log
Hiroyuki Sato, Osamu Ishikawa Parses Apache Custom Log files read by other file input plugins.
grok
$ embulk gem install embulk-parser-grok
Ikezoe Akihiro, Rishi Kathera Parses Grok files read by other file input plugins.
xpath2
$ embulk gem install embulk-parser-xpath2
maji-KY Parses XML files read by other file input plugins.
csv_guessable
$ embulk gem install embulk-parser-csv_guessable
koooge Parses Guessable Csv files read by other file input plugins.
apache-log
$ embulk gem install embulk-parser-apache-log
Hiroyuki Sato Parses Apache Log files read by other file input plugins.
twitter_ads_stats
$ embulk gem install embulk-parser-twitter_ads_stats
kimutyam Parses Twitter Ads Stats files read by other file input plugins.
apache_error_log
$ embulk gem install embulk-parser-apache_error_log
Tomohiro Mitsumune Parses Apache Error Log files read by other file input plugins.
fluent-s3-log
$ embulk gem install embulk-parser-fluent-s3-log
y-matsuwitter Parses Fluent S3 Log files read by other file input plugins.
roo-excel
$ embulk gem install embulk-parser-roo-excel
Hiroyuki Sato Parses Excel files(xlsx) read by other file input plugins.
sisimai
$ embulk gem install embulk-parser-sisimai
Hiroyuki Sato Parses Sisimai Analyzer files read by other file input plugins.
jdbc-schema-csv
$ embulk gem install embulk-parser-jdbc-schema-csv
Hitoshi Tanaka This Embulk plugin extends CSV parser to define columns based on database meta data.
pcapng
$ embulk gem install embulk-parser-pcapng
enukane Pcapng parser plugin is an Embulk plugin that parses Pcapng file format read by any file input plugins. Search the file input plugins by 'embulk-input file' keywords.
forcepoint
$ embulk gem install embulk-parser-forcepoint
sesame Parses Forcepoint files read by other file input plugins.
unpack
$ embulk gem install embulk-parser-unpack
Karri Niemelä Parses fixed width files read by other file input plugins.
xpath
$ embulk gem install embulk-parser-xpath
Tatsunori Matoba XPath parser plugin is Embulk plugin to fetch entries in xml format use XPath.
fluentd_out_file
$ embulk gem install embulk-parser-fluentd_out_file
Muga Nishizawa Parses Fluentd Out File files read by other file input plugins.
mysqldump_tab
$ embulk gem install embulk-parser-mysqldump_tab
inouet Embulk parser plugin for mysqldump file that dumped with the --tab option.
csv_with_default_value
$ embulk gem install embulk-parser-csv_with_default_value
Kazuhiro Sasaki Parses Csv With Default Value files read by other file input plugins.
fixed
$ embulk gem install embulk-parser-fixed
Karri Niemelä Parses fixed width files read by other file input plugins.
csv_with_schema_file
$ embulk gem install embulk-parser-csv_with_schema_file
jo8937 Parses csv files with schema file read by other file input plugins.
none-bin
$ embulk gem install embulk-parser-none-bin
Klaus Woelfel Embulk parser plugin not to parse at all.
jsonline
$ embulk gem install embulk-parser-jsonline
locona Parses Jsonl files read by other file input plugins.
joni_regexp
$ embulk gem install embulk-parser-joni_regexp
Hiroyuki Sato The Embulk parser plugin for the Fluentd regex parser(Oniguruma) compatible.
mahout
$ embulk gem install embulk-parser-mahout
kihengk Parses Mahout files read by other file input plugins.
variable_length_bytes
$ embulk gem install embulk-parser-variable_length_bytes
Koji Matsumoto Parses variable length bytes files read by other file input plugins.
flexml
$ embulk gem install embulk-parser-flexml
Fs02 XML parser plugin is Embulk plugin to fetch entries in xml format. Supports xpath and attributes.

FILE DECODER

Star Name Author About
remove_nonstandard_utf8_bytes
$ embulk gem install embulk-decoder-remove_nonstandard_utf8_bytes
smdmts Decodes Remove Nonstandard Utf8 Bytes-encoded files read by other file input plugins.
commons-compress
$ embulk gem install embulk-decoder-commons-compress
hata Commons Compress decoder plugin is an Embulk plugin that decodes files using Apache Commons Compress library. It is read by any file input plugins. Search the file input plugins by 'embulk-input file' keywords.
lzo
$ embulk gem install embulk-decoder-lzo
ntkes3 Decodes Lzo-encoded files read by other file input plugins.
lz4
$ embulk gem install embulk-decoder-lz4
yuuzi41 Decodes LZ4 files read by other file input plugins.
command
$ embulk gem install embulk-decoder-command
ksss Decodes any files read by other file input plugins.
exec
$ embulk gem install embulk-decoder-exec
ksss Decodes Exec-encoded files read by other file input plugins.

FILE FORMATTER

Star Name Author About
jsonl
$ embulk gem install embulk-formatter-jsonl
TAKEI Yuya Formats Embulk Formatter Jsonl files for other file output plugins.
single_value
$ embulk gem install embulk-formatter-single_value
Naotoshi Seo Embulk formatter plugin to output values of a single column.
fast_jsonl
$ embulk gem install embulk-formatter-fast_jsonl
smdmts fast_jsonl.
avro
$ embulk gem install embulk-formatter-avro
joker1007 Formats Avro files for other file output plugins.
poi_excel
$ embulk gem install embulk-formatter-poi_excel
hishidama Formats Excel files(xls, xlsx) for other file output plugins.
markdown_table
$ embulk gem install embulk-formatter-markdown_table
yuemori Formats Markdown Table files for other file output plugins.
html_table
$ embulk gem install embulk-formatter-html_table
yuemori Formats Html Table files for other file output plugins.
geojson
$ embulk gem install embulk-formatter-geojson
lewuathe Formats Geojson files for other file output plugins.
sprintf
$ embulk gem install embulk-formatter-sprintf
toyama0919 Formats Sprintf(Java String#format) files for other file output plugins.

FILE ENCODER

Star Name Author About
commons-compress
$ embulk gem install embulk-encoder-commons-compress
hata Commons Compress encoder plugin is an Embulk plugin that encodes files using Commons Compress so that any file output plugins can store the files. Search the file output plugins by 'embulk-output file' keywords.
encrypted_zip
$ embulk gem install embulk-encoder-encrypted_zip
Ken Morishita Encodes files using Encrypted Zip for other file output plugins.
xz
$ embulk gem install embulk-encoder-xz
Sadayuki Furuhashi Compress files using XZ (also know as LZMA)
pgp_encryption
$ embulk gem install embulk-encoder-pgp_encryption
Ken Morishita Encodes files using PGP Encryption for other file output plugins.
lz4
$ embulk gem install embulk-encoder-lz4
yuuzi41 Encodes LZ4 files for other file output plugins.
command
$ embulk gem install embulk-encoder-command
ksss Encodes files using any command output for other file output plugins.

EXECUTOR

Star Name Author About
mapreduce
$ embulk gem install embulk-executor-mapreduce
Sadayuki Furuhashi Executes tasks on Hadoop.
mapreduce_2_6
$ embulk gem install embulk-executor-mapreduce_2_6
Sadayuki Furuhashi Executes tasks on Hadoop.
mapreduce_2_7
$ embulk gem install embulk-executor-mapreduce_2_7
Sadayuki Furuhashi Executes tasks on Hadoop.