public abstract class MessageDeserializer extends Object
Modifier | Constructor and Description |
---|---|
protected |
MessageDeserializer() |
Modifier and Type | Method and Description |
---|---|
abstract AbortTxnMessage |
getAbortTxnMessage(String messageBody)
Method to de-serialize AbortTxnMessage instance.
|
abstract AddForeignKeyMessage |
getAddForeignKeyMessage(String messageBody)
Method to de-serialize AddForeignKeyMessage instance.
|
abstract AddNotNullConstraintMessage |
getAddNotNullConstraintMessage(String messageBody)
Method to de-serialize AddNotNullConstraintMessage instance.
|
abstract AddPartitionMessage |
getAddPartitionMessage(String messageBody)
Method to de-serialize AddPartitionMessage instance.
|
abstract AddPrimaryKeyMessage |
getAddPrimaryKeyMessage(String messageBody)
Method to de-serialize AddPrimaryKeyMessage instance.
|
abstract AddUniqueConstraintMessage |
getAddUniqueConstraintMessage(String messageBody)
Method to de-serialize AddUniqueConstraintMessage instance.
|
abstract AllocWriteIdMessage |
getAllocWriteIdMessage(String messageBody) |
abstract AlterDatabaseMessage |
getAlterDatabaseMessage(String messageBody)
Method to de-serialize AlterDatabaseMessage instance.
|
abstract AlterPartitionMessage |
getAlterPartitionMessage(String messageBody)
Method to deserialize AlterPartitionMessage
|
abstract AlterTableMessage |
getAlterTableMessage(String messageBody)
Method to de-serialize AlterTableMessge
|
abstract CommitTxnMessage |
getCommitTxnMessage(String messageBody)
Method to de-serialize CommitTxnMessage instance.
|
abstract CreateDatabaseMessage |
getCreateDatabaseMessage(String messageBody)
Method to de-serialize CreateDatabaseMessage instance.
|
abstract CreateFunctionMessage |
getCreateFunctionMessage(String messageBody)
Method to de-serialize CreateFunctionMessage instance.
|
abstract CreateTableMessage |
getCreateTableMessage(String messageBody)
Method to de-serialize CreateTableMessage instance.
|
abstract DropConstraintMessage |
getDropConstraintMessage(String messageBody)
Method to de-serialize DropConstraintMessage instance.
|
abstract DropDatabaseMessage |
getDropDatabaseMessage(String messageBody)
Method to de-serialize DropDatabaseMessage instance.
|
abstract DropFunctionMessage |
getDropFunctionMessage(String messageBody)
Method to de-serialize DropFunctionMessage instance.
|
abstract DropPartitionMessage |
getDropPartitionMessage(String messageBody)
Method to de-serialize DropPartitionMessage instance.
|
abstract DropTableMessage |
getDropTableMessage(String messageBody)
Method to de-serialize DropTableMessage instance.
|
EventMessage |
getEventMessage(String eventTypeString,
String messageBody)
Method to construct EventMessage from string.
|
abstract InsertMessage |
getInsertMessage(String messageBody)
Method to deserialize InsertMessage
|
abstract OpenTxnMessage |
getOpenTxnMessage(String messageBody)
Method to de-serialize OpenTxnMessage instance.
|
public EventMessage getEventMessage(String eventTypeString, String messageBody)
public abstract CreateDatabaseMessage getCreateDatabaseMessage(String messageBody)
public abstract AlterDatabaseMessage getAlterDatabaseMessage(String messageBody)
public abstract DropDatabaseMessage getDropDatabaseMessage(String messageBody)
public abstract CreateTableMessage getCreateTableMessage(String messageBody)
public abstract AlterTableMessage getAlterTableMessage(String messageBody)
messageBody
- string messagepublic abstract DropTableMessage getDropTableMessage(String messageBody)
public abstract AddPartitionMessage getAddPartitionMessage(String messageBody)
public abstract AlterPartitionMessage getAlterPartitionMessage(String messageBody)
messageBody
- the message in serialized formpublic abstract DropPartitionMessage getDropPartitionMessage(String messageBody)
public abstract CreateFunctionMessage getCreateFunctionMessage(String messageBody)
public abstract DropFunctionMessage getDropFunctionMessage(String messageBody)
public abstract InsertMessage getInsertMessage(String messageBody)
messageBody
- the message in serialized formpublic abstract AddPrimaryKeyMessage getAddPrimaryKeyMessage(String messageBody)
public abstract AddForeignKeyMessage getAddForeignKeyMessage(String messageBody)
public abstract AddUniqueConstraintMessage getAddUniqueConstraintMessage(String messageBody)
public abstract AddNotNullConstraintMessage getAddNotNullConstraintMessage(String messageBody)
public abstract DropConstraintMessage getDropConstraintMessage(String messageBody)
public abstract OpenTxnMessage getOpenTxnMessage(String messageBody)
public abstract CommitTxnMessage getCommitTxnMessage(String messageBody)
public abstract AbortTxnMessage getAbortTxnMessage(String messageBody)
public abstract AllocWriteIdMessage getAllocWriteIdMessage(String messageBody)
Copyright © 2022 The Apache Software Foundation. All rights reserved.