Sha256: e85e8a5ecc4bcf42f2588b5c48fd0adb6955d177038f62d6650fbf3206f4710e

Contents?: true

Size: 1.58 KB

Versions: 1

Compression:

Stored size: 1.58 KB

Contents

# RethinkDB input plugin for Embulk

[![Gem Version](https://badge.fury.io/rb/embulk-input-rethinkdb.svg)](https://badge.fury.io/rb/embulk-input-rethinkdb)

RethinkDB input plugin for Embulk loads records from RethinkDB.

## Overview

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

## Configuration

- **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)
    <br>or<br>
    - **table**: table from which load data from (string)
- **column_name**: column name used in outputs (string, default: `"record"`)

## ReQL for query option

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`.

## Example

```yaml
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}
```


## Build

```
$ ./gradlew gem
```

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
embulk-input-rethinkdb-0.1.2 README.md