gpt4 book ai didi

org.apache.helix.messaging.ZNRecordRow.getMapSubKey()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 03:09:31 27 4
gpt4 key购买 nike

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

ZNRecordRow.getMapSubKey介绍

暂无

代码示例

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

(liveParticipants.contains(row.getRecordId()) || liveParticipants.contains(row.getMapSubKey()))) {
 result.add(row);
Map<String, String> resultRow = new HashMap<String, String>();
resultRow.put("instanceName", !recipientCriteria.getInstanceName().equals("") ?
  (!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");

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

/**
 * Check if a given row matches the specified criteria
 * @param criteria the criteria
 * @param row row of currently persisted data
 * @return true if it matches, false otherwise
 */
private boolean rowMatches(Criteria criteria, ZNRecordRow row) {
 String instanceName = normalizePattern(criteria.getInstanceName());
 String resourceName = normalizePattern(criteria.getResource());
 String partitionName = normalizePattern(criteria.getPartition());
 String partitionState = normalizePattern(criteria.getPartitionState());
 return stringMatches(instanceName, row.getMapSubKey()) && stringMatches(resourceName, row.getRecordId())
   && stringMatches(partitionName, row.getMapKey()) && stringMatches(partitionState, row.getMapValue());
}

代码示例来源:origin: org.apache.gobblin/gobblin-cluster

(liveParticipants.contains(row.getRecordId()) || liveParticipants.contains(row.getMapSubKey()))) {
 result.add(row);
Map<String, String> resultRow = new HashMap<String, String>();
resultRow.put("instanceName", !recipientCriteria.getInstanceName().equals("") ?
  (!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");

代码示例来源:origin: com.linkedin.gobblin/gobblin-cluster

(liveParticipants.contains(row.getRecordId()) || liveParticipants.contains(row.getMapSubKey()))) {
 result.add(row);
Map<String, String> resultRow = new HashMap<String, String>();
resultRow.put("instanceName", !recipientCriteria.getInstanceName().equals("") ?
  (!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");

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

/**
 * Check if a given row matches the specified criteria
 * @param criteria the criteria
 * @param row row of currently persisted data
 * @return true if it matches, false otherwise
 */
private boolean rowMatches(Criteria criteria, ZNRecordRow row) {
 String instanceName = normalizePattern(criteria.getInstanceName());
 String resourceName = normalizePattern(criteria.getResource());
 String partitionName = normalizePattern(criteria.getPartition());
 String partitionState = normalizePattern(criteria.getPartitionState());
 return (stringMatches(instanceName, Strings.nullToEmpty(row.getMapSubKey())) ||
     stringMatches(instanceName, Strings.nullToEmpty(row.getRecordId())))
   && stringMatches(resourceName, Strings.nullToEmpty(row.getRecordId()))
   && stringMatches(partitionName, Strings.nullToEmpty(row.getMapKey()))
   && stringMatches(partitionState, Strings.nullToEmpty(row.getMapValue()));
}

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

/**
 * Check if a given row matches the specified criteria
 * @param criteria the criteria
 * @param row row of currently persisted data
 * @return true if it matches, false otherwise
 */
private boolean rowMatches(Criteria criteria, ZNRecordRow row) {
 String instanceName = normalizePattern(criteria.getInstanceName());
 String resourceName = normalizePattern(criteria.getResource());
 String partitionName = normalizePattern(criteria.getPartition());
 String partitionState = normalizePattern(criteria.getPartitionState());
 return (stringMatches(instanceName, Strings.nullToEmpty(row.getMapSubKey())) ||
     stringMatches(instanceName, Strings.nullToEmpty(row.getRecordId())))
   && stringMatches(resourceName, Strings.nullToEmpty(row.getRecordId()))
   && stringMatches(partitionName, Strings.nullToEmpty(row.getMapKey()))
   && stringMatches(partitionState, Strings.nullToEmpty(row.getMapValue()));
}

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

(liveParticipants.contains(row.getRecordId()) || liveParticipants.contains(row.getMapSubKey()))) {
 result.add(row);
Map<String, String> resultRow = new HashMap<String, String>();
resultRow.put("instanceName", !recipientCriteria.getInstanceName().equals("") ?
  (!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) :
  "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId()

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

(liveParticipants.contains(row.getRecordId()) || liveParticipants.contains(row.getMapSubKey()))) {
 result.add(row);
Map<String, String> resultRow = new HashMap<String, String>();
resultRow.put("instanceName", !recipientCriteria.getInstanceName().equals("") ?
  (!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) :
  "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId()

代码示例来源:origin: org.apache.gobblin/gobblin-cluster

/**
 * Check if a given row matches the specified criteria
 * @param criteria the criteria
 * @param row row of currently persisted data
 * @return true if it matches, false otherwise
 */
private boolean rowMatches(Criteria criteria, ZNRecordRow row) {
 String instanceName = normalizePattern(criteria.getInstanceName());
 String resourceName = normalizePattern(criteria.getResource());
 String partitionName = normalizePattern(criteria.getPartition());
 String partitionState = normalizePattern(criteria.getPartitionState());
 return stringMatches(instanceName, row.getMapSubKey()) && stringMatches(resourceName, row.getRecordId())
   && stringMatches(partitionName, row.getMapKey()) && stringMatches(partitionState, row.getMapValue());
}

代码示例来源:origin: com.linkedin.gobblin/gobblin-cluster

/**
 * Check if a given row matches the specified criteria
 * @param criteria the criteria
 * @param row row of currently persisted data
 * @return true if it matches, false otherwise
 */
private boolean rowMatches(Criteria criteria, ZNRecordRow row) {
 String instanceName = normalizePattern(criteria.getInstanceName());
 String resourceName = normalizePattern(criteria.getResource());
 String partitionName = normalizePattern(criteria.getPartition());
 String partitionState = normalizePattern(criteria.getPartitionState());
 return stringMatches(instanceName, row.getMapSubKey()) && stringMatches(resourceName, row.getRecordId())
   && stringMatches(partitionName, row.getMapKey()) && stringMatches(partitionState, row.getMapValue());
}

27 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com