org.apache.helix.model.Message.getResourceName()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(185)

本文整理了Java中org.apache.helix.model.Message.getResourceName()方法的一些代码示例，展示了Message.getResourceName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.getResourceName()方法的具体详情如下：
包路径：org.apache.helix.model.Message
类名称：Message
方法名：getResourceName

Message.getResourceName介绍

[英]Get the resource associated with this message
[中]获取与此消息关联的资源

代码示例

代码示例来源：origin: apache/incubator-pinot

  1. @Transition(from = "OFFLINE", to = "DROPPED")
  2. public void onBecomeDroppedFromOffline(Message message, NotificationContext context) {
  3.  _logger.info("SegmentOnlineOfflineStateModel.onBecomeDroppedFromOffline() : " + message);
  4.  String tableNameWithType = message.getResourceName();
  5.  String segmentName = message.getPartitionName();
  6.  // This method might modify the file on disk. Use segment lock to prevent race condition
  7.  Lock segmentLock = SegmentLocks.getSegmentLock(tableNameWithType, segmentName);
  8.  try {
  9.   segmentLock.lock();
  10.   final File segmentDir = new File(_fetcherAndLoader.getSegmentLocalDirectory(tableNameWithType, segmentName));
  11.   if (segmentDir.exists()) {
  12.    FileUtils.deleteQuietly(segmentDir);
  13.    _logger.info("Deleted segment directory {}", segmentDir);
  14.   }
  15.  } catch (final Exception e) {
  16.   _logger.error("Cannot delete the segment : " + segmentName + " from local directory!\n" + e.getMessage(), e);
  17.   Utils.rethrowException(e);
  18.  } finally {
  19.   segmentLock.unlock();
  20.  }
  21. }

代码示例来源：origin: apache/incubator-pinot

  1. @Transition(from = "ONLINE", to = "OFFLINE")
  2. public void onBecomeOfflineFromOnline(Message message, NotificationContext context) {
  3.  _logger.info("SegmentOnlineOfflineStateModel.onBecomeOfflineFromOnline() : " + message);
  4.  String tableNameWithType = message.getResourceName();
  5.  String segmentName = message.getPartitionName();
  6.  try {
  7.   _instanceDataManager.removeSegment(tableNameWithType, segmentName);
  8.  } catch (Exception e) {
  9.   _logger.error("Caught exception in state transition from ONLINE -> OFFLINE for resource: {}, partition: {}",
  10.     tableNameWithType, segmentName, e);
  11.   Utils.rethrowException(e);
  12.  }
  13. }

代码示例来源：origin: apache/incubator-pinot

  1. @Transition(from = "CONSUMING", to = "OFFLINE")
  2. public void onBecomeOfflineFromConsuming(Message message, NotificationContext context) {
  3.  _logger.info("SegmentOnlineOfflineStateModel.onBecomeOfflineFromConsuming() : " + message);
  4.  String realtimeTableName = message.getResourceName();
  5.  String segmentName = message.getPartitionName();
  6.  try {
  7.   _instanceDataManager.removeSegment(realtimeTableName, segmentName);
  8.  } catch (Exception e) {
  9.   _logger.error("Caught exception in state transition from CONSUMING -> OFFLINE for resource: {}, partition: {}",
  10.     realtimeTableName, segmentName, e);
  11.   Utils.rethrowException(e);
  12.  }
  13. }

