HCatLoader
insteadpublic class HCatLoader
extends LoadFunc
org.apache.pig.LoadFunc
to read data from HCatModifier and Type | Field and Description |
---|---|
static java.lang.String |
INNER_SIGNATURE
Deprecated.
|
static java.lang.String |
INNER_SIGNATURE_PREFIX
Deprecated.
|
protected static java.lang.String |
PRUNE_PROJECTION_INFO
Deprecated.
|
protected java.lang.String |
signature
Deprecated.
|
Constructor and Description |
---|
HCatLoader()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<OperatorSet> |
getFeatures()
Deprecated.
|
<any> |
getInputFormat()
Deprecated.
|
Tuple |
getNext()
Deprecated.
|
java.lang.String[] |
getPartitionKeys(java.lang.String location,
Job job)
Deprecated.
|
ResourceSchema |
getSchema(java.lang.String location,
Job job)
Deprecated.
|
protected static long |
getSizeInBytes(InputJobInfo inputJobInfo)
Deprecated.
A utility method to get the size of inputs.
|
ResourceStatistics |
getStatistics(java.lang.String location,
Job job)
Deprecated.
Get statistics about the data to be loaded.
|
void |
prepareToRead(RecordReader reader,
PigSplit arg1)
Deprecated.
|
RequiredFieldResponse |
pushProjection(RequiredFieldList requiredFieldsInfo)
Deprecated.
|
java.lang.String |
relativeToAbsolutePath(java.lang.String location,
Path curDir)
Deprecated.
|
void |
setLocation(java.lang.String location,
Job job)
Deprecated.
|
void |
setPartitionFilter(Expression partitionFilter)
Deprecated.
|
void |
setUDFContextSignature(java.lang.String signature)
Deprecated.
|
protected void |
storeInUDFContext(java.lang.String signature,
java.lang.String key,
java.lang.Object value)
Deprecated.
|
public static final java.lang.String INNER_SIGNATURE
public static final java.lang.String INNER_SIGNATURE_PREFIX
protected static final java.lang.String PRUNE_PROJECTION_INFO
protected java.lang.String signature
public <any> getInputFormat() throws java.io.IOException
java.io.IOException
public java.lang.String relativeToAbsolutePath(java.lang.String location, Path curDir) throws java.io.IOException
java.io.IOException
public void setLocation(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public java.lang.String[] getPartitionKeys(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public ResourceSchema getSchema(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public void setPartitionFilter(Expression partitionFilter) throws java.io.IOException
java.io.IOException
public ResourceStatistics getStatistics(java.lang.String location, Job job) throws java.io.IOException
java.io.IOException
public Tuple getNext() throws java.io.IOException
java.io.IOException
public void prepareToRead(RecordReader reader, PigSplit arg1) throws java.io.IOException
java.io.IOException
public java.util.List<OperatorSet> getFeatures()
public RequiredFieldResponse pushProjection(RequiredFieldList requiredFieldsInfo) throws FrontendException
FrontendException
public void setUDFContextSignature(java.lang.String signature)
protected void storeInUDFContext(java.lang.String signature, java.lang.String key, java.lang.Object value)
protected static long getSizeInBytes(InputJobInfo inputJobInfo) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation