Pigpen 0.3.3

Installation

To install, add the following dependency to your project or build file:

[pigpen "0.3.3"]

Namespaces

pigpen.avro

*** ALPHA - Subject to change ***

Public variables and functions:

pigpen.cascading

Functions to convert a PigPen query into a Cascading flow.

Public variables and functions:

pigpen.core

The core PigPen operations. These are the primary functions that you use to
build a PigPen query.

pigpen.core.fn

*** ALPHA - Subject to change ***

pigpen.core.op

*** ALPHA - Subject to change ***

pigpen.fold

Fold operations for use with pig/fold, pig/group-by, and pig/cogroup.

pigpen.parquet

Functions for reading and writing parquet data and for creating parquet
schemas. Start with `load-parquet` and `store-parquet`.

pigpen.pig

Functions to convert a PigPen query into a Pig script.

Public variables and functions:

pigpen.rx

A high performance dump operator. The default implementation in pigpen.core
uses lazy seqs, which can be inefficient on larger data. The rx implementation
uses rx-java to deliver a slightly more performance for large local datasets.

Public variables and functions:

pigpen.viz

Functions to create graph-viz graphs from PigPen queries.

Public variables and functions: