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

ZKMetadataProvider.getOfflineSegmentZKMetadata介绍

[英]NOTE: this method is very expensive, use #getSegments(ZkHelixPropertyStore,String) instead if only segment segment names are needed.
[中]注意：此方法非常昂贵，如果只需要段名称，请使用#getSegments（ZkHelixPropertyStore，String）。

代码示例

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

public OfflineSegmentZKMetadata getOfflineSegmentZKMetadata(@Nonnull String tableName, @Nonnull String segmentName) {
 return ZKMetadataProvider.getOfflineSegmentZKMetadata(_propertyStore, tableName, segmentName);
}

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

private void updateSegmentMetadataCrc(String tableName, String segmentName, int currentVersion) {
 OfflineSegmentZKMetadata offlineSegmentZKMetadata =
   ZKMetadataProvider.getOfflineSegmentZKMetadata(_propertyStore, tableName, segmentName);
 _lastKnownSegmentMetadataVersionMap.get(tableName).put(segmentName, currentVersion);
 _segmentCrcMap.get(tableName).put(segmentName, offlineSegmentZKMetadata.getCrc());
}

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

private long getNumRowsFromOfflineMetadata(String segmentName)
  throws Exception {
 OfflineSegmentZKMetadata segmentZKMetadata =
   ZKMetadataProvider.getOfflineSegmentZKMetadata(_propertyStore, TABLE_NAME, segmentName);
 return segmentZKMetadata.getTotalRawDocs();
}

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

if (segmentZKMetadata == null || segmentZKMetadata.getPartitionMetadata() == null
  || segmentZKMetadata.getPartitionMetadata().getColumnPartitionMap().size() == 0) {
 segmentZKMetadata = ZKMetadataProvider.getOfflineSegmentZKMetadata(_propertyStore, tableName, segmentName);
 if (segmentZKMetadata != null) {
  _segmentToZkMetadataMapping.put(segmentName, segmentZKMetadata);

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

public void addOrReplaceOfflineSegment(String tableNameWithType, String segmentName) {
 OfflineSegmentZKMetadata newSegmentZKMetadata =
   ZKMetadataProvider.getOfflineSegmentZKMetadata(_propertyStore, tableNameWithType, segmentName);
 Preconditions.checkNotNull(newSegmentZKMetadata);

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

/**
 * Returns the segment metadata.
 *
 * @param tableNameWithType Table name with type suffix
 * @param segmentName Segment name
 * @return Singleton JSON array of the segment metadata
 */
private ArrayNode getSegmentMetaData(String tableNameWithType, String segmentName) {
 ZkHelixPropertyStore<ZNRecord> propertyStore = _pinotHelixResourceManager.getPropertyStore();
 if (!ZKMetadataProvider.isSegmentExisted(propertyStore, tableNameWithType, segmentName)) {
  return null;
 }
 ArrayNode ret = JsonUtils.newArrayNode();
 ObjectNode jsonObj = JsonUtils.newObjectNode();
 jsonObj.put(TABLE_NAME, tableNameWithType);
 if (TableNameBuilder.OFFLINE.tableHasTypeSuffix(tableNameWithType)) {
  // OFFLINE table
  OfflineSegmentZKMetadata offlineSegmentZKMetadata =
    ZKMetadataProvider.getOfflineSegmentZKMetadata(propertyStore, tableNameWithType, segmentName);
  jsonObj.set(STATE, JsonUtils.objectToJsonNode(offlineSegmentZKMetadata.toMap()));
 } else {
  // REALTIME table
  RealtimeSegmentZKMetadata realtimeSegmentZKMetadata =
    ZKMetadataProvider.getRealtimeSegmentZKMetadata(propertyStore, tableNameWithType, segmentName);
  jsonObj.set(STATE, JsonUtils.objectToJsonNode(realtimeSegmentZKMetadata.toMap()));
 }
 ret.add(jsonObj);
 return ret;
}