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

ZkHelixPropertyStore.exists介绍

暂无

代码示例

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

public boolean exist(String path) {
 return propertyStore.exists(pathPrefix + "/" + path, AccessOption.PERSISTENT);
}

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

public static boolean isSegmentExisted(ZkHelixPropertyStore<ZNRecord> propertyStore, String resourceNameForResource,
  String segmentName) {
 return propertyStore
   .exists(constructPropertyStorePathForSegment(resourceNameForResource, segmentName), AccessOption.PERSISTENT);
}

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

public static void removeResourceConfigFromPropertyStore(ZkHelixPropertyStore<ZNRecord> propertyStore,
  String resourceName) {
 String propertyStorePath = constructPropertyStorePathForResourceConfig(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

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

public static void removeInstancePartitionAssignmentFromPropertyStore(ZkHelixPropertyStore<ZNRecord> propertyStore,
  String offlineTableName) {
 String propertyStorePath = constructPropertyStorePathForInstancePartitions(offlineTableName);
 if (propertyStore.exists(propertyStorePath, AccessOption.PERSISTENT)) {
  propertyStore.remove(propertyStorePath, AccessOption.PERSISTENT);
 }
}

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

public static boolean getClusterTenantIsolationEnabled(ZkHelixPropertyStore<ZNRecord> propertyStore) {
  String controllerConfigPath = constructPropertyStorePathForControllerConfig(CLUSTER_TENANT_ISOLATION_ENABLED_KEY);
  if (propertyStore.exists(controllerConfigPath, AccessOption.PERSISTENT)) {
   ZNRecord znRecord = propertyStore.get(controllerConfigPath, null, AccessOption.PERSISTENT);
   if (znRecord.getSimpleFields().keySet().contains(CLUSTER_TENANT_ISOLATION_ENABLED_KEY)) {
    return znRecord.getBooleanField(CLUSTER_TENANT_ISOLATION_ENABLED_KEY, true);
   } else {
    return true;
   }
  } else {
   return true;
  }
 }
}

代码示例来源：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

if (!deleteSuccessful[i]) {
 if (_propertyStore.exists(propStorePathList.get(i), AccessOption.PERSISTENT)) {
  LOGGER.info("Could not delete {} from propertystore", propStorePathList.get(i));
  segmentsToRetryLater.add(segmentId);

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

/**
 * Delete the given schema.
 * @param schema The schema to be deleted.
 * @return True on success, false otherwise.
 */
public boolean deleteSchema(Schema schema) {
 if (schema != null) {
  String propertyStorePath = ZKMetadataProvider.constructPropertyStorePathForSchema(schema.getSchemaName());
  if (_propertyStore.exists(propertyStorePath, AccessOption.PERSISTENT)) {
   _propertyStore.remove(propertyStorePath, AccessOption.PERSISTENT);
   return true;
  }
 }
 return false;
}

代码示例来源：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

/**
 * 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

public static void setClusterTenantIsolationEnabled(ZkHelixPropertyStore<ZNRecord> propertyStore,
  boolean isSingleTenantCluster) {
 final ZNRecord znRecord;
 final String path = constructPropertyStorePathForControllerConfig(CLUSTER_TENANT_ISOLATION_ENABLED_KEY);
 if (!propertyStore.exists(path, AccessOption.PERSISTENT)) {
  znRecord = new ZNRecord(CLUSTER_TENANT_ISOLATION_ENABLED_KEY);
 } else {
  znRecord = propertyStore.get(path, null, AccessOption.PERSISTENT);
 }
 znRecord.setBooleanField(CLUSTER_TENANT_ISOLATION_ENABLED_KEY, isSingleTenantCluster);
 propertyStore.set(path, znRecord, AccessOption.PERSISTENT);
}

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

when(store.exists(anyString(), anyInt())).thenReturn(true);
return store;

代码示例来源：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

assertFalse(_propertyStore.exists(instancePath, 0));
assertFalse(_propertyStore.exists(configPath, 0));

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

@Override
public boolean exists(String path, int options) {
 if (_fallbackStore == null) {
  return super.exists(path, options);
 } else {
  boolean exist = super.exists(path, options);
  if (!exist) {
   exist = _fallbackStore.exists(path, options);
  }
  return exist;
 }
}

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

@Override
public boolean exists(String path, int options) {
 if (_fallbackStore == null) {
  return super.exists(path, options);
 } else {
  boolean exist = super.exists(path, options);
  if (!exist) {
   exist = _fallbackStore.exists(path, options);
  }
  return exist;
 }
}

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

@Override
public boolean[] exists(List<String> paths, int options) {
 if (_fallbackStore == null) {
  return super.exists(paths, options);
 } else {
  boolean[] exists = super.exists(paths, options);
  Map<String, Integer> fallbackMap = new HashMap<String, Integer>();
  for (int i = 0; i < paths.size(); i++) {
   boolean exist = exists[i];
   if (!exist) {
    fallbackMap.put(paths.get(i), i);
   }
  }
  if (fallbackMap.size() > 0) {
   List<String> fallbackPaths = new ArrayList<String>(fallbackMap.keySet());
   boolean[] fallbackExists = _fallbackStore.exists(fallbackPaths, options);
   for (int i = 0; i < fallbackPaths.size(); i++) {
    String fallbackPath = fallbackPaths.get(i);
    int j = fallbackMap.get(fallbackPath);
    exists[j] = fallbackExists[i];
   }
  }
  return exists;
 }
}