|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.zebra.types.Partition
public class Partition
Partition is a column group management class. Its responsibilities include storing column groups, handle column groups spliting and stitching by insertions and queries respectively.
Nested Class Summary | |
---|---|
class |
Partition.PartitionInfo
|
static class |
Partition.SplitType
Storage split types |
Constructor Summary | |
---|---|
Partition(Schema schema,
Projection projection,
String storage,
String comparator)
|
|
Partition(String schema,
String storage,
String comparator)
|
|
Partition(String schema,
String storage,
String comparator,
String sortColumns)
|
Method Summary | |
---|---|
CGSchema |
generateDefaultCGSchema(String name,
String compressor,
String serializer,
String owner,
String group,
short perm,
int defaultCGIndex,
String comparator)
|
CGSchema |
getCGSchema(int index)
|
CGSchema[] |
getCGSchemas()
|
String |
getComparator()
|
Partition.PartitionInfo |
getPartitionInfo()
|
Projection |
getProjection()
returns table projection |
String |
getProjection(int cgindex)
returns projection schema for a particular column group |
Schema |
getSchema()
returns table schema |
SortInfo |
getSortInfo()
|
HashSet<org.apache.hadoop.zebra.types.Partition.PartitionInfo.ColumnMappingEntry> |
getSplitMap(Schema.ColumnSchema fs)
|
void |
insert(org.apache.hadoop.io.BytesWritable key,
Tuple t)
insert a tuple after splits |
boolean |
isCGNeeded(int i)
|
boolean |
isSorted()
|
void |
read(Tuple t)
read in a tuple based on stitches |
boolean |
setCGIndex(Schema.ColumnSchema fs,
int ri,
int fi,
String name)
|
void |
setSource(Tuple[] tuples)
sets the source tuple for the column group ops |
void |
setSplit(Schema.ColumnSchema fs,
Partition.SplitType st,
Partition.SplitType cst,
String name,
String childName,
boolean splitChild)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Partition(Schema schema, Projection projection, String storage, String comparator) throws ParseException, IOException
ParseException
IOException
public Partition(String schema, String storage, String comparator, String sortColumns) throws ParseException, IOException
ParseException
IOException
public Partition(String schema, String storage, String comparator) throws ParseException, IOException
ParseException
IOException
Method Detail |
---|
public SortInfo getSortInfo()
public boolean isSorted()
public String getComparator()
public Schema getSchema()
public Partition.PartitionInfo getPartitionInfo()
public CGSchema[] getCGSchemas()
public CGSchema getCGSchema(int index)
public void read(Tuple t) throws AssertionError, IOException, Exception
AssertionError
IOException
Exception
public void insert(org.apache.hadoop.io.BytesWritable key, Tuple t) throws AssertionError, IOException, Exception
AssertionError
IOException
Exception
public void setSource(Tuple[] tuples) throws ParseException
ParseException
public String getProjection(int cgindex) throws ParseException
ParseException
public Projection getProjection()
public HashSet<org.apache.hadoop.zebra.types.Partition.PartitionInfo.ColumnMappingEntry> getSplitMap(Schema.ColumnSchema fs)
public CGSchema generateDefaultCGSchema(String name, String compressor, String serializer, String owner, String group, short perm, int defaultCGIndex, String comparator) throws ParseException
ParseException
public void setSplit(Schema.ColumnSchema fs, Partition.SplitType st, Partition.SplitType cst, String name, String childName, boolean splitChild) throws ParseException
ParseException
public boolean setCGIndex(Schema.ColumnSchema fs, int ri, int fi, String name)
public boolean isCGNeeded(int i)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |