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