Commit 4119f431 by rmani Committed by Madhan Neethiraj

ATLAS-2445: updated HBase hook to handle table-clone and snapshot-restore operations

parent a0c85e5a
...@@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.TableName; ...@@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.NamespaceDescriptor; import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment;
import org.apache.hadoop.hbase.coprocessor.ObserverContext; import org.apache.hadoop.hbase.coprocessor.ObserverContext;
import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
...@@ -149,6 +150,30 @@ public class HBaseAtlasCoprocessor extends HBaseAtlasCoprocessorBase { ...@@ -149,6 +150,30 @@ public class HBaseAtlasCoprocessor extends HBaseAtlasCoprocessorBase {
LOG.debug("<== HBaseAtlasCoprocessor.postModifyNamespace()"); LOG.debug("<== HBaseAtlasCoprocessor.postModifyNamespace()");
} }
} }
@Override
public void postCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> observerContext, HBaseProtos.SnapshotDescription snapshotDescription, HTableDescriptor hTableDescriptor) throws IOException {
if (LOG.isDebugEnabled()) {
LOG.debug("==> HBaseAtlasCoprocessoror.postCloneSnapshot()");
}
hbaseAtlasHook.sendHBaseTableOperation(hTableDescriptor, null, HBaseAtlasHook.OPERATION.CREATE_TABLE);
if (LOG.isDebugEnabled()) {
LOG.debug("<== HBaseAtlasCoprocessoror.postCloneSnapshot()");
}
}
@Override
public void postRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> observerContext, HBaseProtos.SnapshotDescription snapshotDescription, HTableDescriptor hTableDescriptor) throws IOException {
if (LOG.isDebugEnabled()) {
LOG.debug("==> HBaseAtlasCoprocessor.postRestoreSnapshot()");
}
hbaseAtlasHook.sendHBaseTableOperation(hTableDescriptor, hTableDescriptor.getTableName(), HBaseAtlasHook.OPERATION.ALTER_TABLE);
if (LOG.isDebugEnabled()) {
LOG.debug("<== HBaseAtlasCoprocessor.postRestoreSnapshot()");
}
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment