RethinkDB input plugin for Embulk loads records from RethinkDB.

• Plugin type: input
• Resume supported: no
• Cleanup supported: no
• Guess supported: no

• host: database host name (string, required)
• port: database port number (integer, default: 28015)
• database: database name (string, required)
• user: database login user name (string, required)
• password: database login password (string, required)
• cert_file: path to TLS CA certificate file (string)
• Select whether to write a query or specify only the table
  • query: ReQL to run (string)
    or
    
  • table: table from which load data from (string)
• column_name: column name used in outputs (string, default: "record")

ReQL specified in query option is described according to the following syntax rules.

• The syntax is JavaScript (ECMAScript 5.1) runs on Nashorn (JavaScript Engine developed in Java).
• The code must be an expression that evaluates to ReqlAst. (No trailing semicolon required)
• The RethinkDB object can be referenced as the variable r.

in:
  type: rethinkdb
  host: 'rethink'
  port: 28015
  database: 'test'
  user: 'admin'
  password: ''
  query:
    r.table("authors").filter(function(row) {
      return row.g("tv_show").eq("Battlestar Galactica");
    })
out: {type: stdout}

$ ./gradlew gem