org.apache.hadoop.hive.metastore.messaging.json

Class JSONMessageDeserializer

java.lang.Object

org.apache.hadoop.hive.metastore.messaging.MessageDeserializer

org.apache.hadoop.hive.metastore.messaging.json.JSONMessageDeserializer

public class JSONMessageDeserializer
extends MessageDeserializer

MessageDeserializer implementation, for deserializing from JSON strings.

Constructor Summary

Constructors

Constructor and Description
JSONMessageDeserializer()

Method Summary

Modifier and Type	Method and Description
AbortTxnMessage	getAbortTxnMessage(String messageBody) Method to de-serialize AbortTxnMessage instance.
AddForeignKeyMessage	getAddForeignKeyMessage(String messageBody) Method to de-serialize AddForeignKeyMessage instance.
AddNotNullConstraintMessage	getAddNotNullConstraintMessage(String messageBody) Method to de-serialize AddNotNullConstraintMessage instance.
AddPartitionMessage	getAddPartitionMessage(String messageBody) Method to de-serialize AddPartitionMessage instance.
AddPrimaryKeyMessage	getAddPrimaryKeyMessage(String messageBody) Method to de-serialize AddPrimaryKeyMessage instance.
AddUniqueConstraintMessage	getAddUniqueConstraintMessage(String messageBody) Method to de-serialize AddUniqueConstraintMessage instance.
AllocWriteIdMessage	getAllocWriteIdMessage(String messageBody)
AlterDatabaseMessage	getAlterDatabaseMessage(String messageBody) Method to de-serialize AlterDatabaseMessage instance.
AlterPartitionMessage	getAlterPartitionMessage(String messageBody) Method to deserialize AlterPartitionMessage
AlterTableMessage	getAlterTableMessage(String messageBody) Method to de-serialize AlterTableMessge
CommitTxnMessage	getCommitTxnMessage(String messageBody) Method to de-serialize CommitTxnMessage instance.
CreateDatabaseMessage	getCreateDatabaseMessage(String messageBody) Method to de-serialize CreateDatabaseMessage instance.
CreateFunctionMessage	getCreateFunctionMessage(String messageBody) Method to de-serialize CreateFunctionMessage instance.
CreateTableMessage	getCreateTableMessage(String messageBody) Method to de-serialize CreateTableMessage instance.
DropConstraintMessage	getDropConstraintMessage(String messageBody) Method to de-serialize DropConstraintMessage instance.
DropDatabaseMessage	getDropDatabaseMessage(String messageBody) Method to de-serialize DropDatabaseMessage instance.
DropFunctionMessage	getDropFunctionMessage(String messageBody) Method to de-serialize DropFunctionMessage 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
OpenTxnMessage	getOpenTxnMessage(String messageBody) Method to de-serialize OpenTxnMessage instance.

Methods inherited from class org.apache.hadoop.hive.metastore.messaging.MessageDeserializer

getEventMessage

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

getAlterDatabaseMessage

public AlterDatabaseMessage getAlterDatabaseMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AlterDatabaseMessage instance.

Specified by:

getAlterDatabaseMessage 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

getCreateFunctionMessage

public CreateFunctionMessage getCreateFunctionMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize CreateFunctionMessage instance.

Specified by:

getCreateFunctionMessage in class MessageDeserializer

getDropFunctionMessage

public DropFunctionMessage getDropFunctionMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize DropFunctionMessage instance.

Specified by:

getDropFunctionMessage 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

getAddPrimaryKeyMessage

public AddPrimaryKeyMessage getAddPrimaryKeyMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AddPrimaryKeyMessage instance.

Specified by:

getAddPrimaryKeyMessage in class MessageDeserializer

getAddForeignKeyMessage

public AddForeignKeyMessage getAddForeignKeyMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AddForeignKeyMessage instance.

Specified by:

getAddForeignKeyMessage in class MessageDeserializer

getAddUniqueConstraintMessage

public AddUniqueConstraintMessage getAddUniqueConstraintMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AddUniqueConstraintMessage instance.

Specified by:

getAddUniqueConstraintMessage in class MessageDeserializer

getAddNotNullConstraintMessage

public AddNotNullConstraintMessage getAddNotNullConstraintMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AddNotNullConstraintMessage instance.

Specified by:

getAddNotNullConstraintMessage in class MessageDeserializer

getDropConstraintMessage

public DropConstraintMessage getDropConstraintMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize DropConstraintMessage instance.

Specified by:

getDropConstraintMessage in class MessageDeserializer

getOpenTxnMessage

public OpenTxnMessage getOpenTxnMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize OpenTxnMessage instance.

Specified by:

getOpenTxnMessage in class MessageDeserializer

getCommitTxnMessage

public CommitTxnMessage getCommitTxnMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize CommitTxnMessage instance.

Specified by:

getCommitTxnMessage in class MessageDeserializer

getAbortTxnMessage

public AbortTxnMessage getAbortTxnMessage(String messageBody)

Description copied from class: MessageDeserializer

Method to de-serialize AbortTxnMessage instance.

Specified by:

getAbortTxnMessage in class MessageDeserializer

getAllocWriteIdMessage

public AllocWriteIdMessage getAllocWriteIdMessage(String messageBody)

Specified by:

getAllocWriteIdMessage in class MessageDeserializer