public class JSONMessageDeserializer extends MessageDeserializer
Constructor and Description |
---|
JSONMessageDeserializer() |
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.
|
getEventMessage
public CreateDatabaseMessage getCreateDatabaseMessage(String messageBody)
MessageDeserializer
getCreateDatabaseMessage
in class MessageDeserializer
public AlterDatabaseMessage getAlterDatabaseMessage(String messageBody)
MessageDeserializer
getAlterDatabaseMessage
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 InsertMessage getInsertMessage(String messageBody)
MessageDeserializer
getInsertMessage
in class MessageDeserializer
messageBody
- the message in serialized formpublic AddPrimaryKeyMessage getAddPrimaryKeyMessage(String messageBody)
MessageDeserializer
getAddPrimaryKeyMessage
in class MessageDeserializer
public AddForeignKeyMessage getAddForeignKeyMessage(String messageBody)
MessageDeserializer
getAddForeignKeyMessage
in class MessageDeserializer
public AddUniqueConstraintMessage getAddUniqueConstraintMessage(String messageBody)
MessageDeserializer
getAddUniqueConstraintMessage
in class MessageDeserializer
public AddNotNullConstraintMessage getAddNotNullConstraintMessage(String messageBody)
MessageDeserializer
getAddNotNullConstraintMessage
in class MessageDeserializer
public DropConstraintMessage getDropConstraintMessage(String messageBody)
MessageDeserializer
getDropConstraintMessage
in class MessageDeserializer
public OpenTxnMessage getOpenTxnMessage(String messageBody)
MessageDeserializer
getOpenTxnMessage
in class MessageDeserializer
public CommitTxnMessage getCommitTxnMessage(String messageBody)
MessageDeserializer
getCommitTxnMessage
in class MessageDeserializer
public AbortTxnMessage getAbortTxnMessage(String messageBody)
MessageDeserializer
getAbortTxnMessage
in class MessageDeserializer
public AllocWriteIdMessage getAllocWriteIdMessage(String messageBody)
getAllocWriteIdMessage
in class MessageDeserializer
Copyright © 2022 The Apache Software Foundation. All rights reserved.