Toggle navigation
Home
java.util.Iterator to org.apache.hadoop.yarn.server.timeline.TimelineStoreMapAdapter.CloseableIterator
No. of Instances - 7
No. of Commits - 1
No. of Projects - {'hadoop'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Other
tempTreeSet.iterator()
to
tempTreeSet.iterator()
new TreeSet<>(internalMap.values()).iterator()
to
new TreeSet<>(internalMap.values()).iterator()
Cascading Type Change (Similar)
Iterator<V>
to
CloseableIterator<V>
Update Anonymous class
{ @Override public boolean hasNext(){ if (!internalDbIterator.hasNext()) { return false; } Map.Entry<byte[],byte[]> nextEntry=internalDbIterator.peekNext(); if (LeveldbUtils.prefixMatches(prefixBytes,prefixBytes.length,nextEntry.getKey())) { return true; } return false; } @Override public V next(){ if (hasNext()) { Map.Entry<byte[],byte[]> nextRaw=internalDbIterator.next(); try { V result=getEntityForKey(nextRaw.getKey()); return result; } catch ( IOException e) { LOG.error("GenericObjectMapper cannot read key from key " + nextRaw.getKey() + " into an object. Read aborted! "); LOG.error(e.getMessage()); } } return null; } @Override public void remove(){ LOG.error("LevelDB map adapter does not support iterate-and-remove" + " use cases. "); } }
to
{ @Override public boolean hasNext(){ if (!internalDbIterator.hasNext()) { return false; } Map.Entry<byte[],byte[]> nextEntry=internalDbIterator.peekNext(); if (LeveldbUtils.prefixMatches(prefixBytes,prefixBytes.length,nextEntry.getKey())) { return true; } return false; } @Override public V next(){ if (hasNext()) { Map.Entry<byte[],byte[]> nextRaw=internalDbIterator.next(); try { V result=getEntityForKey(nextRaw.getKey()); return result; } catch ( IOException e) { LOG.error("GenericObjectMapper cannot read key from key " + nextRaw.getKey() + " into an object. Read aborted! "); LOG.error(e.getMessage()); } } return null; } @Override public void remove(){ LOG.error("LevelDB map adapter does not support iterate-and-remove" + " use cases. "); } @Override public void close() throws IOException { internalDbIterator.close(); } }