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

ZKMetadataProvider.setRealtimeTableConfig介绍

暂无

代码示例

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

public void setExistingTableConfig(TableConfig config, String tableNameWithType, TableType type)
  throws IOException {
 if (type == TableType.REALTIME) {
  ZKMetadataProvider.setRealtimeTableConfig(_propertyStore, tableNameWithType, TableConfig.toZnRecord(config));
  ensureRealtimeClusterIsSetUp(config, tableNameWithType, config.getIndexingConfig());
 } else if (type == TableType.OFFLINE) {
  // Update replica group partition assignment to the property store if applicable
  updateReplicaGroupPartitionAssignment(config);
  ZKMetadataProvider.setOfflineTableConfig(_propertyStore, tableNameWithType, TableConfig.toZnRecord(config));
  IdealState idealState = _helixAdmin.getResourceIdealState(_helixClusterName, tableNameWithType);
  final String configReplication = config.getValidationConfig().getReplication();
  if (configReplication != null && !config.getValidationConfig().getReplication()
    .equals(idealState.getReplicas())) {
   HelixHelper.updateIdealState(_helixZkManager, tableNameWithType, new Function<IdealState, IdealState>() {
    @Nullable
    @Override
    public IdealState apply(@Nullable IdealState idealState) {
     idealState.setReplicas(configReplication);
     return idealState;
    }
   }, RetryPolicies.exponentialBackoffRetryPolicy(5, 1000L, 1.2f));
  }
 }
}

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

.setRealtimeTableConfig(_propertyStore, tableNameWithType, TableConfig.toZnRecord(tableConfig));

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

@Test
public void testOfflineTableWithNullQuotaButWithRealtimeTableConfigNullQpsConfig()
  throws Exception {
 QuotaConfig quotaConfig = new QuotaConfig();
 quotaConfig.setStorage("6G");
 TableConfig realtimeTableConfig =
   new TableConfig.Builder(TableType.REALTIME).setTableName(RAW_TABLE_NAME).setQuotaConfig(quotaConfig)
     .setRetentionTimeUnit("DAYS").setRetentionTimeValue("1").setSegmentPushType("APPEND")
     .setBrokerTenant("testBroker").setServerTenant("testServer").build();
 ZKMetadataProvider
   .setRealtimeTableConfig(_testPropertyStore, REALTIME_TABLE_NAME, TableConfig.toZnRecord(realtimeTableConfig));
 ExternalView brokerResource = generateBrokerResource(OFFLINE_TABLE_NAME);
 TableConfig tableConfig = generateDefaultTableConfig(OFFLINE_TABLE_NAME);
 _tableQueryQuotaManager.initTableQueryQuota(tableConfig, brokerResource);
 Assert.assertEquals(_tableQueryQuotaManager.getRateLimiterMapSize(), 0);
 // Nothing happened since it doesn't have qps quota.
 _tableQueryQuotaManager.dropTableQueryQuota(OFFLINE_TABLE_NAME);
 Assert.assertEquals(_tableQueryQuotaManager.getRateLimiterMapSize(), 0);
}

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

@Test
public void testOfflineTableWithNullQuotaButWithRealtimeTableConfigNotNullQpsConfig()
  throws Exception {
 QuotaConfig quotaConfig = new QuotaConfig();
 quotaConfig.setStorage("6G");
 quotaConfig.setMaxQueriesPerSecond("100.00");
 TableConfig realtimeTableConfig =
   new TableConfig.Builder(TableType.REALTIME).setTableName(RAW_TABLE_NAME).setQuotaConfig(quotaConfig)
     .setRetentionTimeUnit("DAYS").setRetentionTimeValue("1").setSegmentPushType("APPEND")
     .setBrokerTenant("testBroker").setServerTenant("testServer").build();
 ZKMetadataProvider
   .setRealtimeTableConfig(_testPropertyStore, REALTIME_TABLE_NAME, TableConfig.toZnRecord(realtimeTableConfig));
 ExternalView brokerResource = generateBrokerResource(REALTIME_TABLE_NAME);
 TableConfig tableConfig = generateDefaultTableConfig(OFFLINE_TABLE_NAME);
 _tableQueryQuotaManager.initTableQueryQuota(tableConfig, brokerResource);
 Assert.assertEquals(_tableQueryQuotaManager.getRateLimiterMapSize(), 0);
 // Drop the offline table won't have any affect since it is table type specific.
 _tableQueryQuotaManager.dropTableQueryQuota(OFFLINE_TABLE_NAME);
 Assert.assertEquals(_tableQueryQuotaManager.getRateLimiterMapSize(), 0);
}

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

.setRealtimeTableConfig(_testPropertyStore, REALTIME_TABLE_NAME, TableConfig.toZnRecord(realtimeTableConfig));
ZKMetadataProvider
  .setOfflineTableConfig(_testPropertyStore, OFFLINE_TABLE_NAME, TableConfig.toZnRecord(offlineTableConfig));