GraalPy filter for Embulk

Uses GraalPy to run filter functions. Use JDK from https://github.com/graalvm/graalvm-ce-builds/releases to run this. This build assumes version 23.

Overview

• Plugin type: filter
• Guess supported: no
• Embulk 0.11 or later

Example

in:
  type: any file input plugin type
  ...
filters:
  - type: python
    python_code: |
      print("Hello from python and the record is:", record)
      # Modify the 'a' field
      record['a'] = record['a'] + "b"
      record['c'] = 5
      # Return the modified record
      return record
   

Build

$ ./gradlew gem