代码示例来源：origin: apache/incubator-pinot

  1. @Transition(from = "OFFLINE", to = "ONLINE")
  2. public void onBecomeOnlineFromOffline(Message message, NotificationContext context) {
  3.  _logger.info("SegmentOnlineOfflineStateModel.onBecomeOnlineFromOffline() : " + message);
  4.  String tableNameWithType = message.getResourceName();
  5.  String segmentName = message.getPartitionName();
  6.  try {
  7.   TableType tableType = TableNameBuilder.getTableTypeFromTableName(message.getResourceName());
  8.   Preconditions.checkNotNull(tableType);
  9.   if (tableType == TableType.OFFLINE) {
  10.    _fetcherAndLoader.addOrReplaceOfflineSegment(tableNameWithType, segmentName);
  11.   } else {
  12.    _instanceDataManager.addRealtimeSegment(tableNameWithType, segmentName);
  13.   }
  14.  } catch (Exception e) {
  15.   _logger.error("Caught exception in state transition from OFFLINE -> ONLINE for resource: {}, partition: {}",
  16.     tableNameWithType, segmentName, e);
  17.   Utils.rethrowException(e);
  18.  }
  19. }

代码示例来源：origin: apache/incubator-pinot

  1. @Transition(from = "CONSUMING", to = "ONLINE")
  2. public void onBecomeOnlineFromConsuming(Message message, NotificationContext context) {
  3.  String realtimeTableName = message.getResourceName();
  4.  String segmentNameStr = message.getPartitionName();
  5.  LLCSegmentName segmentName = new LLCSegmentName(segmentNameStr);

代码示例来源：origin: uber/chaperone

  1. public void onBecomeDroppedFromOffline(Message message, NotificationContext context) {
  2.  System.out.println("TestOnlineOfflineStateModel.onBecomeDroppedFromOffline() for topic: "
  3.    + message.getResourceName() + ", partition: " + message.getPartitionName()
  4.    + " to instance: " + _instanceId);
  5.  sleep();
  6. }

代码示例来源：origin: uber/chaperone

  1. public void onBecomeOnlineFromOffline(Message message, NotificationContext context) {
  2.  System.out.println("TestOnlineOfflineStateModel.onBecomeOnlineFromOffline for topic: "
  3.    + message.getResourceName() + ", partition: " + message.getPartitionName()
  4.    + " to instance: " + _instanceId);
  5.  sleep();
  6. }

代码示例来源：origin: uber/chaperone

  1. public void onBecomeOfflineFromOnline(Message message, NotificationContext context) {
  2.  System.out.println("TestOnlineOfflineStateModel.onBecomeOfflineFromOnline for topic: "
  3.    + message.getResourceName() + ", partition: " + message.getPartitionName()
  4.    + " to instance: " + _instanceId);
  5.  sleep();
  6. }

代码示例来源：origin: apache/helix

  1. private void removeMessageFromTaskAndFutureMap(Message message) {
  2.  _knownMessageIds.remove(message.getId());
  3.  String messageTarget = getMessageTarget(message.getResourceName(), message.getPartitionName());
  4.  if (_messageTaskMap.containsKey(messageTarget)) {
  5.   _messageTaskMap.remove(messageTarget);
  6.  }
  7. }

代码示例来源：origin: uber/uReplicator

  1. @Transition(from = "ONLINE", to = "OFFLINE")
  2. public void onBecomeOfflineFromOnline(Message message, NotificationContext context) {
  3.  LOGGER.info("ControllerStateModel.onBecomeOfflineFromOnline() for resource: "
  4.    + message.getResourceName() + ", partition: " + message.getPartitionName());
  5.  handleStateChange(message);
  6. }

代码示例来源：origin: uber/uReplicator

  1. @Transition(from = "ERROR", to = "DROPPED")
  2. public void onBecomeDroppedFromError(Message message, NotificationContext context) {
  3.  LOGGER.info("ControllerStateModel.onBecomeDroppedFromError() for resource: "
  4.    + message.getResourceName() + ", partition: " + message.getPartitionName());
  5.  handleStateChange(message);
  6. }

代码示例来源：origin: apache/helix

  1. /**
  2.  * Generate the sub-path under STATUSUPDATE or ERROR path for a status update
  3.  */
  4. String getStatusUpdateSubPath(Message message) {
  5.  if (message.getMsgType().equalsIgnoreCase(MessageType.STATE_TRANSITION.name())) {
  6.   return message.getResourceName();
  7.  }
  8.  return message.getMsgType();
  9. }

代码示例来源：origin: uber/uReplicator

  1. @Transition(from = "OFFLINE", to = "DROPPED")
  2. public void onBecomeDroppedFromOffline(Message message, NotificationContext context) {
  3.  LOGGER.info("ControllerStateModel.onBecomeDroppedFromOffline() for resource: "
  4.    + message.getResourceName() + ", partition: " + message.getPartitionName());
  5.  handleStateChange(message);
  6. }

代码示例来源：origin: uber/uReplicator

  1. @Transition(from = "ERROR", to = "OFFLINE")
  2. public void onBecomeOfflineFromError(Message message, NotificationContext context) {
  3.  LOGGER.info("ControllerStateModel.onBecomeOfflineFromError() for resource: "
  4.    + message.getResourceName() + ", partition: " + message.getPartitionName());
  5.  handleStateChange(message);
  6. }

代码示例来源：origin: org.apache.helix/helix-core

  1. public void onBecomeStandbyFromOffline(Message message, NotificationContext context) {
  2.  System.out.println("LeaderStandbyStateModel.onBecomeStandbyFromOffline():" + _instanceName
  3.    + " transitioning from " + message.getFromState() + " to " + message.getToState()
  4.    + " for " + message.getResourceName() + " " + message.getPartitionName());
  5.  sleep();
  6. }

代码示例来源：origin: org.apache.helix/helix-core

  1. public void onBecomeOnlineFromOffline(Message message, NotificationContext context) {
  2.  System.out.println(
  3.    "OnlineOfflineStateModelFactory.onBecomeOnlineFromOffline():" + _instanceName
  4.      + " transitioning from " + message.getFromState() + " to " + message.getToState()
  5.      + " for " + message.getResourceName() + " " + message.getPartitionName());
  6.  sleep();
  7. }

代码示例来源：origin: org.apache.helix/helix-core

  1. public void onBecomeDroppedFromOffline(Message message, NotificationContext context) {
  2.  System.out.println(
  3.    "OnlineOfflineStateModelFactory.onBecomeDroppedFromOffline():" + _instanceName
  4.      + " transitioning from " + message.getFromState() + " to " + message.getToState()
  5.      + " for " + message.getResourceName() + " " + message.getPartitionName());
  6.  sleep();
  7. }

代码示例来源：origin: apache/helix

  1. public void onBecomeOfflineFromStandby(Message message, NotificationContext context) {
  2.  System.out.println("LeaderStandbyStateModel.onBecomeOfflineFromStandby():" + _instanceName
  3.    + " transitioning from " + message.getFromState() + " to " + message.getToState()
  4.    + " for " + message.getResourceName() + " " + message.getPartitionName());
  5.  sleep();
  6. }

代码示例来源：origin: apache/helix

  1. @Transition(to = "*", from = "*")
  2. public void generalTransitionHandle(Message message, NotificationContext context)
  3.   throws InterruptedException {
  4.  LOG.info(String
  5.    .format("Resource %s partition %s becomes %s from %s", message.getResourceName(),
  6.      message.getPartitionName(), message.getToState(), message.getFromState()));
  7.  if (_transition != null) {
  8.   _transition.doTransition(message, context);
  9.  }
  10. }

代码示例来源：origin: apache/helix

  1. public void onBecomeOnlineFromOffline(Message message, NotificationContext context) {
  2.  String db = message.getPartitionName();
  3.  String instanceName = context.getManager().getInstanceName();
  4.  MockProcess.sleep(_transDelay);
  5.  logger.info("MockStateModel.onBecomeOnlineFromOffline(), instance:" + instanceName + ", db:"
  6.    + db);
  7.  logger.info(
  8.    "MockStateModel.onBecomeOnlineFromOffline(), resource " + message.getResourceName()
  9.      + ", partition"
  10.      + message.getPartitionName());
  11.  verifyMessage(message);
  12. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com