- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.helix.ZNRecord
类的一些代码示例,展示了ZNRecord
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZNRecord
类的具体详情如下:
包路径:org.apache.helix.ZNRecord
类名称:ZNRecord
[英]Generic Record Format to store data at a Node This can be used to store simpleFields mapFields listFields
[中]在节点上存储数据的通用记录格式可用于存储simpleFields mapFields listFields
代码示例来源:origin: apache/incubator-pinot
ZNRecord record = new ZNRecord(PINOT_SEGMENT_ONLINE_OFFLINE_STATE_MODEL);
record.setSimpleField(StateModelDefinitionProperty.INITIAL_STATE.toString(), OFFLINE_STATE);
statePriorityList.add(OFFLINE_STATE);
statePriorityList.add(DROPPED_STATE);
record.setListField(StateModelDefinitionProperty.STATE_PRIORITY_LIST.toString(), statePriorityList);
if (state.equals(ONLINE_STATE)) {
metadata.put("count", "R");
record.setMapField(key, metadata);
record.setMapField(key, metadata);
record.setMapField(key, metadata);
metadata.put(OFFLINE_STATE, OFFLINE_STATE);
metadata.put(DROPPED_STATE, DROPPED_STATE);
record.setMapField(key, metadata);
metadata.put(ONLINE_STATE, ONLINE_STATE);
metadata.put(DROPPED_STATE, DROPPED_STATE);
record.setMapField(key, metadata);
stateTransitionPriorityList.add("OFFLINE-DROPPED");
record.setListField(StateModelDefinitionProperty.STATE_TRANSITION_PRIORITYLIST.toString(),
stateTransitionPriorityList);
代码示例来源:origin: apache/incubator-pinot
public SegmentZKMetadata(ZNRecord znRecord) {
_segmentName = znRecord.getSimpleField(CommonConstants.Segment.SEGMENT_NAME);
_tableName = znRecord.getSimpleField(CommonConstants.Segment.TABLE_NAME);
_crypterName = znRecord.getSimpleField(CommonConstants.Segment.CRYPTER_NAME);
_segmentType = znRecord.getEnumField(CommonConstants.Segment.SEGMENT_TYPE, SegmentType.class, SegmentType.OFFLINE);
_startTime = znRecord.getLongField(CommonConstants.Segment.START_TIME, -1);
_endTime = znRecord.getLongField(CommonConstants.Segment.END_TIME, -1);
if (znRecord.getSimpleFields().containsKey(CommonConstants.Segment.TIME_UNIT) && !znRecord
.getSimpleField(CommonConstants.Segment.TIME_UNIT).equals(NULL)) {
setTimeUnit(znRecord.getEnumField(CommonConstants.Segment.TIME_UNIT, TimeUnit.class, TimeUnit.DAYS));
}
_indexVersion = znRecord.getSimpleField(CommonConstants.Segment.INDEX_VERSION);
_totalRawDocs = znRecord.getLongField(CommonConstants.Segment.TOTAL_DOCS, -1);
_crc = znRecord.getLongField(CommonConstants.Segment.CRC, -1);
_creationTime = znRecord.getLongField(CommonConstants.Segment.CREATION_TIME, -1);
try {
String partitionMetadataJson = znRecord.getSimpleField(CommonConstants.Segment.PARTITION_METADATA);
if (partitionMetadataJson != null) {
_partitionMetadata = SegmentPartitionMetadata.fromJsonString(partitionMetadataJson);
}
} catch (IOException e) {
LOGGER.error(
"Exception caught while reading partition info from zk metadata for segment '{}', partition info dropped.",
_segmentName, e);
}
_segmentUploadStartTime = znRecord.getLongField(CommonConstants.Segment.SEGMENT_UPLOAD_START_TIME, -1);
_customMap = znRecord.getMapField(CommonConstants.Segment.CUSTOM_MAP);
}
代码示例来源:origin: apache/incubator-pinot
public static SegmentMergeLineage fromZNRecord(ZNRecord record) {
String tableNameWithType = record.getId();
Map<String, List<String>> segmentGroupLineageMap = record.getListFields();
Map<Integer, Map<String, List<String>>> groupToSegmentsMap = new HashMap<>();
for (Map.Entry<String, Map<String, String>> entry : record.getMapFields().entrySet()) {
String levelKey = entry.getKey();
Integer level = Integer.parseInt(levelKey.substring(LEVEL_KEY_PREFIX.length()));
Map<String, List<String>> groupToSegmentsForLevel = new HashMap<>();
for (Map.Entry<String, String> groupEntry : entry.getValue().entrySet()) {
String groupId = groupEntry.getKey();
String segmentsString = groupEntry.getValue();
List<String> segments = Arrays.asList(segmentsString.split(SEGMENT_DELIMITER));
groupToSegmentsForLevel.put(groupId, new ArrayList<>(segments));
}
groupToSegmentsMap.put(level, groupToSegmentsForLevel);
}
return new SegmentMergeLineage(tableNameWithType, segmentGroupLineageMap, groupToSegmentsMap);
}
代码示例来源:origin: apache/incubator-pinot
@Override
public ZNRecord toZNRecord() {
ZNRecord znRecord = super.toZNRecord();
znRecord.setLongField(START_OFFSET, _startOffset);
znRecord.setLongField(END_OFFSET, _endOffset);
znRecord.setIntField(NUM_REPLICAS, _numReplicas);
znRecord.setSimpleField(DOWNLOAD_URL, _downloadUrl);
return znRecord;
}
代码示例来源:origin: apache/incubator-pinot
@Override
public ZNRecord toZNRecord() {
ZNRecord znRecord = new ZNRecord(getId());
znRecord.setMapField(KAFKA_HIGH_LEVEL_CONSUMER_GROUP_MAP, _groupIdMap);
znRecord.setMapField(KAFKA_HIGH_LEVEL_CONSUMER_PARTITION_MAP, _partitionMap);
return znRecord;
}
代码示例来源:origin: apache/incubator-pinot
public OfflineSegmentZKMetadata(ZNRecord znRecord) {
super(znRecord);
setSegmentType(SegmentType.OFFLINE);
_downloadUrl = znRecord.getSimpleField(CommonConstants.Segment.Offline.DOWNLOAD_URL);
_pushTime = znRecord.getLongField(CommonConstants.Segment.Offline.PUSH_TIME, Long.MIN_VALUE);
_refreshTime = znRecord.getLongField(CommonConstants.Segment.Offline.REFRESH_TIME, Long.MIN_VALUE);
}
代码示例来源:origin: apache/incubator-pinot
@Override
public ZNRecord toZNRecord() {
ZNRecord znRecord = new ZNRecord(_segmentName);
znRecord.setSimpleField(CommonConstants.Segment.SEGMENT_NAME, _segmentName);
znRecord.setSimpleField(CommonConstants.Segment.TABLE_NAME, _tableName);
znRecord.setSimpleField(CommonConstants.Segment.CRYPTER_NAME, _crypterName);
znRecord.setEnumField(CommonConstants.Segment.SEGMENT_TYPE, _segmentType);
if (_timeUnit == null) {
znRecord.setSimpleField(CommonConstants.Segment.TIME_UNIT, NULL);
} else {
znRecord.setEnumField(CommonConstants.Segment.TIME_UNIT, _timeUnit);
znRecord.setLongField(CommonConstants.Segment.START_TIME, _startTime);
znRecord.setLongField(CommonConstants.Segment.END_TIME, _endTime);
znRecord.setSimpleField(CommonConstants.Segment.INDEX_VERSION, _indexVersion);
znRecord.setLongField(CommonConstants.Segment.TOTAL_DOCS, _totalRawDocs);
znRecord.setLongField(CommonConstants.Segment.CRC, _crc);
znRecord.setLongField(CommonConstants.Segment.CREATION_TIME, _creationTime);
znRecord.setSimpleField(CommonConstants.Segment.PARTITION_METADATA, partitionMetadataJson);
} catch (IOException e) {
LOGGER
znRecord.setLongField(CommonConstants.Segment.SEGMENT_UPLOAD_START_TIME, _segmentUploadStartTime);
znRecord.setMapField(CommonConstants.Segment.CUSTOM_MAP, _customMap);
代码示例来源:origin: apache/helix
private static void setZNRecord(ZNRecord diff, ZNRecord record, String keySuffix) {
if (diff == null || record == null) {
return;
}
for (String key : record.getSimpleFields().keySet()) {
diff.setSimpleField(key + "/" + keySuffix, record.getSimpleField(key));
}
for (String key : record.getListFields().keySet()) {
diff.setListField(key + "/" + keySuffix, record.getListField(key));
}
for (String key : record.getMapFields().keySet()) {
diff.setMapField(key + "/" + keySuffix, record.getMapField(key));
}
}
代码示例来源:origin: apache/incubator-pinot
/**
* Wrap {@link Schema} into a {@link ZNRecord}.
*/
public static ZNRecord toZNRecord(@Nonnull Schema schema) {
ZNRecord record = new ZNRecord(schema.getSchemaName());
record.setSimpleField("schemaJSON", schema.getJSONSchema());
return record;
}
代码示例来源:origin: apache/incubator-pinot
@Nullable
@Override
public IdealState apply(@Nullable IdealState input) {
Map<String, Map<String, String>> existingMapField = input.getRecord().getMapFields();
for (Map.Entry<String, Map<String, String>> segmentEntry : proposedIdealState.entrySet()) {
existingMapField.put(segmentEntry.getKey(), segmentEntry.getValue());
}
return input;
}
}, RetryPolicies.exponentialBackoffRetryPolicy(5, 500L, 2.0f));
代码示例来源:origin: linkedin/ambry
"ZNRecord does not exist on path={} in HelixPropertyStore when updating accounts. Creating a new ZNRecord.",
FULL_ACCOUNT_METADATA_PATH);
recordToUpdate = new ZNRecord(ZN_RECORD_ID);
} else {
recordToUpdate = recordFromZk;
Map<String, String> accountMap = recordToUpdate.getMapField(ACCOUNT_METADATA_MAP_KEY);
if (accountMap == null) {
logger.debug("AccountMap does not exist in ZNRecord when updating accounts. Creating a new accountMap");
recordToUpdate.setMapField(ACCOUNT_METADATA_MAP_KEY, accountMap);
potentialNewState = accountMap;
return recordToUpdate;
代码示例来源:origin: org.apache.helix/helix-core
public static List<ZNRecordRow> convertSimpleFields(ZNRecord record) {
List<ZNRecordRow> result = new ArrayList<ZNRecordRow>();
for (String key : record.getSimpleFields().keySet()) {
ZNRecordRow row = new ZNRecordRow();
row.putField(ZNRECORD_ID, record.getId());
row.putField(SIMPLE_KEY, key);
row.putField(SIMPLE_VALUE, record.getSimpleField(key));
result.add(row);
}
return result;
}
代码示例来源:origin: apache/helix
/**
* Initialize the property with an existing ZNRecord with new record id
* @param record
* @param id
*/
public HelixProperty(ZNRecord record, String id) {
_record = new ZNRecord(record, id);
_stat = new Stat(_record.getVersion(), _record.getCreationTime(), _record.getModifiedTime(), _record.getEphemeralOwner());
}
代码示例来源:origin: apache/incubator-pinot
/**
*
* @param tableName is the offline table name
* @param segmentName is name of the segment
* @param crc is the CRC of the new segment
*/
public SegmentRefreshMessage(String tableName, String segmentName, long crc) {
super(MessageType.USER_DEFINE_MSG, UUID.randomUUID().toString());
setResourceName(tableName);
setPartitionName(segmentName);
setMsgSubType(REFRESH_SEGMENT_MSG_SUB_TYPE);
// Give it infinite time to process the message, as long as session is alive
setExecutionTimeout(-1);
getRecord().setSimpleField(SIMPLE_FIELD_CRC, Long.toString(crc));
}
代码示例来源:origin: apache/incubator-pinot
public LLCRealtimeSegmentZKMetadata(ZNRecord znRecord) {
super(znRecord);
_startOffset = Long.valueOf(znRecord.getSimpleField(START_OFFSET));
_numReplicas = Integer.valueOf(znRecord.getSimpleField(NUM_REPLICAS));
_endOffset = Long.valueOf(znRecord.getSimpleField(END_OFFSET));
_downloadUrl = znRecord.getSimpleField(DOWNLOAD_URL);
}
代码示例来源:origin: apache/incubator-pinot
public static boolean comparisonZNRecords(ZNRecord record1, ZNRecord record2) {
if (!record1.getId().equals(record2.getId())) {
return false;
Map<String, String> simpleFieldMap1 = record1.getSimpleFields();
Map<String, String> simpleFieldMap2 = record2.getSimpleFields();
if (simpleFieldMap1.size() != simpleFieldMap2.size()) {
return false;
Map<String, List<String>> listFieldMap1 = record1.getListFields();
Map<String, List<String>> listFieldMap2 = record2.getListFields();
if (listFieldMap1.size() != listFieldMap2.size()) {
return false;
Map<String, Map<String, String>> mapFieldMap1 = record1.getMapFields();
Map<String, Map<String, String>> mapFieldMap2 = record2.getMapFields();
if (mapFieldMap1.size() != mapFieldMap2.size()) {
return false;
代码示例来源:origin: org.apache.helix/helix-core
private IdealState buildWorkflowIdealState(String workflow) {
CustomModeISBuilder IsBuilder = new CustomModeISBuilder(workflow);
IsBuilder.setRebalancerMode(IdealState.RebalanceMode.TASK).setNumReplica(1)
.setNumPartitions(1).setStateModel(TaskConstants.STATE_MODEL_NAME).disableExternalView();
IdealState is = IsBuilder.build();
is.getRecord().setListField(workflow, new ArrayList<String>());
is.getRecord().setMapField(workflow, new HashMap<String, String>());
is.setRebalancerClassName(WorkflowRebalancer.class.getName());
return is;
}
代码示例来源:origin: org.apache.helix/helix-core
@Override
public ZNRecord update(ZNRecord znRecord) {
if (znRecord.getMapField(task) == null) {
znRecord.setMapField(task, new HashMap<String, String>());
}
znRecord.getMapField(task).put(key, value);
return znRecord;
}
}, AccessOption.PERSISTENT);
代码示例来源:origin: apache/incubator-pinot
public ZNRecord toZNRecord() {
ZNRecord record = new ZNRecord(_tableNameWithType);
record.setListFields(_parentGroupToChildrenGroupsMap);
Map<String, Map<String, String>> groupToSegmentsMap = new HashMap<>();
for (Map.Entry<Integer, Map<String, List<String>>> entry : _levelToGroupToSegmentsMap.entrySet()) {
String key = LEVEL_KEY_PREFIX + entry.getKey();
Map<String, String> groupSegmentsForLevel = new HashMap<>();
for (Map.Entry<String, List<String>> groupEntry : entry.getValue().entrySet()) {
String groupId = groupEntry.getKey();
String segments = String.join(SEGMENT_DELIMITER, groupEntry.getValue());
groupSegmentsForLevel.put(groupId, segments);
}
groupToSegmentsMap.put(key, groupSegmentsForLevel);
}
record.setMapFields(groupToSegmentsMap);
return record;
}
代码示例来源:origin: apache/helix
public StateTransitionTimeoutConfig(ZNRecord record) {
_resource = record.getId();
if (record.getMapFields().containsKey(StateTransitionTimeoutProperty.TIMEOUT.name())) {
_timeoutMap = record.getMapField(StateTransitionTimeoutProperty.TIMEOUT.name());
} else {
_timeoutMap = new HashMap<String, String>();
}
}
我尝试理解[c代码 -> 汇编]代码 void node::Check( data & _data1, vector& _data2) { -> push ebp -> mov ebp,esp ->
我需要在当前表单(代码)的上下文中运行文本文件中的代码。其中一项要求是让代码创建新控件并将其添加到当前窗体。 例如,在Form1.cs中: using System.Windows.Forms; ..
我有此 C++ 代码并将其转换为 C# (.net Framework 4) 代码。有没有人给我一些关于 malloc、free 和 sprintf 方法的提示? int monate = ee; d
我的网络服务器代码有问题 #include #include #include #include #include #include #include int
给定以下 html 代码,将列表中的第三个元素(即“美丽”一词)以斜体显示的 CSS 代码是什么?当然,我可以给这个元素一个 id 或一个 class,但 html 代码必须保持不变。谢谢
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 我们不允许提问寻求书籍、工具、软件库等的推荐。您可以编辑问题,以便用事实和引用来回答。 关闭 7 年前。
我试图制作一个宏来避免重复代码和注释。 我试过这个: #define GrowOnPage(any Page, any Component) Component.Width := Page.Surfa
我正在尝试将我的旧 C++ 代码“翻译”成头条新闻所暗示的 C# 代码。问题是我是 C# 中的新手,并不是所有的东西都像 C++ 中那样。在 C++ 中这些解决方案运行良好,但在 C# 中只是不能。我
在 Windows 10 上工作,R 语言的格式化程序似乎没有在 Visual Studio Code 中完成它的工作。我试过R support for Visual Studio Code和 R-T
我正在处理一些报告(计数),我必须获取不同参数的计数。非常简单但乏味。 一个参数的示例查询: qCountsEmployee = ( "select count(*) from %s wher
最近几天我尝试从 d00m 调试网络错误。我开始用尽想法/线索,我希望其他 SO 用户拥有可能有用的宝贵经验。我希望能够提供所有相关信息,但我个人无法控制服务器环境。 整个事情始于用户注意到我们应用程
我有一个 app.js 文件,其中包含如下 dojo amd 模式代码: require(["dojo/dom", ..], function(dom){ dom.byId('someId').i
我对“-gencode”语句中的“code=sm_X”选项有点困惑。 一个例子:NVCC 编译器选项有什么作用 -gencode arch=compute_13,code=sm_13 嵌入库中? 只有
我为我的表格使用 X-editable 框架。 但是我有一些问题。 $(document).ready(function() { $('.access').editable({
我一直在通过本教程学习 flask/python http://blog.miguelgrinberg.com/post/the-flask-mega-tutorial-part-i-hello-wo
我想将 Vim 和 EMACS 用于 CNC、G 代码和 M 代码。 Vim 或 EMACS 是否有任何语法或模式来处理这种类型的代码? 最佳答案 一些快速搜索使我找到了 this vim 和 thi
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 想改进这个问题?更新问题,使其成为 on-topic对于堆栈溢出。 7年前关闭。 Improve this
这个问题在这里已经有了答案: Enabling markdown highlighting in Vim (5 个回答) 6年前关闭。 当我在 Vim 中编辑包含 Markdown 代码的 READM
我正在 Swift3 iOS 中开发视频应用程序。基本上我必须将视频 Assets 和音频与淡入淡出效果合并为一个并将其保存到 iPhone 画廊。为此,我使用以下方法: private func d
pipeline { agent any stages { stage('Build') { steps { e
我是一名优秀的程序员,十分优秀!