org.apache.hive.hcatalog.messaging.json

Class JSONMessageDeserializer

java.lang.Object

org.apache.hive.hcatalog.messaging.MessageDeserializer

org.apache.hive.hcatalog.messaging.json.JSONMessageDeserializer

public class JSONMessageDeserializer
extends MessageDeserializer

MessageDeserializer implementation, for deserializing from JSON strings.

Constructor Summary

Constructors

Constructor and Description
JSONMessageDeserializer()

Method Summary

Methods

Modifier and Type	Method and Description
AddPartitionMessage	getAddPartitionMessage(String messageBody) Method to de-serialize AddPartitionMessage instance.
AlterPartitionMessage	getAlterPartitionMessage(String messageBody) Method to deserialize AlterPartitionMessage
AlterTableMessage	getAlterTableMessage(String messageBody) Method to de-serialize AlterTableMessge
CreateDatabaseMessage	getCreateDatabaseMessage(String messageBody) Method to de-serialize CreateDatabaseMessage instance.
CreateTableMessage	getCreateTableMessage(String messageBody) Method to de-serialize CreateTableMessage instance.
DropDatabaseMessage	getDropDatabaseMessage(String messageBody) Method to de-serialize DropDatabaseMessage instance.
DropPartitionMessage	getDropPartitionMessage(String messageBody) Method to de-serialize DropPartitionMessage instance.
DropTableMessage	getDropTableMessage(String messageBody) Method to de-serialize DropTableMessage instance.
InsertMessage	getInsertMessage(String messageBody) Method to deserialize InsertMessage

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

getHCatEventMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

JSONMessageDeserializer

public JSONMessageDeserializer()

Method Detail

getCreateDatabaseMessage

public CreateDatabaseMessage getCreateDatabaseMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize CreateDatabaseMessage instance.

Specified by:

getCreateDatabaseMessage in class MessageDeserializer

getDropDatabaseMessage

public DropDatabaseMessage getDropDatabaseMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize DropDatabaseMessage instance.

Specified by:

getDropDatabaseMessage in class MessageDeserializer

getCreateTableMessage

public CreateTableMessage getCreateTableMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize CreateTableMessage instance.

Specified by:

getCreateTableMessage in class MessageDeserializer

getAlterTableMessage

public AlterTableMessage getAlterTableMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AlterTableMessge

Specified by:

getAlterTableMessage in class MessageDeserializer

Parameters:

messageBody - string message

Returns:

object message

getDropTableMessage

public DropTableMessage getDropTableMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize DropTableMessage instance.

Specified by:

getDropTableMessage in class MessageDeserializer

getAddPartitionMessage

public AddPartitionMessage getAddPartitionMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AddPartitionMessage instance.

Specified by:

getAddPartitionMessage in class MessageDeserializer

getAlterPartitionMessage

public AlterPartitionMessage getAlterPartitionMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to deserialize AlterPartitionMessage

Specified by:

getAlterPartitionMessage in class MessageDeserializer

Parameters:

messageBody - the message in serialized form

Returns:

message in object form

getDropPartitionMessage

public DropPartitionMessage getDropPartitionMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize DropPartitionMessage instance.

Specified by:

getDropPartitionMessage in class MessageDeserializer

getInsertMessage

public InsertMessage getInsertMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to deserialize InsertMessage

Specified by:

getInsertMessage in class MessageDeserializer

Parameters:

messageBody - the message in serialized form

Returns:

message in object form