org.apache.hadoop.hbase.procedure.ZKProcedureUtil.getAbortNode()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-17 01:23:31 26 4

public String getAbortZNode(String opInstanceName) {
 return ZKProcedureUtil.getAbortNode(this, opInstanceName);
}

/**
 * Verify that the prepare, commit and abort nodes for the operation are removed from zookeeper
 */
private void verifyZooKeeperClean(String operationName, ZKWatcher watcher,
  ZKProcedureUtil controller) throws Exception {
 String prepare = ZKProcedureUtil.getAcquireBarrierNode(controller, operationName);
 String commit = ZKProcedureUtil.getReachedBarrierNode(controller, operationName);
 String abort = ZKProcedureUtil.getAbortNode(controller, operationName);
 assertEquals("Didn't delete prepare node", -1, ZKUtil.checkExists(watcher, prepare));
 assertEquals("Didn't delete commit node", -1, ZKUtil.checkExists(watcher, commit));
 assertEquals("Didn't delete abort node", -1, ZKUtil.checkExists(watcher, abort));
}

public String getAbortZNode(String opInstanceName) {
 return ZKProcedureUtil.getAbortNode(this, opInstanceName);
}

public String getAbortZNode(String opInstanceName) {
 return ZKProcedureUtil.getAbortNode(this, opInstanceName);
}

/**
 * Verify that the prepare, commit and abort nodes for the operation are removed from zookeeper
 */
private void verifyZooKeeperClean(String operationName, ZKWatcher watcher,
  ZKProcedureUtil controller) throws Exception {
 String prepare = ZKProcedureUtil.getAcquireBarrierNode(controller, operationName);
 String commit = ZKProcedureUtil.getReachedBarrierNode(controller, operationName);
 String abort = ZKProcedureUtil.getAbortNode(controller, operationName);
 assertEquals("Didn't delete prepare node", -1, ZKUtil.checkExists(watcher, prepare));
 assertEquals("Didn't delete commit node", -1, ZKUtil.checkExists(watcher, commit));
 assertEquals("Didn't delete abort node", -1, ZKUtil.checkExists(watcher, abort));
}

26 4 0

• mysql - 哪个更好 : calling procedure inside a procedure or executing sql inside a procedure?

  我有 3 个表: 1. 学生:{id, name, roll} 2. 主题:{id, name} 3. 分数:{student_id, subject_id, marks} 我有一个返回所有学生及其分

• procedural-generation - 数学题: procedural generation of a galaxy

  我将制作一款完全由程序生成的空间/交易/战斗游戏。但是，我知道将整个星系的所有细节存储在内存中是不可行的。因此，我一直认为我可以使用种子来生成太阳系，并且从该太阳系，您可以使用跳跃门前往其他太阳系。问

