HCatStorer
insteadpublic class HCatStorer
extends StoreFunc
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
COMPUTED_OUTPUT_SCHEMA
Deprecated.
|
protected HCatSchema |
computedSchema
Deprecated.
|
static java.lang.String |
INNER_SIGNATURE
Deprecated.
|
static java.lang.String |
INNER_SIGNATURE_PREFIX
Deprecated.
|
protected java.util.List<java.lang.String> |
partitionKeys
Deprecated.
|
protected java.util.Map<java.lang.String,java.lang.String> |
partitions
Deprecated.
|
protected static java.lang.String |
PIG_SCHEMA
Deprecated.
|
protected Schema |
pigSchema
Deprecated.
|
protected java.lang.String |
sign
Deprecated.
|
Constructor and Description |
---|
HCatStorer()
Deprecated.
|
HCatStorer(java.lang.String partSpecs)
Deprecated.
|
HCatStorer(java.lang.String partSpecs,
java.lang.String schema)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
checkSchema(ResourceSchema resourceSchema)
Deprecated.
|
void |
cleanupOnFailure(java.lang.String location,
Job job)
Deprecated.
|
protected HCatSchema |
convertPigSchemaToHCatSchema(Schema pigSchema,
HCatSchema tableSchema)
Deprecated.
Constructs HCatSchema from pigSchema.
|
protected void |
doSchemaValidations(Schema pigSchema,
HCatSchema tblSchema)
Deprecated.
|
OutputFormat |
getOutputFormat()
Deprecated.
|
void |
prepareToWrite(RecordWriter writer)
Deprecated.
|
void |
putNext(Tuple tuple)
Deprecated.
|
java.lang.String |
relToAbsPathForStoreLocation(java.lang.String location,
Path curDir)
Deprecated.
|
static boolean |
removeTupleFromBag(HCatFieldSchema hcatFieldSchema,
FieldSchema bagFieldSchema)
Deprecated.
|
void |
setStoreFuncUDFContextSignature(java.lang.String signature)
Deprecated.
|
void |
setStoreLocation(java.lang.String location,
Job job)
Deprecated.
|
void |
storeSchema(ResourceSchema schema,
java.lang.String arg1,
Job job)
Deprecated.
|
void |
storeStatistics(ResourceStatistics stats,
java.lang.String arg1,
Job job)
Deprecated.
|
public static final java.lang.String INNER_SIGNATURE
public static final java.lang.String INNER_SIGNATURE_PREFIX
protected static final java.lang.String COMPUTED_OUTPUT_SCHEMA
protected final java.util.List<java.lang.String> partitionKeys
protected final java.util.Map<java.lang.String,java.lang.String> partitions
protected Schema pigSchema
protected HCatSchema computedSchema
protected static final java.lang.String PIG_SCHEMA
protected java.lang.String sign
public HCatStorer(java.lang.String partSpecs, java.lang.String schema) throws java.lang.Exception
java.lang.Exception
public HCatStorer(java.lang.String partSpecs) throws java.lang.Exception
java.lang.Exception
public HCatStorer() throws java.lang.Exception
java.lang.Exception
public OutputFormat getOutputFormat() throws java.io.IOException
java.io.IOException
public void setStoreLocation(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public void storeSchema(ResourceSchema schema, java.lang.String arg1, Job job) throws java.io.IOException
java.io.IOException
public void cleanupOnFailure(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public void checkSchema(ResourceSchema resourceSchema) throws java.io.IOException
java.io.IOException
protected HCatSchema convertPigSchemaToHCatSchema(Schema pigSchema, HCatSchema tableSchema) throws FrontendException
FrontendException
public static boolean removeTupleFromBag(HCatFieldSchema hcatFieldSchema, FieldSchema bagFieldSchema) throws HCatException
HCatException
public void prepareToWrite(RecordWriter writer) throws java.io.IOException
java.io.IOException
public void putNext(Tuple tuple) throws java.io.IOException
java.io.IOException
public java.lang.String relToAbsPathForStoreLocation(java.lang.String location, Path curDir) throws java.io.IOException
java.io.IOException
public void setStoreFuncUDFContextSignature(java.lang.String signature)
protected void doSchemaValidations(Schema pigSchema, HCatSchema tblSchema) throws FrontendException, HCatException
FrontendException
HCatException
public void storeStatistics(ResourceStatistics stats, java.lang.String arg1, Job job) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation