H A D | OnDiskMergeImporter.java | 730 try (final SequentialCursor<ByteString, ByteString> cursor = 733 while (cursor.next()) 735 final ByteString key = cursor.getKey(); 736 final ByteString value = cursor.getValue(); 1977 /** A cursor de-duplicating data with the same keys from a sorted cursor. */ 1986 CollectorCursor(MeteredCursor<K, ? extends V> cursor, Collector<A, V> collector) argument 1988 this.delegate = cursor; 2074 /** Provides a globally sorted cursor from multiple sorted cursors. */ 2100 for (MeteredCursor<K, V> cursor 2667 addCursor(MeteredCursor<?, ?> cursor) argument 2679 removeCursor(MeteredCursor<?, ?> cursor) argument 3067 trackCursorProgress(final PhaseTwoProgressReporter reporter, final MeteredCursor<K, V> cursor) argument 3082 throwIfUndefined(SequentialCursor<?, ?> cursor) argument [all...] |