import it.unimi.dsi.fastutil.objects.Object2IntLinkedOpenHashMap; //导入依赖的package包/类
void updateFlushThresholdForSegmentMetadata(LLCRealtimeSegmentZKMetadata segmentZKMetadata,
    ZNRecord partitionAssignment, int tableFlushSize) {
  // If config does not have a flush threshold, use the default.
  if (tableFlushSize < 1) {
    tableFlushSize = KafkaHighLevelStreamProviderConfig.getDefaultMaxRealtimeRowsCount();
  }

  // Gather list of instances for this partition
  Object2IntMap<String> partitionCountForInstance = new Object2IntLinkedOpenHashMap<>();
  String segmentPartitionId = new LLCSegmentName(segmentZKMetadata.getSegmentName()).getPartitionRange();
  for (String instanceName : partitionAssignment.getListField(segmentPartitionId)) {
    partitionCountForInstance.put(instanceName, 0);
  }

  // Find the maximum number of partitions served for each instance that is serving this segment
  int maxPartitionCountPerInstance = 1;
  for (Map.Entry<String, List<String>> partitionAndInstanceList : partitionAssignment.getListFields().entrySet()) {
    for (String instance : partitionAndInstanceList.getValue()) {
      if (partitionCountForInstance.containsKey(instance)) {
        int partitionCountForThisInstance = partitionCountForInstance.getInt(instance);
        partitionCountForThisInstance++;
        partitionCountForInstance.put(instance, partitionCountForThisInstance);

        if (maxPartitionCountPerInstance < partitionCountForThisInstance) {
          maxPartitionCountPerInstance = partitionCountForThisInstance;
        }
      }
    }
  }

  // Configure the segment size flush limit based on the maximum number of partitions allocated to a replica
  int segmentFlushSize = (int) (((float) tableFlushSize) / maxPartitionCountPerInstance);
  segmentZKMetadata.setSizeThresholdToFlushSegment(segmentFlushSize);
}
 

import it.unimi.dsi.fastutil.objects.Object2IntLinkedOpenHashMap; //导入依赖的package包/类
private static <T> Object2IntMap<T> createObject2IntMap() {
  Object2IntMap<T> result = new Object2IntLinkedOpenHashMap<>();
  result.defaultReturnValue(NOT_KNOWN);
  return result;
}
 

import it.unimi.dsi.fastutil.objects.Object2IntLinkedOpenHashMap; //导入依赖的package包/类
/**
 * Gets the type to field to index map.
 * @return The type to field to index map.
 */
public Map<Type, Object2IntLinkedOpenHashMap<String>> getTypeToFieldToIndex()
{
  return typeToFieldToIndex;
}
 

import it.unimi.dsi.fastutil.objects.Object2IntLinkedOpenHashMap; //导入依赖的package包/类
public Fresh() {
    counters = new Object2IntLinkedOpenHashMap<>();
}
 

import it.unimi.dsi.fastutil.objects.Object2IntLinkedOpenHashMap; //导入依赖的package包/类
/**
 * Gets the mapping from the type of a field to the number of values to store for that type.
 * The number of of values to store for a type is usually the number of fields of that type,
 * but if there is type compression enabled for a type, the number of values to store for
 * that type will be 1.
 * @return A map from a type to the number of values to store for that type.
 */
public Object2IntLinkedOpenHashMap<Type> getTypeToSize()
{
  return typeToSize;
}