本文整理了Java中java.util.concurrent.ConcurrentSkipListMap.values()
方法的一些代码示例,展示了ConcurrentSkipListMap.values()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ConcurrentSkipListMap.values()
方法的具体详情如下:
包路径:java.util.concurrent.ConcurrentSkipListMap
类名称:ConcurrentSkipListMap
方法名:values
[英]Lazily initialized values collection
[中]延迟初始化值集合
代码示例来源:origin: apache/hbase
Collection<RegionStateNode> getRegionStateNodes() {
return regionsMap.values();
}
代码示例来源:origin: apache/ignite
/**
* @return Current nodes in topology.
*/
@SuppressWarnings("unchecked")
List<ClusterNode> topologySnapshot() {
return new ArrayList<>((Collection)nodesByOrder.values());
}
代码示例来源:origin: apache/hbase
public List<RegionStateNode> getRegionsInTransition() {
return new ArrayList<RegionStateNode>(regionInTransition.values());
}
代码示例来源:origin: Alluxio/alluxio
/**
* Returns the children of the given inode, if the child list is cached. This method only
* consults the cache, and never looks in the backing store.
*
* @param inodeId the directory to list
* @return the children of the inode, or empty if the child list isn't cached
*/
public Optional<Collection<Long>> getCachedChildIds(Long inodeId) {
ListingCacheEntry entry = mMap.get(inodeId);
if (entry != null && entry.mChildren != null) {
entry.mReferenced = true;
return Optional.of(entry.mChildren.values());
}
return Optional.empty();
}
代码示例来源:origin: apache/hive
@Override
public void debugDumpShort(StringBuilder sb) {
sb.append("\nCache state: ");
for (TagState state : tagInfo.values()) {
synchronized (state) {
sb.append("\n").append(state.name).append(": ").append(state.bufferCount).append("/")
.append(state.maxCount).append(", ").append(state.totalSize).append("/")
.append(state.maxSize);
}
}
}
代码示例来源:origin: apache/hbase
public SortedSet<RegionState> getRegionsInTransitionOrderedByTimestamp() {
final SortedSet<RegionState> rit = new TreeSet<RegionState>(REGION_STATE_STAMP_COMPARATOR);
for (RegionStateNode node: regionInTransition.values()) {
rit.add(node.toRegionState());
}
return rit;
}
代码示例来源:origin: qunarcorp/qmq
@Override
public void flush() {
for (DelaySegment<T> segment : segments.values()) {
segment.flush();
}
}
代码示例来源:origin: qunarcorp/qmq
public void close() {
for (final LogSegment segment : segments.values()) {
segment.close();
}
}
代码示例来源:origin: apache/hbase
public Map<RegionInfo, ServerName> getRegionAssignments() {
final HashMap<RegionInfo, ServerName> assignments = new HashMap<RegionInfo, ServerName>();
for (RegionStateNode node: regionsMap.values()) {
assignments.put(node.getRegionInfo(), node.getRegionLocation());
}
return assignments;
}
代码示例来源:origin: twitter/distributedlog
private Future<List<Set<String>>> retrieveLogs() {
Collection<SubNamespace> subNss = subNamespaces.values();
List<Future<Set<String>>> logsList = Lists.newArrayListWithExpectedSize(subNss.size());
for (SubNamespace subNs : subNss) {
logsList.add(subNs.getLogs());
}
return Future.collect(logsList);
}
代码示例来源:origin: apache/hbase
public List<RegionInfo> getAssignedRegions() {
final List<RegionInfo> result = new ArrayList<RegionInfo>();
for (RegionStateNode node: regionsMap.values()) {
if (!node.isInTransition()) {
result.add(node.getRegionInfo());
}
}
return result;
}
代码示例来源:origin: apache/hbase
public ArrayList<RegionState> getRegionStates() {
final ArrayList<RegionState> regions = new ArrayList<RegionState>(regionsMap.size());
for (RegionStateNode node: regionsMap.values()) {
regions.add(node.toRegionState());
}
return regions;
}
代码示例来源:origin: apache/hbase
public List<RegionState> getRegionsStateInTransition() {
final List<RegionState> rit = new ArrayList<RegionState>(regionInTransition.size());
for (RegionStateNode node: regionInTransition.values()) {
rit.add(node.toRegionState());
}
return rit;
}
代码示例来源:origin: apache/incubator-druid
@Override
public void stop()
{
synchronized (lock) {
if (stopped) {
return;
}
stopped = true;
for (SegmentHolder holder : segmentsToDrop.values()) {
holder.requestFailed("Stopping load queue peon.");
}
for (SegmentHolder holder : segmentsToLoad.values()) {
holder.requestFailed("Stopping load queue peon.");
}
segmentsToDrop.clear();
segmentsToLoad.clear();
queuedSize.set(0L);
failedAssignCount.set(0);
}
}
代码示例来源:origin: apache/hbase
public List<RegionState> getRegionFailedOpen() {
if (regionFailedOpen.isEmpty()) return Collections.emptyList();
ArrayList<RegionState> regions = new ArrayList<RegionState>(regionFailedOpen.size());
for (RegionFailedOpen r: regionFailedOpen.values()) {
regions.add(r.getRegionStateNode().toRegionState());
}
return regions;
}
代码示例来源:origin: apache/hbase
public RegionState getRegionState(final String encodedRegionName) {
// TODO: Need a map <encodedName, ...> but it is just dispatch merge...
for (RegionStateNode node: regionsMap.values()) {
if (node.getRegionInfo().getEncodedName().equals(encodedRegionName)) {
return node.toRegionState();
}
}
return null;
}
代码示例来源:origin: apache/hbase
public Map<RegionState.State, List<RegionInfo>> getRegionByStateOfTable(TableName tableName) {
final State[] states = State.values();
final Map<RegionState.State, List<RegionInfo>> tableRegions =
new HashMap<State, List<RegionInfo>>(states.length);
for (int i = 0; i < states.length; ++i) {
tableRegions.put(states[i], new ArrayList<RegionInfo>());
}
for (RegionStateNode node: regionsMap.values()) {
if (node.getTable().equals(tableName)) {
tableRegions.get(node.getState()).add(node.getRegionInfo());
}
}
return tableRegions;
}
代码示例来源:origin: alibaba/jstorm
@Override
public Snapshot getSnapshot() {
lockForRegularUsage();
try {
return new WeightedSnapshot(values.values());
} finally {
unlockForRegularUsage();
}
}
代码示例来源:origin: qunarcorp/qmq
public void clean(LogCleaner.CleanHook hook) {
long deleteUntil = resolveSegment(System.currentTimeMillis() - config.getDispatchLogKeepTime(), segmentScale);
for (DelaySegment<Boolean> segment : segments.values()) {
if (segment.getSegmentBaseOffset() < deleteUntil) {
doClean(segment, hook);
}
}
}
代码示例来源:origin: apache/hbase
@Test
public void testValues() throws Exception {
for (Long value:m.values()) {
assertTrue(csm.values().contains(value));
assertTrue(m.containsValue(value));
}
}
内容来源于网络,如有侵权,请联系作者删除!