- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.removeResourceConfigFromPropertyStore()
方法的一些代码示例,展示了ZKMetadataProvider.removeResourceConfigFromPropertyStore()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKMetadataProvider.removeResourceConfigFromPropertyStore()
方法的具体详情如下:
包路径:org.apache.pinot.common.metadata.ZKMetadataProvider
类名称:ZKMetadataProvider
方法名:removeResourceConfigFromPropertyStore
暂无
代码示例来源:origin: apache/incubator-pinot
@AfterMethod
public void afterMethod() {
if (_helixManager instanceof FakeHelixManager) {
_testPropertyStore.reset();
ZKMetadataProvider.removeResourceConfigFromPropertyStore(_testPropertyStore, OFFLINE_TABLE_NAME);
ZKMetadataProvider.removeResourceConfigFromPropertyStore(_testPropertyStore, REALTIME_TABLE_NAME);
}
_tableQueryQuotaManager.cleanUpRateLimiterMap();
}
代码示例来源:origin: apache/incubator-pinot
/**
* Drop the table from helix cluster.
*
* @param tableName: Name of table to be dropped.
* @return
*/
public PinotResourceManagerResponse dropTable(String tableName) {
if (!_helixAdmin.getResourcesInCluster(_helixClusterName).contains(tableName)) {
return PinotResourceManagerResponse.failure("Table " + tableName + " not found");
}
if (getSegmentsFor(tableName).size() != 0) {
return PinotResourceManagerResponse.failure("Table " + tableName + " has segments, drop them first");
}
_helixAdmin.dropResource(_helixClusterName, tableName);
// remove from property store
ZKMetadataProvider.removeResourceSegmentsFromPropertyStore(getPropertyStore(), tableName);
ZKMetadataProvider.removeResourceConfigFromPropertyStore(getPropertyStore(), tableName);
return PinotResourceManagerResponse.success("Table " + tableName + " dropped");
}
代码示例来源:origin: apache/incubator-pinot
public void deleteOfflineTable(String tableName) {
String offlineTableName = TableNameBuilder.OFFLINE.tableNameWithType(tableName);
// Remove the table from brokerResource
HelixHelper.removeResourceFromBrokerIdealState(_helixZkManager, offlineTableName);
// Drop the table
if (_helixAdmin.getResourcesInCluster(_helixClusterName).contains(offlineTableName)) {
_helixAdmin.dropResource(_helixClusterName, offlineTableName);
}
// Remove all segments for the table
_segmentDeletionManager.removeSegmentsFromStore(offlineTableName, getSegmentsFor(offlineTableName));
ZKMetadataProvider.removeResourceSegmentsFromPropertyStore(_propertyStore, offlineTableName);
// Remove table config
ZKMetadataProvider.removeResourceConfigFromPropertyStore(_propertyStore, offlineTableName);
// Remove replica group partition assignment
ZKMetadataProvider.removeInstancePartitionAssignmentFromPropertyStore(_propertyStore, offlineTableName);
}
代码示例来源:origin: apache/incubator-pinot
public void deleteRealtimeTable(String tableName) {
String realtimeTableName = TableNameBuilder.REALTIME.tableNameWithType(tableName);
// Remove the table from brokerResource
HelixHelper.removeResourceFromBrokerIdealState(_helixZkManager, realtimeTableName);
// Cache the state and drop the table
Set<String> instancesForTable = null;
if (_helixAdmin.getResourcesInCluster(_helixClusterName).contains(realtimeTableName)) {
instancesForTable = getAllInstancesForTable(realtimeTableName);
_helixAdmin.dropResource(_helixClusterName, realtimeTableName);
}
// Remove all segments for the table
_segmentDeletionManager.removeSegmentsFromStore(realtimeTableName, getSegmentsFor(realtimeTableName));
ZKMetadataProvider.removeResourceSegmentsFromPropertyStore(_propertyStore, realtimeTableName);
// Remove table config
ZKMetadataProvider.removeResourceConfigFromPropertyStore(_propertyStore, realtimeTableName);
// Remove groupId/PartitionId mapping for HLC table
if (instancesForTable != null) {
for (String instance : instancesForTable) {
InstanceZKMetadata instanceZKMetadata = ZKMetadataProvider.getInstanceZKMetadata(_propertyStore, instance);
if (instanceZKMetadata != null) {
instanceZKMetadata.removeResource(realtimeTableName);
ZKMetadataProvider.setInstanceZKMetadata(_propertyStore, instanceZKMetadata);
}
}
}
}
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.removeResourceConfigFromPropertyStore(
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.constructPropertyStorePathForResourceC
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.removeResourceConfigFromPropertyStore(
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.constructPropertyStorePathForResourceC
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getRealtimeTableConfig()方法的一些代码示例,展示了Z
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.setRealtimeTableConfig()方法的一些代码示例,展示了Z
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getOfflineTableConfig()方法的一些代码示例,展示了ZK
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getSchema()方法的一些代码示例,展示了ZKMetadataProv
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getInstanceZKMetadata()方法的一些代码示例,展示了ZK
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.constructPropertyStorePathForSchema()方
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getClusterTenantIsolationEnabled()方法的一
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.constructPropertyStorePathForResource(
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.setRealtimeSegmentZKMetadata()方法的一些代码示
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getOfflineSegmentZKMetadata()方法的一些代码示例
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.setOfflineSegmentZKMetadata()方法的一些代码示例
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getTableSchema()方法的一些代码示例,展示了ZKMetadat
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.constructPropertyStorePathForSegment()
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getRealtimeSegmentZKMetadata()方法的一些代码示
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getOfflineSegmentZKMetadataListForTabl
本文整理了Java中org.apache.pinot.common.metadata.ZKMetadataProvider.getTableConfig()方法的一些代码示例,展示了ZKMetadat
我是一名优秀的程序员,十分优秀!