public class JSONMessageDeserializer extends MessageDeserializer
Constructor and Description |
---|
JSONMessageDeserializer() |
Modifier and Type | Method and Description |
---|---|
AddPartitionMessage |
getAddPartitionMessage(String messageBody)
Method to de-serialize AddPartitionMessage instance.
|
AlterIndexMessage |
getAlterIndexMessage(String messageBody)
Method to de-serialize AlterIndexMessage 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.
|
CreateFunctionMessage |
getCreateFunctionMessage(String messageBody)
Method to de-serialize CreateFunctionMessage instance.
|
CreateIndexMessage |
getCreateIndexMessage(String messageBody)
Method to de-serialize CreateIndexMessage instance.
|
CreateTableMessage |
getCreateTableMessage(String messageBody)
Method to de-serialize CreateTableMessage instance.
|
DropDatabaseMessage |
getDropDatabaseMessage(String messageBody)
Method to de-serialize DropDatabaseMessage instance.
|
DropFunctionMessage |
getDropFunctionMessage(String messageBody)
Method to de-serialize DropFunctionMessage instance.
|
DropIndexMessage |
getDropIndexMessage(String messageBody)
Method to de-serialize DropIndexMessage 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
|
getEventMessage
public CreateDatabaseMessage getCreateDatabaseMessage(String messageBody)
MessageDeserializer
getCreateDatabaseMessage
in class MessageDeserializer
public DropDatabaseMessage getDropDatabaseMessage(String messageBody)
MessageDeserializer
getDropDatabaseMessage
in class MessageDeserializer
public CreateTableMessage getCreateTableMessage(String messageBody)
MessageDeserializer
getCreateTableMessage
in class MessageDeserializer
public AlterTableMessage getAlterTableMessage(String messageBody)
MessageDeserializer
getAlterTableMessage
in class MessageDeserializer
messageBody
- string messagepublic DropTableMessage getDropTableMessage(String messageBody)
MessageDeserializer
getDropTableMessage
in class MessageDeserializer
public AddPartitionMessage getAddPartitionMessage(String messageBody)
MessageDeserializer
getAddPartitionMessage
in class MessageDeserializer
public AlterPartitionMessage getAlterPartitionMessage(String messageBody)
MessageDeserializer
getAlterPartitionMessage
in class MessageDeserializer
messageBody
- the message in serialized formpublic DropPartitionMessage getDropPartitionMessage(String messageBody)
MessageDeserializer
getDropPartitionMessage
in class MessageDeserializer
public CreateFunctionMessage getCreateFunctionMessage(String messageBody)
MessageDeserializer
getCreateFunctionMessage
in class MessageDeserializer
public DropFunctionMessage getDropFunctionMessage(String messageBody)
MessageDeserializer
getDropFunctionMessage
in class MessageDeserializer
public CreateIndexMessage getCreateIndexMessage(String messageBody)
MessageDeserializer
getCreateIndexMessage
in class MessageDeserializer
public DropIndexMessage getDropIndexMessage(String messageBody)
MessageDeserializer
getDropIndexMessage
in class MessageDeserializer
public AlterIndexMessage getAlterIndexMessage(String messageBody)
MessageDeserializer
getAlterIndexMessage
in class MessageDeserializer
public InsertMessage getInsertMessage(String messageBody)
MessageDeserializer
getInsertMessage
in class MessageDeserializer
messageBody
- the message in serialized formCopyright © 2021 The Apache Software Foundation. All rights reserved.