com.splout.db.hadoop
Class TablespaceSpec

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

public class TablespaceSpec
extends java.lang.Object

Immutable bean that defines a Tablespace whose view has to be generated. It may contain one or more Table beans. It can be obtained by TablespaceBuilder.

Method Summary

java.util.List<java.lang.String>	getInitStatements()
int	getnPartitions()
com.google.common.collect.ImmutableList<Table>	getPartitionedTables()
com.google.common.collect.ImmutableList<Table>	getReplicateAllTables()
static TablespaceSpec	of(org.apache.hadoop.conf.Configuration conf, java.lang.String[] partitionFields, org.apache.hadoop.fs.Path input, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat, int nPartitions) Schema-less quick tablespace builder that samples the first record of the first InputSplit in order to obtain the Table Schema.
static TablespaceSpec	of(com.datasalt.pangool.io.Schema schema, java.lang.String[] partitionFields, org.apache.hadoop.fs.Path input, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat, int nPartitions)
static TablespaceSpec	of(com.datasalt.pangool.io.Schema schema, java.lang.String partitionField, org.apache.hadoop.fs.Path input, org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat, int nPartitions) (Common case that can be built without using the builder)

Methods inherited from class java.lang.Object

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

Method Detail

of

public static TablespaceSpec of(com.datasalt.pangool.io.Schema schema,
                                java.lang.String partitionField,
                                org.apache.hadoop.fs.Path input,
                                org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat,
                                int nPartitions)

(Common case that can be built without using the builder)

of

public static TablespaceSpec of(org.apache.hadoop.conf.Configuration conf,
                                java.lang.String[] partitionFields,
                                org.apache.hadoop.fs.Path input,
                                org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat,
                                int nPartitions)
                         throws java.io.IOException,
                                java.lang.InterruptedException

Schema-less quick tablespace builder that samples the first record of the first InputSplit in order to obtain the Table Schema. Note that this will only work for InputFormats that can obtain the Schema implicitly (e.g. TupleInputFormat).

Throws:

java.io.IOException

java.lang.InterruptedException

of

public static TablespaceSpec of(com.datasalt.pangool.io.Schema schema,
                                java.lang.String[] partitionFields,
                                org.apache.hadoop.fs.Path input,
                                org.apache.hadoop.mapreduce.InputFormat<com.datasalt.pangool.io.ITuple,org.apache.hadoop.io.NullWritable> inputFormat,
                                int nPartitions)

getPartitionedTables

public com.google.common.collect.ImmutableList<Table> getPartitionedTables()

getReplicateAllTables

public com.google.common.collect.ImmutableList<Table> getReplicateAllTables()

getnPartitions

public int getnPartitions()

getInitStatements

public java.util.List<java.lang.String> getInitStatements()