本文整理了Java中org.apache.helix.messaging.ZNRecordRow.getMapKey()
方法的一些代码示例,展示了ZNRecordRow.getMapKey()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNRecordRow.getMapKey()
方法的具体详情如下:
包路径:org.apache.helix.messaging.ZNRecordRow
类名称:ZNRecordRow
方法名:getMapKey
暂无
代码示例来源:origin: apache/incubator-gobblin
(!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");
resultRow.put("partitionState", !recipientCriteria.getPartitionState().equals("") ? row.getMapValue() : "");
selected.add(resultRow);
代码示例来源: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
(!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");
resultRow.put("partitionState", !recipientCriteria.getPartitionState().equals("") ? row.getMapValue() : "");
selected.add(resultRow);
代码示例来源:origin: com.linkedin.gobblin/gobblin-cluster
(!Strings.isNullOrEmpty(row.getMapSubKey()) ? row.getMapSubKey() : row.getRecordId()) : "");
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId() : "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey() : "");
resultRow.put("partitionState", !recipientCriteria.getPartitionState().equals("") ? row.getMapValue() : "");
selected.add(resultRow);
代码示例来源: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
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId()
: "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey()
: "");
resultRow.put("partitionState",
代码示例来源:origin: org.apache.helix/helix-core
resultRow.put("resourceName", !recipientCriteria.getResource().equals("") ? row.getRecordId()
: "");
resultRow.put("partitionName", !recipientCriteria.getPartition().equals("") ? row.getMapKey()
: "");
resultRow.put("partitionState",
代码示例来源: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());
}
内容来源于网络,如有侵权,请联系作者删除!