Sha256: 85d0c0c03f260b4604592b235508d67172e5d3d374b31f4f090de2ae8f90fc5d

Contents?: true

Size: 671 Bytes

Versions: 1

Compression:

Stored size: 671 Bytes

Contents

# Murmur2 Partitioner filter plugin for Embulk

Add partition number that is calculated by Apache Kafka's murmur2 partitioner.

## Overview

* **Plugin type**: filter

## Configuration

- **key_column**: column as partition key (string, required)
- **partition_column**: set partition number to this column. unless the column exists, add the column to output schema automatically. (string, default: `"partition"`)
- **partition_count**: Partition Count (integer, required)

## Example

```yaml
filters:
  - type: murmur2_partitioner
    key_column: id
    partition_count: 8
```


## Build

```
$ ./gradlew gem  # -t to watch change of files and rebuild continuously
```

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
embulk-filter-murmur2_partitioner-0.1.0 README.md