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 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 CreateTableMessage |
getCreateTableMessage(String messageBody)
Method to de-serialize CreateTableMessage instance.
|
abstract DropDatabaseMessage |
getDropDatabaseMessage(String messageBody)
Method to de-serialize DropDatabaseMessage 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 InsertMessage getInsertMessage(String messageBody)
messageBody
- the message in serialized formCopyright © 2017 The Apache Software Foundation. All rights reserved.