com.splout.db.hadoop
Class SchemaSampler

java.lang.Object
  com.splout.db.hadoop.SchemaSampler

public class SchemaSampler
extends java.lang.Object

Small piece of code that can sample a Pangool Schema from an arbitrary InputFormat. It just reads the first Tuple and reads the Schema from it.

Constructor Summary

SchemaSampler()

Method Summary

static com.datasalt.pangool.io.Schema

sample(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path input, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SchemaSampler

public SchemaSampler()

Method Detail

sample

public static com.datasalt.pangool.io.Schema sample(org.apache.hadoop.conf.Configuration conf,
                                                    org.apache.hadoop.fs.Path input,
                                                    org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat)
                                             throws java.io.IOException,
                                                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException