Sha256: 76b2756cae1f0d8df27ffbc4418f191e1902e4880b0d37138031bf7c622950c0

Contents?: true

Size: 1.43 KB

Versions: 6

Compression:

Stored size: 1.43 KB

Contents

# Facebook Presto input plugin for Embulk [![Build Status](https://secure.travis-ci.org/toyama0919/embulk-input-presto.png?branch=master)](http://travis-ci.org/toyama0919/embulk-input-presto)

Facebook Presto input plugin for Embulk.
[see](https://prestodb.io/).

## Overview

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

## Configuration

- **host**: host (string, default: `"localhost"`)
- **port**: port (integer, default: `8080`)
- **schema**: schema (string, default: `"default"`)
- **catalog**: catalog (string, default: `"native"`)
- **query**: query (string, required)
- **user**: user (string, default: `"embulk"`)
- **columns**(**deprecated**): columns (array, required)
  - **name**: name (string, required)
  - **type**: type (string, required)

**Warning** : **columns** deprecated since over v0.2.0. Support auto fetch schema.

## Example

```yaml
in:
  type: presto
  host: presto-cordinator
  catalog: store
  schema: public
  query: |
    SELECT
      trim(upper(url_decode(keyword))) AS keyword,
      count(*) as count
    FROM search
    CROSS JOIN UNNEST(split(keywords, ',')) AS t (keyword)
    WHERE log_date >= (CURRENT_DATE - INTERVAL '90' DAY)
     AND length(keywords) != 256
    group by keyword
    having count(*) >= 10
    order by count(*) desc
out:
  type: stdout
```

## Support type
* TIMESTAMP
* LONG
* DOUBLE
* BOOLEAN
* STRING
* JSON

## Build

```
$ rake
```

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
embulk-input-presto-0.2.5 README.md
embulk-input-presto-0.2.4 README.md
embulk-input-presto-0.2.3 README.md
embulk-input-presto-0.2.2 README.md
embulk-input-presto-0.2.1 README.md
embulk-input-presto-0.2.0 README.md