Modifier and Type | Class and Description |
---|---|
class |
ConnectionFailureException
Class representing exceptions resulting from connection problems
between HCat client and server.
|
class |
ObjectNotFoundException
This exception is thrown when a Database, Table or Partition
specified in an HCatalog query is not found.
|
Modifier and Type | Method and Description |
---|---|
void |
HCatClientHMSImpl.addPartition(HCatAddPartitionDesc partInfo) |
abstract void |
HCatClient.addPartition(HCatAddPartitionDesc partInfo)
Adds the partition.
|
int |
HCatClientHMSImpl.addPartitions(List<HCatAddPartitionDesc> partInfoList) |
abstract int |
HCatClient.addPartitions(List<HCatAddPartitionDesc> partInfoList)
Adds a list of partitions.
|
int |
HCatClientHMSImpl.addPartitionSpec(HCatPartitionSpec partitionSpec) |
abstract int |
HCatClient.addPartitionSpec(HCatPartitionSpec partitionSpec)
Adds partitions using HCatPartitionSpec.
|
HCatCreateTableDesc |
HCatCreateTableDesc.Builder.build()
Builds the HCatCreateTableDesc.
|
HCatCreateDBDesc |
HCatCreateDBDesc.Builder.build()
Builds the create database descriptor.
|
HCatAddPartitionDesc |
HCatAddPartitionDesc.Builder.build()
Builds the HCatAddPartitionDesc.
|
void |
HCatClientHMSImpl.cancelDelegationToken(String tokenStrForm) |
abstract void |
HCatClient.cancelDelegationToken(String tokenStrForm)
Cancel delegation token.
|
void |
HCatClientHMSImpl.close() |
abstract void |
HCatClient.close()
Close the hcatalog client.
|
static HCatClient |
HCatClient.create(org.apache.hadoop.conf.Configuration conf)
Creates an instance of HCatClient.
|
static HCatAddPartitionDesc.Builder |
HCatAddPartitionDesc.create(HCatPartition partition)
Constructs a Builder instance, using an HCatPartition object.
|
static HCatAddPartitionDesc.Builder |
HCatAddPartitionDesc.create(String dbName,
String tableName,
String location,
Map<String,String> partSpec)
Deprecated.
|
void |
HCatClientHMSImpl.createDatabase(HCatCreateDBDesc dbInfo) |
abstract void |
HCatClient.createDatabase(HCatCreateDBDesc dbInfo)
Creates the database.
|
void |
HCatClientHMSImpl.createTable(HCatCreateTableDesc createTableDesc) |
abstract void |
HCatClient.createTable(HCatCreateTableDesc createTableDesc)
Creates the table.
|
void |
HCatClientHMSImpl.createTableLike(String dbName,
String existingTblName,
String newTableName,
boolean ifNotExists,
boolean isExternal,
String location) |
abstract void |
HCatClient.createTableLike(String dbName,
String existingTblName,
String newTableName,
boolean ifNotExists,
boolean isExternal,
String location)
Creates the table like an existing table.
|
HCatPartition |
HCatClientHMSImpl.deserializePartition(String hcatPartitionStringRep) |
abstract HCatPartition |
HCatClient.deserializePartition(String hcatPartitionStringRep)
Deserializer for an HCatPartition.
|
List<HCatPartition> |
HCatClientHMSImpl.deserializePartitions(List<String> hcatPartitionStringReps) |
abstract List<HCatPartition> |
HCatClient.deserializePartitions(List<String> hcatPartitionStringReps)
Deserializer for a list of HCatPartition strings.
|
HCatPartitionSpec |
HCatClientHMSImpl.deserializePartitionSpec(List<String> hcatPartitionSpecStrings) |
abstract HCatPartitionSpec |
HCatClient.deserializePartitionSpec(List<String> hcatPartitionSpecStrings)
Deserializer for HCatPartitionSpec.
|
HCatTable |
HCatClientHMSImpl.deserializeTable(String hcatTableStringRep) |
abstract HCatTable |
HCatClient.deserializeTable(String hcatTableStringRep)
Deserializer for HCatTable.
|
void |
HCatClientHMSImpl.dropDatabase(String dbName,
boolean ifExists,
HCatClient.DropDBMode mode) |
abstract void |
HCatClient.dropDatabase(String dbName,
boolean ifExists,
HCatClient.DropDBMode mode)
Drops a database.
|
void |
HCatClientHMSImpl.dropPartitions(String dbName,
String tableName,
Map<String,String> partitionSpec,
boolean ifExists) |
abstract void |
HCatClient.dropPartitions(String dbName,
String tableName,
Map<String,String> partitionSpec,
boolean ifExists)
Drops partition(s) that match the specified (and possibly partial) partition specification.
|
void |
HCatClientHMSImpl.dropPartitions(String dbName,
String tableName,
Map<String,String> partitionSpec,
boolean ifExists,
boolean deleteData) |
abstract void |
HCatClient.dropPartitions(String dbName,
String tableName,
Map<String,String> partitionSpec,
boolean ifExists,
boolean deleteData)
Drops partition(s) that match the specified (and possibly partial) partition specification.
|
void |
HCatClientHMSImpl.dropTable(String dbName,
String tableName,
boolean ifExists) |
abstract void |
HCatClient.dropTable(String dbName,
String tableName,
boolean ifExists)
Drop table.
|
long |
HCatClientHMSImpl.getCurrentNotificationEventId() |
abstract long |
HCatClient.getCurrentNotificationEventId()
Get the most recently used notification id.
|
HCatDatabase |
HCatClientHMSImpl.getDatabase(String dbName) |
abstract HCatDatabase |
HCatClient.getDatabase(String dbName)
Gets the database.
|
String |
HCatClientHMSImpl.getDelegationToken(String owner,
String renewerKerberosPrincipalName) |
abstract String |
HCatClient.getDelegationToken(String owner,
String renewerKerberosPrincipalName)
Gets the delegation token.
|
String |
HCatClientHMSImpl.getMessageBusTopicName(String dbName,
String tableName) |
abstract String |
HCatClient.getMessageBusTopicName(String dbName,
String tableName)
Retrieve Message-bus topic for a table.
|
List<HCatNotificationEvent> |
HCatClientHMSImpl.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
abstract List<HCatNotificationEvent> |
HCatClient.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter)
Get a list of notifications
|
HCatPartition |
HCatClientHMSImpl.getPartition(String dbName,
String tableName,
Map<String,String> partitionSpec) |
abstract HCatPartition |
HCatClient.getPartition(String dbName,
String tableName,
Map<String,String> partitionSpec)
Gets the partition.
|
List<HCatPartition> |
HCatClientHMSImpl.getPartitions(String dbName,
String tblName) |
abstract List<HCatPartition> |
HCatClient.getPartitions(String dbName,
String tblName)
Gets all the partitions.
|
List<HCatPartition> |
HCatClientHMSImpl.getPartitions(String dbName,
String tblName,
Map<String,String> partitionSpec) |
abstract List<HCatPartition> |
HCatClient.getPartitions(String dbName,
String tblName,
Map<String,String> partitionSpec)
Gets all the partitions that match the specified (and possibly partial) partition specification.
|
HCatPartitionSpec |
HCatClientHMSImpl.getPartitionSpecs(String dbName,
String tableName,
int maxPartitions) |
abstract HCatPartitionSpec |
HCatClient.getPartitionSpecs(String dbName,
String tableName,
int maxPartitions)
Gets partitions in terms of generic HCatPartitionSpec instances.
|
HCatPartitionSpec |
HCatClientHMSImpl.getPartitionSpecs(String dbName,
String tableName,
Map<String,String> partitionSelector,
int maxPartitions) |
abstract HCatPartitionSpec |
HCatClient.getPartitionSpecs(String dbName,
String tableName,
Map<String,String> partitionSelector,
int maxPartitions)
Gets partitions in terms of generic HCatPartitionSpec instances.
|
Iterator<ReplicationTask> |
HCatClientHMSImpl.getReplicationTasks(long lastEventId,
int maxEvents,
String dbName,
String tableName) |
abstract Iterator<ReplicationTask> |
HCatClient.getReplicationTasks(long lastEventId,
int maxEvents,
String dbName,
String tableName)
Get an iterator that iterates over a list of replication tasks needed to replicate all the
events that have taken place for a given db/table.
|
HCatTable |
HCatClientHMSImpl.getTable(String dbName,
String tableName) |
abstract HCatTable |
HCatClient.getTable(String dbName,
String tableName)
Gets the table.
|
boolean |
HCatClientHMSImpl.isPartitionMarkedForEvent(String dbName,
String tblName,
Map<String,String> partKVs,
PartitionEventType eventType) |
abstract boolean |
HCatClient.isPartitionMarkedForEvent(String dbName,
String tblName,
Map<String,String> partKVs,
PartitionEventType eventType)
Checks if a partition is marked for event.
|
List<String> |
HCatClientHMSImpl.listDatabaseNamesByPattern(String pattern) |
abstract List<String> |
HCatClient.listDatabaseNamesByPattern(String pattern)
Get all existing databases that match the given
pattern.
|
List<HCatPartition> |
HCatClientHMSImpl.listPartitionsByFilter(String dbName,
String tblName,
String filter) |
abstract List<HCatPartition> |
HCatClient.listPartitionsByFilter(String dbName,
String tblName,
String filter)
List partitions by filter.
|
HCatPartitionSpec |
HCatClientHMSImpl.listPartitionSpecsByFilter(String dbName,
String tblName,
String filter,
int maxPartitions) |
abstract HCatPartitionSpec |
HCatClient.listPartitionSpecsByFilter(String dbName,
String tblName,
String filter,
int maxPartitions)
List partitions by filter, but as HCatPartitionSpecs.
|
List<String> |
HCatClientHMSImpl.listTableNamesByPattern(String dbName,
String tablePattern) |
abstract List<String> |
HCatClient.listTableNamesByPattern(String dbName,
String tablePattern)
Returns all existing tables from the specified database which match the given
pattern.
|
void |
HCatClientHMSImpl.markPartitionForEvent(String dbName,
String tblName,
Map<String,String> partKVs,
PartitionEventType eventType) |
abstract void |
HCatClient.markPartitionForEvent(String dbName,
String tblName,
Map<String,String> partKVs,
PartitionEventType eventType)
Mark partition for event.
|
HCatPartition |
HCatPartitionSpec.HCatPartitionIterator.next() |
void |
HCatClientHMSImpl.renameTable(String dbName,
String oldName,
String newName) |
abstract void |
HCatClient.renameTable(String dbName,
String oldName,
String newName)
Renames a table.
|
long |
HCatClientHMSImpl.renewDelegationToken(String tokenStrForm) |
abstract long |
HCatClient.renewDelegationToken(String tokenStrForm)
Renew delegation token.
|
HCatTable |
HCatTable.resolve(HCatTable rhs,
EnumSet<HCatTable.TableAttribute> attributes)
Method to "adopt" the specified attributes from rhs into this HCatTable object.
|
String |
HCatClientHMSImpl.serializePartition(HCatPartition hcatPartition) |
abstract String |
HCatClient.serializePartition(HCatPartition hcatPartition)
Serializer for HCatPartition.
|
List<String> |
HCatClientHMSImpl.serializePartitions(List<HCatPartition> hcatPartitions) |
abstract List<String> |
HCatClient.serializePartitions(List<HCatPartition> hcatPartitions)
Serializer for a list of HCatPartition.
|
List<String> |
HCatClientHMSImpl.serializePartitionSpec(HCatPartitionSpec partitionSpec) |
abstract List<String> |
HCatClient.serializePartitionSpec(HCatPartitionSpec partitionSpec)
Serializer for HCatPartitionSpec.
|
String |
HCatClientHMSImpl.serializeTable(HCatTable hcatTable) |
abstract String |
HCatClient.serializeTable(HCatTable hcatTable)
Serializer for HCatTable.
|
HCatPartition |
HCatPartition.setPartitionKeyValues(Map<String,String> partitionKeyValues)
Setter for partition key-values.
|
void |
HCatPartitionSpec.setRootLocation(String location)
Setter for the "root" location of the HCatPartitionSpec.
|
int |
HCatPartitionSpec.size()
Getter for the number of HCatPartitions represented by this HCatPartitionSpec instance.
|
HCatTable |
HCatTable.storageHandler(String storageHandler)
Setter for StorageHandler class.
|
HCatCreateTableDesc.Builder |
HCatCreateTableDesc.Builder.storageHandler(String storageHandler)
Deprecated.
|
void |
HCatClientHMSImpl.updateTableSchema(String dbName,
String tableName,
HCatTable newTableDefinition) |
abstract void |
HCatClient.updateTableSchema(String dbName,
String tableName,
HCatTable newTableDefinition)
Updates the Table's whole schema (including column schema, I/O Formats, SerDe definitions, etc.)
|
void |
HCatClientHMSImpl.updateTableSchema(String dbName,
String tableName,
List<HCatFieldSchema> columnSchema) |
abstract void |
HCatClient.updateTableSchema(String dbName,
String tableName,
List<HCatFieldSchema> columnSchema)
Updates the Table's column schema to the specified definition.
|
Constructor and Description |
---|
HCatPartition(HCatPartition rhs,
Map<String,String> partitionKeyValues,
String location) |
HCatPartition(HCatTable hcatTable,
Map<String,String> partitionKeyValues,
String location) |
HCatPartitionSpec(HCatTable hcatTable,
PartitionSpecProxy partitionSpecProxy) |
Constructor and Description |
---|
HCatReplicationTaskIterator(HCatClient hcatClient,
long eventFrom,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
HCatReplicationTaskIterator(HCatClient hcatClient,
long eventFrom,
int maxEvents,
String dbName,
String tableName) |
Modifier and Type | Method and Description |
---|---|
static HCatSchema |
HCatUtil.extractSchema(Partition partition) |
static HCatSchema |
HCatUtil.extractSchema(Table table) |
static List<HCatFieldSchema> |
HCatUtil.getHCatFieldSchemaList(FieldSchema... fields) |
static List<HCatFieldSchema> |
HCatUtil.getHCatFieldSchemaList(List<FieldSchema> fields) |
Modifier and Type | Method and Description |
---|---|
void |
LazyHCatRecord.copy(HCatRecord r) |
abstract void |
HCatRecord.copy(HCatRecord r) |
void |
DefaultHCatRecord.copy(HCatRecord r) |
Object |
LazyHCatRecord.get(String fieldName,
HCatSchema recordSchema) |
abstract Object |
HCatRecord.get(String fieldName,
HCatSchema recordSchema) |
Object |
DefaultHCatRecord.get(String fieldName,
HCatSchema recordSchema) |
protected Object |
HCatRecord.get(String fieldName,
HCatSchema recordSchema,
Class clazz) |
Boolean |
HCatRecord.getBoolean(String fieldName,
HCatSchema recordSchema) |
Byte |
HCatRecord.getByte(String fieldName,
HCatSchema recordSchema) |
byte[] |
HCatRecord.getByteArray(String fieldName,
HCatSchema recordSchema) |
HiveChar |
HCatRecord.getChar(String fieldName,
HCatSchema recordSchema) |
Date |
HCatRecord.getDate(String fieldName,
HCatSchema recordSchema) |
HiveDecimal |
HCatRecord.getDecimal(String fieldName,
HCatSchema recordSchema) |
Double |
HCatRecord.getDouble(String fieldName,
HCatSchema recordSchema) |
Float |
HCatRecord.getFloat(String fieldName,
HCatSchema recordSchema) |
Integer |
HCatRecord.getInteger(String fieldName,
HCatSchema recordSchema) |
List<?> |
HCatRecord.getList(String fieldName,
HCatSchema recordSchema) |
Long |
HCatRecord.getLong(String fieldName,
HCatSchema recordSchema) |
Map<?,?> |
HCatRecord.getMap(String fieldName,
HCatSchema recordSchema) |
Short |
HCatRecord.getShort(String fieldName,
HCatSchema recordSchema) |
String |
HCatRecord.getString(String fieldName,
HCatSchema recordSchema) |
List<? extends Object> |
HCatRecord.getStruct(String fieldName,
HCatSchema recordSchema) |
Timestamp |
HCatRecord.getTimestamp(String fieldName,
HCatSchema recordSchema) |
HiveVarchar |
HCatRecord.getVarchar(String fieldName,
HCatSchema recordSchema) |
HCatRecord |
LazyHCatRecord.getWritable()
Convert this LazyHCatRecord to a DefaultHCatRecord.
|
void |
LazyHCatRecord.remove(int idx) |
abstract void |
HCatRecord.remove(int idx) |
void |
DefaultHCatRecord.remove(int idx) |
void |
LazyHCatRecord.set(String fieldName,
HCatSchema recordSchema,
Object value) |
abstract void |
HCatRecord.set(String fieldName,
HCatSchema recordSchema,
Object value) |
void |
DefaultHCatRecord.set(String fieldName,
HCatSchema recordSchema,
Object value) |
void |
HCatRecord.setBoolean(String fieldName,
HCatSchema recordSchema,
Boolean value) |
void |
HCatRecord.setByte(String fieldName,
HCatSchema recordSchema,
Byte value) |
void |
HCatRecord.setByteArray(String fieldName,
HCatSchema recordSchema,
byte[] value) |
void |
HCatRecord.setChar(String fieldName,
HCatSchema recordSchema,
HiveChar value) |
void |
HCatRecord.setDate(String fieldName,
HCatSchema recordSchema,
Date value)
Note that the proper way to construct a java.sql.Date for use with this object is
Date.valueOf("1999-12-31").
|
void |
HCatRecord.setDecimal(String fieldName,
HCatSchema recordSchema,
HiveDecimal value) |
void |
HCatRecord.setDouble(String fieldName,
HCatSchema recordSchema,
Double value) |
void |
HCatRecord.setFloat(String fieldName,
HCatSchema recordSchema,
Float value) |
void |
HCatRecord.setInteger(String fieldName,
HCatSchema recordSchema,
Integer value) |
void |
HCatRecord.setList(String fieldName,
HCatSchema recordSchema,
List<?> value) |
void |
HCatRecord.setLong(String fieldName,
HCatSchema recordSchema,
Long value) |
void |
HCatRecord.setMap(String fieldName,
HCatSchema recordSchema,
Map<?,?> value) |
void |
HCatRecord.setShort(String fieldName,
HCatSchema recordSchema,
Short value) |
void |
HCatRecord.setString(String fieldName,
HCatSchema recordSchema,
String value) |
void |
HCatRecord.setStruct(String fieldName,
HCatSchema recordSchema,
List<? extends Object> value) |
void |
HCatRecord.setTimestamp(String fieldName,
HCatSchema recordSchema,
Timestamp value) |
void |
HCatRecord.setVarchar(String fieldName,
HCatSchema recordSchema,
HiveVarchar value) |
Modifier and Type | Method and Description |
---|---|
HCatSchemaUtils.CollectionBuilder |
HCatSchemaUtils.CollectionBuilder.addField(FieldSchema fieldSchema) |
void |
HCatSchema.append(HCatFieldSchema hfs) |
abstract HCatSchema |
HCatSchemaUtils.HCatSchemaBuilder.build() |
HCatSchema |
HCatSchemaUtils.CollectionBuilder.build() |
HCatSchema |
HCatSchemaUtils.MapBuilder.build() |
static HCatFieldSchema |
HCatFieldSchema.createMapTypeFieldSchema(String fieldName,
PrimitiveTypeInfo mapKeyType,
HCatSchema mapValueSchema,
String comment) |
HCatFieldSchema |
HCatSchema.get(String fieldName) |
HCatSchema |
HCatFieldSchema.getArrayElementSchema() |
static HCatFieldSchema |
HCatSchemaUtils.getHCatFieldSchema(FieldSchema fs)
Convert a HCatFieldSchema to a FieldSchema
|
static HCatSchema |
HCatSchemaUtils.getHCatSchema(List<? extends FieldSchema> fslist) |
static HCatSchema |
HCatSchemaUtils.getHCatSchema(Schema schema) |
static HCatSchema |
HCatSchemaUtils.getHCatSchema(String schemaString) |
static HCatSchema |
HCatSchemaUtils.getHCatSchema(TypeInfo typeInfo) |
static HCatSchema |
HCatSchemaUtils.getHCatSchemaFromTypeString(String typeString) |
HCatFieldSchema.Type |
HCatFieldSchema.getMapKeyType()
Deprecated.
as of 0.13, slated for removal with 0.15
use
HCatFieldSchema.getMapKeyTypeInfo() instead |
PrimitiveTypeInfo |
HCatFieldSchema.getMapKeyTypeInfo() |
HCatSchema |
HCatFieldSchema.getMapValueSchema() |
HCatSchema |
HCatFieldSchema.getStructSubSchema() |
void |
HCatSchema.remove(HCatFieldSchema hcatFieldSchema) |
Constructor and Description |
---|
HCatFieldSchema(String fieldName,
HCatFieldSchema.Type type,
HCatFieldSchema.Type mapKeyType,
HCatSchema mapValueSchema,
String comment)
Deprecated.
as of 0.13, slated for removal with 0.15
use
HCatFieldSchema.createMapTypeFieldSchema(String, org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo, HCatSchema, String) |
HCatFieldSchema(String fieldName,
HCatFieldSchema.Type type,
HCatSchema subSchema,
String comment)
Constructor for constructing a ARRAY type or STRUCT type HCatFieldSchema, passing type and subschema
|
HCatFieldSchema(String fieldName,
HCatFieldSchema.Type type,
String comment)
Deprecated.
as of 0.13, slated for removal with 0.15
use
HCatFieldSchema.HCatFieldSchema(String, org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo, String) |
HCatFieldSchema(String fieldName,
PrimitiveTypeInfo typeInfo,
String comment) |
Modifier and Type | Method and Description |
---|---|
abstract void |
HCatWriter.abort(WriterContext context)
This method should be called at master node.
|
abstract void |
HCatWriter.commit(WriterContext context)
This method should be called at master node.
|
abstract ReaderContext |
HCatReader.prepareRead()
This should be called at master node to obtain
ReaderContext which
then should be serialized and sent to slave nodes. |
abstract WriterContext |
HCatWriter.prepareWrite()
External system should invoke this method exactly once from a master node.
|
abstract Iterator<HCatRecord> |
HCatReader.read()
This should be called at slave nodes to read
HCatRecord s |
abstract void |
HCatWriter.write(Iterator<HCatRecord> recordItr)
This method should be used at slave needs to perform writes.
|
Modifier and Type | Method and Description |
---|---|
void |
HCatOutputFormatWriter.abort(WriterContext context) |
void |
HCatOutputFormatWriter.commit(WriterContext context) |
ReaderContext |
HCatInputFormatReader.prepareRead() |
WriterContext |
HCatOutputFormatWriter.prepareWrite() |
Iterator<HCatRecord> |
HCatInputFormatReader.read() |
void |
HCatOutputFormatWriter.write(Iterator<HCatRecord> recordItr) |
Modifier and Type | Method and Description |
---|---|
protected static void |
HCatBaseOutputFormat.setPartDetails(OutputJobInfo jobInfo,
HCatSchema schema,
Map<String,String> partMap) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.