@InterfaceAudience.Public @InterfaceStability.Stable public abstract class MetaStoreEventListener extends Object implements org.apache.hadoop.conf.Configurable
Constructor and Description |
---|
MetaStoreEventListener(org.apache.hadoop.conf.Configuration config) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getConf() |
void |
onAbortTxn(AbortTxnEvent abortTxnEvent,
Connection dbConn,
SQLGenerator sqlGenerator)
This will be called to abort a transaction.
|
void |
onAddForeignKey(AddForeignKeyEvent addForeignKeyEvent) |
void |
onAddNotNullConstraint(AddNotNullConstraintEvent addNotNullConstraintEvent) |
void |
onAddPartition(AddPartitionEvent partitionEvent) |
void |
onAddPrimaryKey(AddPrimaryKeyEvent addPrimaryKeyEvent) |
void |
onAddSchemaVersion(AddSchemaVersionEvent addSchemaVersionEvent) |
void |
onAddUniqueConstraint(AddUniqueConstraintEvent addUniqueConstraintEvent) |
void |
onAllocWriteId(AllocWriteIdEvent allocWriteIdEvent,
Connection dbConn,
SQLGenerator sqlGenerator)
This will be called to alloc a new write id.
|
void |
onAlterCatalog(AlterCatalogEvent alterCatalogEvent) |
void |
onAlterDatabase(AlterDatabaseEvent dbEvent) |
void |
onAlterISchema(AlterISchemaEvent alterISchemaEvent) |
void |
onAlterPartition(AlterPartitionEvent partitionEvent) |
void |
onAlterSchemaVersion(AlterSchemaVersionEvent alterSchemaVersionEvent) |
void |
onAlterTable(AlterTableEvent tableEvent) |
void |
onCommitTxn(CommitTxnEvent commitTxnEvent,
Connection dbConn,
SQLGenerator sqlGenerator)
This will be called to commit a transaction.
|
void |
onConfigChange(ConfigChangeEvent tableEvent) |
void |
onCreateCatalog(CreateCatalogEvent createCatalogEvent) |
void |
onCreateDatabase(CreateDatabaseEvent dbEvent) |
void |
onCreateFunction(CreateFunctionEvent fnEvent) |
void |
onCreateISchema(CreateISchemaEvent createISchemaEvent) |
void |
onCreateTable(CreateTableEvent tableEvent) |
void |
onDropCatalog(DropCatalogEvent dropCatalogEvent) |
void |
onDropConstraint(DropConstraintEvent dropConstraintEvent) |
void |
onDropDatabase(DropDatabaseEvent dbEvent) |
void |
onDropFunction(DropFunctionEvent fnEvent) |
void |
onDropISchema(DropISchemaEvent dropISchemaEvent) |
void |
onDropPartition(DropPartitionEvent partitionEvent) |
void |
onDropSchemaVersion(DropSchemaVersionEvent dropSchemaVersionEvent) |
void |
onDropTable(DropTableEvent tableEvent) |
void |
onInsert(InsertEvent insertEvent)
This will be called when an insert is executed that does not cause a partition to be added.
|
void |
onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) |
void |
onOpenTxn(OpenTxnEvent openTxnEvent,
Connection dbConn,
SQLGenerator sqlGenerator)
This will be called when a new transaction is started.
|
void |
setConf(org.apache.hadoop.conf.Configuration config) |
public MetaStoreEventListener(org.apache.hadoop.conf.Configuration config)
public void onConfigChange(ConfigChangeEvent tableEvent) throws MetaException
tableEvent
- table event.MetaException
public void onCreateTable(CreateTableEvent tableEvent) throws MetaException
tableEvent
- table event.MetaException
public void onDropTable(DropTableEvent tableEvent) throws MetaException
tableEvent
- table event.MetaException
public void onAlterTable(AlterTableEvent tableEvent) throws MetaException
tableEvent
- alter table eventMetaException
public void onAddPartition(AddPartitionEvent partitionEvent) throws MetaException
partitionEvent
- add partition eventMetaException
public void onDropPartition(DropPartitionEvent partitionEvent) throws MetaException
partitionEvent
- partition eventMetaException
public void onAlterPartition(AlterPartitionEvent partitionEvent) throws MetaException
partitionEvent
- partition eventMetaException
public void onCreateDatabase(CreateDatabaseEvent dbEvent) throws MetaException
dbEvent
- database eventMetaException
public void onDropDatabase(DropDatabaseEvent dbEvent) throws MetaException
dbEvent
- database eventMetaException
public void onAlterDatabase(AlterDatabaseEvent dbEvent) throws MetaException
dbEvent
- alter database eventMetaException
public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent) throws MetaException
partSetDoneEvent
- MetaException
public void onCreateFunction(CreateFunctionEvent fnEvent) throws MetaException
fnEvent
- function eventMetaException
public void onDropFunction(DropFunctionEvent fnEvent) throws MetaException
fnEvent
- function eventMetaException
public void onInsert(InsertEvent insertEvent) throws MetaException
onAddPartition(org.apache.hadoop.hive.metastore.events.AddPartitionEvent)
to be
called instead.insertEvent
- MetaException
public void onAddPrimaryKey(AddPrimaryKeyEvent addPrimaryKeyEvent) throws MetaException
addPrimaryKeyEvent
- add primary key eventMetaException
public void onAddForeignKey(AddForeignKeyEvent addForeignKeyEvent) throws MetaException
addForeignKeyEvent
- add foreign key eventMetaException
public void onAddUniqueConstraint(AddUniqueConstraintEvent addUniqueConstraintEvent) throws MetaException
addUniqueConstraintEvent
- add unique constraint eventMetaException
public void onAddNotNullConstraint(AddNotNullConstraintEvent addNotNullConstraintEvent) throws MetaException
addNotNullConstraintEvent
- add not null constraint eventMetaException
public void onDropConstraint(DropConstraintEvent dropConstraintEvent) throws MetaException
dropConstraintEvent
- drop constraint eventMetaException
public void onCreateISchema(CreateISchemaEvent createISchemaEvent) throws MetaException
MetaException
public void onAlterISchema(AlterISchemaEvent alterISchemaEvent) throws MetaException
MetaException
public void onDropISchema(DropISchemaEvent dropISchemaEvent) throws MetaException
MetaException
public void onAddSchemaVersion(AddSchemaVersionEvent addSchemaVersionEvent) throws MetaException
MetaException
public void onAlterSchemaVersion(AlterSchemaVersionEvent alterSchemaVersionEvent) throws MetaException
MetaException
public void onDropSchemaVersion(DropSchemaVersionEvent dropSchemaVersionEvent) throws MetaException
MetaException
public void onCreateCatalog(CreateCatalogEvent createCatalogEvent) throws MetaException
MetaException
public void onAlterCatalog(AlterCatalogEvent alterCatalogEvent) throws MetaException
MetaException
public void onDropCatalog(DropCatalogEvent dropCatalogEvent) throws MetaException
MetaException
public void onOpenTxn(OpenTxnEvent openTxnEvent, Connection dbConn, SQLGenerator sqlGenerator) throws MetaException
openTxnEvent
- event to be processeddbConn
- jdbc connection to remote meta store db.sqlGenerator
- helper class to generate db specific sql string.MetaException
public void onCommitTxn(CommitTxnEvent commitTxnEvent, Connection dbConn, SQLGenerator sqlGenerator) throws MetaException
commitTxnEvent
- event to be processeddbConn
- jdbc connection to remote meta store db.sqlGenerator
- helper class to generate db specific sql string.MetaException
public void onAbortTxn(AbortTxnEvent abortTxnEvent, Connection dbConn, SQLGenerator sqlGenerator) throws MetaException
abortTxnEvent
- event to be processeddbConn
- jdbc connection to remote meta store db.sqlGenerator
- helper class to generate db specific sql string.MetaException
public void onAllocWriteId(AllocWriteIdEvent allocWriteIdEvent, Connection dbConn, SQLGenerator sqlGenerator) throws MetaException
allocWriteIdEvent
- event to be processeddbConn
- jdbc connection to remote meta store db.sqlGenerator
- helper class to generate db specific sql string.MetaException
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration config)
setConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2022 The Apache Software Foundation. All rights reserved.