| Package | Description |
|---|---|
| org.apache.hadoop.zebra.io |
Physical I/O management of Hadoop Zebra Tables.
|
| org.apache.hadoop.zebra.mapred |
Providing
InputFormat and
OutputFormat adaptor classes for Hadoop
Zebra Table. |
| org.apache.hadoop.zebra.mapreduce |
Providing
InputFormat and
OutputFormat adaptor classes for Hadoop
Zebra Table. |
| org.apache.hadoop.zebra.schema |
Zebra Schema
|
| org.apache.hadoop.zebra.types |
Data types being shared between the io and mapred packages.
|
| Modifier and Type | Method and Description |
|---|---|
Schema |
TableScanner.getSchema()
Get the projection's schema
|
Schema |
TableInserter.getSchema()
Get the schema of the underlying table we are writing to.
|
Schema |
BasicTable.Reader.getSchema()
Get the schema of the table.
|
Schema |
BasicTable.Writer.getSchema()
Get the schema of the table.
|
static Schema |
BasicTable.Reader.getSchema(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf)
Get the BasicTable schema without loading the full table index.
|
| Modifier and Type | Method and Description |
|---|---|
static Schema |
TableInputFormat.getSchema(org.apache.hadoop.mapred.JobConf conf)
Deprecated.
Get the schema of a table expr
|
static Schema |
BasicTableOutputFormat.getSchema(org.apache.hadoop.mapred.JobConf conf)
Deprecated.
Get the table schema in JobConf.
|
| Modifier and Type | Method and Description |
|---|---|
static Schema |
TableInputFormat.getSchema(org.apache.hadoop.mapreduce.JobContext jobContext)
Get the schema of a table expr
|
static Schema |
BasicTableOutputFormat.getSchema(org.apache.hadoop.mapreduce.JobContext jobContext)
Get the table schema in JobContext.
|
| Modifier and Type | Method and Description |
|---|---|
Schema |
Schema.getProjectionSchema(String[] projcols,
HashMap<Schema.ColumnSchema,HashSet<String>> keysmap)
Get a projection's schema
|
Schema |
Schema.ColumnSchema.getSchema() |
static Schema |
Schema.parse(String schema)
Parse a schema string and create a schema object.
|
| Modifier and Type | Method and Description |
|---|---|
int |
Schema.compareTo(Schema other) |
void |
Schema.unionSchema(Schema other)
union compatible schemas.
|
| Constructor and Description |
|---|
Schema.ColumnSchema(String a,
Schema s)
construct a Column schema for a RECORD column type
|
Schema.ColumnSchema(String a,
Schema s,
ColumnType t)
construct a column schema for a complex column type
|
| Modifier and Type | Method and Description |
|---|---|
Schema |
Projection.getProjectionSchema() |
Schema |
TypesUtils.TupleReader.getSchema() |
Schema |
Projection.getSchema()
accessor to the projected schema including invalid columns
|
Schema |
Partition.getSchema()
returns table schema
|
Schema |
CGSchema.getSchema() |
static Schema |
Projection.toSchema(String projection)
Get schema from a projection string: all map keys are lost
|
| Modifier and Type | Method and Description |
|---|---|
static void |
TypesUtils.checkCompatible(Tuple tuple,
Schema schema)
Check whether the input row object is compatible with the expected schema
|
static void |
TypesUtils.checkNumberColumnCompatible(Tuple tuple,
Schema schema)
Check whether the input row object is compatible with the expected schema
on number of Columns;
|
static DataBag |
TypesUtils.createBag(Schema schema) |
static Tuple |
TypesUtils.createTuple(Schema schema)
Create a tuple based on a schema
|
static SortInfo |
SortInfo.parse(String sortStr,
Schema schema,
String comparator)
Build a SortInfo object from sort column names, schema, and comparator
|
| Constructor and Description |
|---|
CGSchema(Schema schema,
boolean sorted,
String comparator) |
CGSchema(Schema schema,
boolean sorted,
String comparator,
String name,
String serializer,
String compressor,
String owner,
String group,
short perm) |
Partition.PartitionInfo(Schema schema) |
Partition(Schema schema,
Projection projection,
String storage,
String comparator) |
Projection(Schema s)
ctor for full projection
|
Projection(Schema s,
String projection)
ctor for partial projection
|
TypesUtils.TupleReader(Schema physical,
Projection projection)
Constructor - create a TupleReader than can parse the serialized Tuple
with the specified physical schema, and produce the Tuples based on the
projection.
|
TypesUtils.TupleWriter(Schema physical)
The constructor
|
Copyright © 2007-2012 The Apache Software Foundation