apurtell commented on code in PR #4924:
URL: https://github.com/apache/hbase/pull/4924#discussion_r1067359503
##########
hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/RegionServerObserver.java:
##########
@@ -137,4 +140,33 @@ default void
preExecuteProcedures(ObserverContext<RegionServerCoprocessorEnviron
default void
postExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
throws IOException {
}
+
+ /**
+ * This will be called before replication sink mutations are executed on the
sink table as part of
+ * batch call.
+ * @param ctx the environment to interact with the framework and region
server.
+ * @param walEntry wal entry from which mutation is formed.
+ * @param mutation mutation to be applied at sink cluster.
+ * @throws IOException if something goes wrong.
+ */
+ default void preReplicationSinkBatchMutate(
+ ObserverContext<RegionServerCoprocessorEnvironment> ctx,
AdminProtos.WALEntry walEntry,
Review Comment:
I wish we didn't have these protobuf types in the LimitedPrivate coprocessor
API. We are going to have to live within compatibility constraints. However it
would be prohibitively expensive to convert from protobuf types to HBase types
(and back) just for coprocessors.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
