public abstract class FileMetadataHandler extends Object
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
FileMetadataHandler() |
Modifier and Type | Method and Description |
---|---|
void |
cacheFileMetadata(long fileId,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path)
Caches the file metadata for a particular file.
|
void |
configure(org.apache.hadoop.conf.Configuration conf,
PartitionExpressionProxy expressionProxy,
MetadataStore store)
Configures the handler.
|
ByteBuffer[] |
createAddedCols() |
ByteBuffer[][] |
createAddedColVals(List<ByteBuffer> metadata) |
protected PartitionExpressionProxy |
getExpressionProxy() |
protected FileFormatProxy |
getFileFormatProxy() |
abstract void |
getFileMetadataByExpr(List<Long> fileIds,
byte[] expr,
ByteBuffer[] metadatas,
ByteBuffer[] results,
boolean[] eliminated)
Same as RawStore.getFileMetadataByExpr.
|
protected MetadataStore |
getStore() |
protected abstract FileMetadataExprType |
getType() |
public abstract void getFileMetadataByExpr(List<Long> fileIds, byte[] expr, ByteBuffer[] metadatas, ByteBuffer[] results, boolean[] eliminated) throws IOException
IOException
protected abstract FileMetadataExprType getType()
protected PartitionExpressionProxy getExpressionProxy()
protected FileFormatProxy getFileFormatProxy()
protected MetadataStore getStore()
public void configure(org.apache.hadoop.conf.Configuration conf, PartitionExpressionProxy expressionProxy, MetadataStore store)
conf
- Config.expressionProxy
- Expression proxy to access ql stuff.store
- Storage interface to manipulate the metadata.public void cacheFileMetadata(long fileId, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException, InterruptedException
fileId
- File id.fs
- The filesystem of the file.path
- Path to the file.IOException
InterruptedException
public ByteBuffer[] createAddedCols()
public ByteBuffer[][] createAddedColVals(List<ByteBuffer> metadata)
Copyright © 2016 The Apache Software Foundation. All rights reserved.