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

ZKMetadataProvider.constructPropertyStorePathForResource介绍

暂无

代码示例

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

private List<String> getSegmentNames(String tableName) {
 return _propertyStore.getChildNames(ZKMetadataProvider.constructPropertyStorePathForResource(tableName), 0);
}

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

protected List<String> getExistingSegments(String realtimeTableName) {
 String propStorePath = ZKMetadataProvider.constructPropertyStorePathForResource(realtimeTableName);
 return _propertyStore.getChildNames(propStorePath, AccessOption.PERSISTENT);
}

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

public static void removeResourceSegmentsFromPropertyStore(ZkHelixPropertyStore<ZNRecord> propertyStore,
  String resourceName) {
 String propertyStorePath = constructPropertyStorePathForResource(resourceName);
 if (propertyStore.exists(propertyStorePath, AccessOption.PERSISTENT)) {
  propertyStore.remove(propertyStorePath, AccessOption.PERSISTENT);
 }
}

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

/**
 * Returns the segments for the given table.
 *
 * @param propertyStore Helix property store
 * @param tableNameWithType Table name with type suffix
 * @return List of segment names
 */
public static List<String> getSegments(ZkHelixPropertyStore<ZNRecord> propertyStore, String tableNameWithType) {
 String segmentsPath = constructPropertyStorePathForResource(tableNameWithType);
 if (propertyStore.exists(segmentsPath, AccessOption.PERSISTENT)) {
  return propertyStore.getChildNames(segmentsPath, AccessOption.PERSISTENT);
 } else {
  return Collections.emptyList();
 }
}

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

/**
 * NOTE: this method is very expensive, use {@link #getSegments(ZkHelixPropertyStore, String)} instead if only segment
 * segment names are needed.
 */
public static List<OfflineSegmentZKMetadata> getOfflineSegmentZKMetadataListForTable(
  ZkHelixPropertyStore<ZNRecord> propertyStore, String tableName) {
 List<OfflineSegmentZKMetadata> resultList = new ArrayList<>();
 if (propertyStore == null) {
  return resultList;
 }
 String offlineTableName = TableNameBuilder.OFFLINE.tableNameWithType(tableName);
 if (propertyStore.exists(constructPropertyStorePathForResource(offlineTableName), AccessOption.PERSISTENT)) {
  List<ZNRecord> znRecordList = propertyStore
    .getChildren(constructPropertyStorePathForResource(offlineTableName), null, AccessOption.PERSISTENT);
  if (znRecordList != null) {
   for (ZNRecord record : znRecordList) {
    resultList.add(new OfflineSegmentZKMetadata(record));
   }
  }
 }
 return resultList;
}

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

/**
 * NOTE: this method is very expensive, use {@link #getSegments(ZkHelixPropertyStore, String)} instead if only segment
 * segment names are needed.
 */
public static List<RealtimeSegmentZKMetadata> getRealtimeSegmentZKMetadataListForTable(
  ZkHelixPropertyStore<ZNRecord> propertyStore, String resourceName) {
 List<RealtimeSegmentZKMetadata> resultList = new ArrayList<>();
 if (propertyStore == null) {
  return resultList;
 }
 String realtimeTableName = TableNameBuilder.REALTIME.tableNameWithType(resourceName);
 if (propertyStore.exists(constructPropertyStorePathForResource(realtimeTableName), AccessOption.PERSISTENT)) {
  List<ZNRecord> znRecordList = propertyStore
    .getChildren(constructPropertyStorePathForResource(realtimeTableName), null, AccessOption.PERSISTENT);
  if (znRecordList != null) {
   for (ZNRecord record : znRecordList) {
    resultList.add(new RealtimeSegmentZKMetadata(record));
   }
  }
 }
 return resultList;
}

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

/**
 * Returns the LLC realtime segments for the given table.
 *
 * @param propertyStore Helix property store
 * @param realtimeTableName Realtime table name
 * @return List of LLC realtime segment names
 */
