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

ZKMetadataProvider.getOfflineTableConfig介绍

暂无

代码示例

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

/**
 * Get the offline table config for the given table name.
 *
 * @param tableName Table name with or without type suffix
 * @return Table config
 */
@Nullable
public TableConfig getOfflineTableConfig(@Nonnull String tableName) {
 return ZKMetadataProvider.getOfflineTableConfig(_propertyStore, tableName);
}

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

TableConfig tableConfig = ZKMetadataProvider.getOfflineTableConfig(_propertyStore, rawTableName);
Preconditions.checkNotNull(tableConfig);

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

/**
 * Get all the broker instances for the given table name.
 *
 * @param tableName Table name with or without type suffix
 * @return List of broker instance Ids
 */
@Nonnull
public List<String> getBrokerInstancesFor(@Nonnull String tableName) {
 String brokerTenantName = null;
 TableConfig offlineTableConfig = ZKMetadataProvider.getOfflineTableConfig(_propertyStore, tableName);
 if (offlineTableConfig != null) {
  brokerTenantName = offlineTableConfig.getTenantConfig().getBroker();
 } else {
  TableConfig realtimeTableConfig = ZKMetadataProvider.getRealtimeTableConfig(_propertyStore, tableName);
  if (realtimeTableConfig != null) {
   brokerTenantName = realtimeTableConfig.getTenantConfig().getBroker();
  }
 }
 return HelixHelper.getInstancesWithTag(_helixZkManager, TagNameUtils.getBrokerTagForTenant(brokerTenantName));
}

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

final TableConfig offlineTableConfig = ZKMetadataProvider.getOfflineTableConfig(propertyStore, offlineTableName);
final int newNumReplicas = Integer.parseInt(offlineTableConfig.getValidationConfig().getReplication());

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

TableConfig offlineTableConfig = ZKMetadataProvider.getOfflineTableConfig(_propertyStore, tableName);
assert offlineTableConfig != null;
String timeType = offlineTableConfig.getValidationConfig().getTimeType();

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

LinkedHashMap<String, Integer> states = new LinkedHashMap<>();
int numReplicasInIdealState = Integer.parseInt(currentIdealState.getReplicas());
final TableConfig offlineTableConfig = ZKMetadataProvider.getOfflineTableConfig(propertyStore, tableName);
final int numReplicasInTableConfig = Integer.parseInt(offlineTableConfig.getValidationConfig().getReplication());

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

/**
 * Helper method to add the passed in offline segment to the helix cluster.
 * - Gets the segment name and the table name from the passed in segment meta-data.
 * - Identifies the instance set onto which the segment needs to be added, based on
 *   segment assignment strategy and replicas in the table config in the property-store.
 * - Updates ideal state such that the new segment is assigned to required set of instances as per
 *    the segment assignment strategy and replicas.
 *
 * @param segmentMetadata Meta-data for the segment, used to access segmentName and tableName.
 */
// NOTE: method should be thread-safe
private void addNewOfflineSegment(SegmentMetadata segmentMetadata) {
 String offlineTableName = TableNameBuilder.OFFLINE.tableNameWithType(segmentMetadata.getTableName());
 String segmentName = segmentMetadata.getName();
 // Assign new segment to instances
 TableConfig offlineTableConfig = ZKMetadataProvider.getOfflineTableConfig(_propertyStore, offlineTableName);
 Preconditions.checkNotNull(offlineTableConfig);
 int numReplicas = Integer.parseInt(offlineTableConfig.getValidationConfig().getReplication());
 String serverTenant = TagNameUtils.getOfflineTagForTenant(offlineTableConfig.getTenantConfig().getServer());
 SegmentAssignmentStrategy segmentAssignmentStrategy = SegmentAssignmentStrategyFactory
   .getSegmentAssignmentStrategy(offlineTableConfig.getValidationConfig().getSegmentAssignmentStrategy());
 List<String> assignedInstances = segmentAssignmentStrategy
   .getAssignedInstances(_helixZkManager, _helixAdmin, _propertyStore, _helixClusterName, segmentMetadata,
     numReplicas, serverTenant);
 HelixHelper.addSegmentToIdealState(_helixZkManager, offlineTableName, segmentName, assignedInstances);
}

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

String segmentName = segmentMetadata.getName();
TableConfig offlineTableConfig =
  ZKMetadataProvider.getOfflineTableConfig(_pinotHelixResourceManager.getPropertyStore(), offlineTableName);