• stored-procedures - 优势数据库服务器 : slow stored procedure performance

  我有一个关于 ADS 中存储过程的性能的问题。我创建了一个具有以下结构的简单数据库: CREATE TABLE MainTable ( Id INTEGER PRIMARY KEY,

• procedure - 序言 : Making a procedure to print Hello World

  我想将这个简单的东西加载到我的编辑器中: Write:-repeat,write("hi"),nl,fail. 所以它打印“嗨”。 我该怎么办？ 我目前正在尝试做 File->New 并将名为 Wri

• c# - 调用 MySQL Procedure 出现异常 "procedure cannot be found"

  在从 c# 调用过程中显示以下错误 "Procedure or function 'CALL get_Users()'cannot be foundin database 'joomla'."` 代码

• MySQL 服务器 : stored procedures - when do i create the stored procedures?

  在网上找到了创建存储过程的教程，只是不明白到底什么时候需要执行创建存储过程。 是否应该在每次重新启动 MySQL 服务器时执行存储过程创建？ 我是否需要在每次启动我的应用程序时都执行存储过程创建sql

• stored-procedures - MySql 恢复问题 :Stored procedure not Restored

  我有一个包含所有例程的 MySQL 转储。当我恢复时，只有存储过程没有恢复。我从中提取 Dump 的 MySQL 版本是 5.0.77-log，我恢复到的版本是 5.6.12。 感谢任何帮助。 谢谢

• SQL Server : Find Stored Procedures called within a procedure

  我是一家大量使用存储过程(500+)的公司的新手。为了帮助学习系统，我希望有一种简单的方法来构建一个树型列表，显示系统中的所有存储过程以及它们自己调用哪些存储过程......从而创建可以执行的存储过程

• mysqldump --add-drop-procedure 或 DROP PROCEDURE IF EXISTS

  我需要使用 mysqldump 和 replace 而不是 insert 并且在恢复时不删除数据库和表。但我需要删除并重新创建触发器和存储过程 为此，我将 mysqldump 与 --replace

• runtime-error - 我的代码显示错误 “application: not a procedure”或 “call to non procedure”

  在执行代码的过程中，我在不同的Scheme实现中遇到以下错误: Racket : application: not a procedure; expected a procedure that ca

• stored-procedures - Entity Framework : Map output parameters from stored procedure?

  我想将存储过程输出参数映射到一个实体。 例如， PROCEDURE ForExample @ID int, @LastUpdate datetime OUTPUT AS Update EntityTa

• stored-procedures - MSSQL2000 : Using a stored procedure results as a table in sql

  假设我有“myStoredProcedure”，它接受一个 Id 作为参数，并返回一个信息表。 是否可以编写类似于此的 SQL 语句？ SELECT MyColumn FROM Tabl

• stored-procedures - PL/SQL : Passing lexical parameter to a stored procedure

  我想将整个 sql 查询作为词法参数传递给存储过程，然后执行它。任何建议如何做到这一点？ 最佳答案 你可以试试这个: create or replace procedure my_proc(pstri

• delphi - 优雅地放松 "Local procedure/function assigned to procedure variable"限制

  考虑以下测试用例: { CompilerVersion = 21 } procedure Global(); procedure Local(); begin end; type TP

• azure - 宇宙数据库 : Call a stored procedure from another stored procedure or trigger

  在 Azure Cosmos Db 中，是否可以从另一个存储过程调用一个存储过程？那么UDF呢？我可以从另一个 UDF、存储过程或触发器调用一个 UDF吗？ 最佳答案 is there a way t

• azure - 宇宙数据库 : Call a stored procedure from another stored procedure or trigger

  在 Azure Cosmos Db 中，是否可以从另一个存储过程调用一个存储过程？那么UDF呢？我可以从另一个 UDF、存储过程或触发器调用一个 UDF吗？ 最佳答案 is there a way t

• stored-procedures - 链接到实体 : Result set not getting updated after Stored Procedure Call

  在 LINQ to Entities 中，我将存储过程的结果集映射到实体。 在存储过程中，我执行一些更新语句并通过运行 SELECT 查询并将结果集映射到实体来返回结果集。 数据库行得到正确更新，但返

• tsql - "CREATE PROCEDURE SPNAME AS"与 "CREATE PROCEDURE SPNAME AS BEGIN/END"

  创建存储过程时，BEGIN/END 块是否有用途？ 例如， CREATE PROCEDURE SPNAME AS SELECT * FROM TABLE 对比 CREATE PROCEDURE S

• mysql - procedure 参数是 int，但是当使用 double 调用 procedure 时，它​​会编译

  正如您在下面看到的，我的过程有两个参数。我希望它们都是整数。但是，当我使用非整数测试该过程时，它仍然可以编译!为什么？ create procedure int_arith( p_1 int, p_

• arrays - Excel vba : Property let procedure not defined and property get procedure did not return an object

  我有一个 Client类(class)。在那个类里面有一个数组 losses .首先，我创建并使用客户端填充 clientsColl大批。然后对于该数组中的每个客户端，我填充其 losses大批。 然