org.apache.hive.hcatalog.messaging.json

Class JSONMessageFactory

java.lang.Object

org.apache.hive.hcatalog.messaging.MessageFactory

org.apache.hive.hcatalog.messaging.json.JSONMessageFactory

public class JSONMessageFactory
extends MessageFactory

The JSON implementation of the MessageFactory. Constructs JSON implementations of each message-type.

Field Summary

Fields inherited from class org.apache.hive.hcatalog.messaging.MessageFactory

HCAT_SERVER_URL, HCAT_SERVICE_PRINCIPAL, hiveConf

Constructor Summary

Constructors

Constructor and Description
JSONMessageFactory()

Method Summary

Methods

Modifier and Type	Method and Description
AddPartitionMessage	buildAddPartitionMessage(Table table, Iterator<Partition> partitionsIterator) Factory method for AddPartitionMessage.
AlterPartitionMessage	buildAlterPartitionMessage(Table table, Partition before, Partition after) Factory method for building AlterPartitionMessage
AlterTableMessage	buildAlterTableMessage(Table before, Table after) Factory method for AlterTableMessage.
CreateDatabaseMessage	buildCreateDatabaseMessage(Database db) Factory method for CreateDatabaseMessage.
CreateTableMessage	buildCreateTableMessage(Table table) Factory method for CreateTableMessage.
DropDatabaseMessage	buildDropDatabaseMessage(Database db) Factory method for DropDatabaseMessage.
DropPartitionMessage	buildDropPartitionMessage(Table table, Iterator<Partition> partitions) Factory method for DropPartitionMessage.
DropTableMessage	buildDropTableMessage(Table table) Factory method for DropTableMessage.
InsertMessage	buildInsertMessage(String db, String table, Map<String,String> partKeyVals, List<String> files) Factory method for building insert message
MessageDeserializer	getDeserializer()
String	getMessageFormat() Getter for message-format.
String	getVersion() Getter for version-string, corresponding to all constructed messages.

Methods inherited from class org.apache.hive.hcatalog.messaging.MessageFactory

getDeserializer, getInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JSONMessageFactory

public JSONMessageFactory()

Method Detail

getDeserializer

public MessageDeserializer getDeserializer()

Specified by:

getDeserializer in class MessageFactory

getVersion

public String getVersion()

Description copied from class: MessageFactory

Getter for version-string, corresponding to all constructed messages.

Specified by:

getVersion in class MessageFactory

getMessageFormat

public String getMessageFormat()

Description copied from class: MessageFactory

Getter for message-format.

Specified by:

getMessageFormat in class MessageFactory

buildCreateDatabaseMessage

public CreateDatabaseMessage buildCreateDatabaseMessage(Database db)

Description copied from class: MessageFactory

Factory method for CreateDatabaseMessage.

Specified by:

buildCreateDatabaseMessage in class MessageFactory

Parameters:

db - The Database being added.

Returns:

CreateDatabaseMessage instance.

buildDropDatabaseMessage

public DropDatabaseMessage buildDropDatabaseMessage(Database db)

Description copied from class: MessageFactory

Factory method for DropDatabaseMessage.

Specified by:

buildDropDatabaseMessage in class MessageFactory

Parameters:

db - The Database being dropped.

Returns:

DropDatabaseMessage instance.

buildCreateTableMessage

public CreateTableMessage buildCreateTableMessage(Table table)

Description copied from class: MessageFactory

Factory method for CreateTableMessage.

Specified by:

buildCreateTableMessage in class MessageFactory

Parameters:

table - The Table being created.

Returns:

CreateTableMessage instance.

buildAlterTableMessage

public AlterTableMessage buildAlterTableMessage(Table before,
                                       Table after)

Description copied from class: MessageFactory

Factory method for AlterTableMessage. Unlike most of these calls, this one can return null, which means no message should be sent. This is because there are many flavors of alter table (add column, add partition, etc.). Some are covered elsewhere (like add partition) and some are not yet supported.

Specified by:

buildAlterTableMessage in class MessageFactory

Parameters:

before - The table before the alter

after - The table after the alter

Returns:

buildDropTableMessage

public DropTableMessage buildDropTableMessage(Table table)

Description copied from class: MessageFactory

Factory method for DropTableMessage.

Specified by:

buildDropTableMessage in class MessageFactory

Parameters:

table - The Table being dropped.

Returns:

DropTableMessage instance.

buildAddPartitionMessage

public AddPartitionMessage buildAddPartitionMessage(Table table,
                                           Iterator<Partition> partitionsIterator)

Description copied from class: MessageFactory

Factory method for AddPartitionMessage.

Specified by:

buildAddPartitionMessage in class MessageFactory

Parameters:

table - The Table to which the partitions are added.

partitionsIterator - The iterator to set of Partitions being added.

Returns:

AddPartitionMessage instance.

buildAlterPartitionMessage

public AlterPartitionMessage buildAlterPartitionMessage(Table table,
                                               Partition before,
                                               Partition after)

Description copied from class: MessageFactory

Factory method for building AlterPartitionMessage

Specified by:

buildAlterPartitionMessage in class MessageFactory

Parameters:

table - The table in which the partition is being altered

before - The partition before it was altered

after - The partition after it was altered

Returns:

a new AlterPartitionMessage

buildDropPartitionMessage

public DropPartitionMessage buildDropPartitionMessage(Table table,
                                             Iterator<Partition> partitions)

Description copied from class: MessageFactory

Factory method for DropPartitionMessage.

Specified by:

buildDropPartitionMessage in class MessageFactory

Parameters:

table - The Table from which the partition is dropped.

partitions - The set of partitions being dropped.

Returns:

DropPartitionMessage instance.

buildInsertMessage

public InsertMessage buildInsertMessage(String db,
                               String table,
                               Map<String,String> partKeyVals,
                               List<String> files)

Description copied from class: MessageFactory

Factory method for building insert message

Specified by:

buildInsertMessage in class MessageFactory

Parameters:

db - Name of the database the insert occurred in

table - Name of the table the insert occurred in

partKeyVals - Partition values for the partition that the insert occurred in, may be null if the insert was done into a non-partitioned table

files - List of files created as a result of the insert, may be null.

Returns:

instance of InsertMessage