public static List<String> getLLCRealtimeSegments(ZkHelixPropertyStore<ZNRecord> propertyStore,
  String realtimeTableName) {
 List<String> llcRealtimeSegments = new ArrayList<>();
 String segmentsPath = constructPropertyStorePathForResource(realtimeTableName);
 if (propertyStore.exists(segmentsPath, AccessOption.PERSISTENT)) {
  List<String> segments = propertyStore.getChildNames(segmentsPath, AccessOption.PERSISTENT);
  for (String segment : segments) {
   if (SegmentName.isLowLevelConsumerSegmentName(segment)) {
    llcRealtimeSegments.add(segment);
   }
  }
 }
 return llcRealtimeSegments;
}

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

private void createHelixEntriesForHighLevelConsumer(TableConfig config, String realtimeTableName,
  IdealState idealState) {
 if (idealState == null) {
  idealState = PinotTableIdealStateBuilder
    .buildInitialHighLevelRealtimeIdealStateFor(realtimeTableName, config, _helixZkManager, _propertyStore,
      _enableBatchMessageMode);
  LOGGER.info("Adding helix resource with empty HLC IdealState for {}", realtimeTableName);
  _helixAdmin.addResource(_helixClusterName, realtimeTableName, idealState);
 } else {
  // TODO jfim: We get in this block if we're trying to add a HLC or it already exists. If it doesn't already exist, we need to set instance configs properly (which is done in buildInitialHighLevelRealtimeIdealState, surprisingly enough). For now, do nothing.
  LOGGER.info("Not reconfiguring HLC for table {}", realtimeTableName);
 }
 LOGGER.info("Successfully created empty ideal state for  high level consumer for {} ", realtimeTableName);
 // Finally, create the propertystore entry that will trigger watchers to create segments
 String tablePropertyStorePath = ZKMetadataProvider.constructPropertyStorePathForResource(realtimeTableName);
 if (!_propertyStore.exists(tablePropertyStorePath, AccessOption.PERSISTENT)) {
  _propertyStore.create(tablePropertyStorePath, new ZNRecord(realtimeTableName), AccessOption.PERSISTENT);
 }
}

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

/**
 * NOTE: this method is very expensive, use {@link #getLLCRealtimeSegments(ZkHelixPropertyStore, String)} instead if
 * only segment names are needed.
 */
public static List<LLCRealtimeSegmentZKMetadata> getLLCRealtimeSegmentZKMetadataListForTable(
  ZkHelixPropertyStore<ZNRecord> propertyStore, String resourceName) {
 List<LLCRealtimeSegmentZKMetadata> resultList = new ArrayList<>();
 if (propertyStore == null) {
  return resultList;
 }
 String realtimeTableName = TableNameBuilder.REALTIME.tableNameWithType(resourceName);
 if (propertyStore.exists(constructPropertyStorePathForResource(realtimeTableName), AccessOption.PERSISTENT)) {
  List<ZNRecord> znRecordList = propertyStore
    .getChildren(constructPropertyStorePathForResource(realtimeTableName), null, AccessOption.PERSISTENT);
  if (znRecordList != null) {
   for (ZNRecord record : znRecordList) {
    RealtimeSegmentZKMetadata realtimeSegmentZKMetadata = new RealtimeSegmentZKMetadata(record);
    if (SegmentName.isLowLevelConsumerSegmentName(realtimeSegmentZKMetadata.getSegmentName())) {
     resultList.add(new LLCRealtimeSegmentZKMetadata(record));
    }
   }
  }
 }
 return resultList;
}

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

.setOfflineTableConfig(_propertyStore, tableNameWithType, TableConfig.toZnRecord(tableConfig));
_propertyStore.create(ZKMetadataProvider.constructPropertyStorePathForResource(tableNameWithType),
  new ZNRecord(tableNameWithType), AccessOption.PERSISTENT);