MarkovPairs (datafu-pig 1.6.0 API)

java.lang.Object
- org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
- - datafu.pig.stats.MarkovPairs

```
public class MarkovPairs
extends org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
```
Accepts a bag of tuples, with user supplied ordering, and generates pairs that can be used for a Markov chain analysis. For example, if you had {(1), (4), (7)}, using the default lookahead of 1, you get the pairs { ((1),(4)), ((4),(7))} A lookahead factor tells the UDF how many steps in to the future to include. so, for a,b,c with a lookahead of 2, a would be paired with both b and c. The results are ordered are returned as ordered by the caller.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.pig.EvalFunc
  org.apache.pig.EvalFunc.SchemaType

Field Summary
- Fields inherited from class org.apache.pig.EvalFunc
  log, pigLogger, reporter, returnType

Constructors
Constructor and Description
`MarkovPairs()`
`MarkovPairs(java.lang.String lookahead_steps)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`org.apache.pig.data.DataBag`	`exec(org.apache.pig.data.Tuple input)`
`org.apache.pig.impl.logicalLayer.schema.Schema`	`outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)`

Methods inherited from class org.apache.pig.EvalFunc
allowCompileTimeCalculation, finish, getArgToFuncMapping, getCacheFiles, getInputSchema, getLogger, getPigLogger, getReporter, getReturnType, getSchemaName, getSchemaType, getShipFiles, isAsynchronous, progress, setInputSchema, setPigLogger, setReporter, setUDFContextSignature, warn

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public MarkovPairs(java.lang.String lookahead_steps)

public org.apache.pig.data.DataBag exec(org.apache.pig.data.Tuple input)
                                 throws java.io.IOException

Specified by:: exec in class org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>
Throws:: java.io.IOException

public org.apache.pig.impl.logicalLayer.schema.Schema outputSchema(org.apache.pig.impl.logicalLayer.schema.Schema input)

Overrides:: outputSchema in class org.apache.pig.EvalFunc<org.apache.pig.data.DataBag>

Class MarkovPairs