public abstract class MessageFactory
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
HCAT_SERVER_URL |
protected static java.lang.String |
HCAT_SERVICE_PRINCIPAL |
protected static HiveConf |
hiveConf |
Constructor and Description |
---|
MessageFactory() |
Modifier and Type | Method and Description |
---|---|
abstract AddPartitionMessage |
buildAddPartitionMessage(Table table,
Partition partition)
Factory method for AddPartitionMessage.
|
abstract CreateDatabaseMessage |
buildCreateDatabaseMessage(Database db)
Factory method for CreateDatabaseMessage.
|
abstract CreateTableMessage |
buildCreateTableMessage(Table table)
Factory method for CreateTableMessage.
|
abstract DropDatabaseMessage |
buildDropDatabaseMessage(Database db)
Factory method for DropDatabaseMessage.
|
abstract DropPartitionMessage |
buildDropPartitionMessage(Table table,
Partition partition)
Factory method for DropPartitionMessage.
|
abstract DropTableMessage |
buildDropTableMessage(Table table)
Factory method for DropTableMessage.
|
abstract MessageDeserializer |
getDeserializer() |
static MessageDeserializer |
getDeserializer(java.lang.String format,
java.lang.String version)
Getter for MessageDeserializer, corresponding to the specified format and version.
|
static MessageFactory |
getInstance()
Getter for MessageFactory instance.
|
abstract java.lang.String |
getMessageFormat()
Getter for message-format.
|
abstract java.lang.String |
getVersion()
Getter for version-string, corresponding to all constructed messages.
|
protected static final HiveConf hiveConf
protected static final java.lang.String HCAT_SERVER_URL
protected static final java.lang.String HCAT_SERVICE_PRINCIPAL
public static MessageFactory getInstance()
public static MessageDeserializer getDeserializer(java.lang.String format, java.lang.String version)
format
- Serialization format for notifications.version
- Version of serialization format (currently ignored.)public abstract MessageDeserializer getDeserializer()
public abstract java.lang.String getVersion()
public abstract java.lang.String getMessageFormat()
public abstract CreateDatabaseMessage buildCreateDatabaseMessage(Database db)
db
- The Database being added.public abstract DropDatabaseMessage buildDropDatabaseMessage(Database db)
db
- The Database being dropped.public abstract CreateTableMessage buildCreateTableMessage(Table table)
table
- The Table being created.public abstract DropTableMessage buildDropTableMessage(Table table)
table
- The Table being dropped.public abstract AddPartitionMessage buildAddPartitionMessage(Table table, Partition partition)
table
- The Table to which the partition is added.partition
- The Partition being added.public abstract DropPartitionMessage buildDropPartitionMessage(Table table, Partition partition)
table
- The Table from which the partition is dropped.partition
- The Partition being dropped.Copyright © 2012 The Apache Software Foundation