http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c91fafb4/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStore.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStore.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStore.html index 3aed8f0..16d7d26 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStore.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStore.html @@ -1746,15 +1746,15 @@ <span class="sourceLineNo">1738</span> @Override<a name="line.1738"></a> <span class="sourceLineNo">1739</span> public boolean start() throws IOException {<a name="line.1739"></a> <span class="sourceLineNo">1740</span> boolean isFirst = RUNNER_COUNT.getAndIncrement() == 0;<a name="line.1740"></a> -<span class="sourceLineNo">1741</span> boolean rval = super.start();<a name="line.1741"></a> -<span class="sourceLineNo">1742</span> if (isFirst) {<a name="line.1742"></a> -<span class="sourceLineNo">1743</span> try {<a name="line.1743"></a> -<span class="sourceLineNo">1744</span> START_COMPACTOR_LATCH.await();<a name="line.1744"></a> +<span class="sourceLineNo">1741</span> if (isFirst) {<a name="line.1741"></a> +<span class="sourceLineNo">1742</span> try {<a name="line.1742"></a> +<span class="sourceLineNo">1743</span> START_COMPACTOR_LATCH.await();<a name="line.1743"></a> +<span class="sourceLineNo">1744</span> return super.start();<a name="line.1744"></a> <span class="sourceLineNo">1745</span> } catch (InterruptedException ex) {<a name="line.1745"></a> <span class="sourceLineNo">1746</span> throw new RuntimeException(ex);<a name="line.1746"></a> <span class="sourceLineNo">1747</span> }<a name="line.1747"></a> <span class="sourceLineNo">1748</span> }<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> return rval;<a name="line.1749"></a> +<span class="sourceLineNo">1749</span> return super.start();<a name="line.1749"></a> <span class="sourceLineNo">1750</span> }<a name="line.1750"></a> <span class="sourceLineNo">1751</span> }<a name="line.1751"></a> <span class="sourceLineNo">1752</span><a name="line.1752"></a> @@ -1773,137 +1773,140 @@ <span class="sourceLineNo">1765</span> }<a name="line.1765"></a> <span class="sourceLineNo">1766</span><a name="line.1766"></a> <span class="sourceLineNo">1767</span> @Override<a name="line.1767"></a> -<span class="sourceLineNo">1768</span> void inMemoryCompaction() {<a name="line.1768"></a> -<span class="sourceLineNo">1769</span> RUNNER_COUNT.incrementAndGet();<a name="line.1769"></a> -<span class="sourceLineNo">1770</span> if (LOG.isDebugEnabled()) {<a name="line.1770"></a> -<span class="sourceLineNo">1771</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1771"></a> -<span class="sourceLineNo">1772</span> }<a name="line.1772"></a> -<span class="sourceLineNo">1773</span> super.inMemoryCompaction();<a name="line.1773"></a> -<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> -<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> -<span class="sourceLineNo">1776</span><a name="line.1776"></a> -<span class="sourceLineNo">1777</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1777"></a> -<span class="sourceLineNo">1778</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1778"></a> -<span class="sourceLineNo">1779</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1779"></a> -<span class="sourceLineNo">1780</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1780"></a> -<span class="sourceLineNo">1781</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1781"></a> -<span class="sourceLineNo">1782</span> HStore store, RegionServicesForStores regionServices,<a name="line.1782"></a> -<span class="sourceLineNo">1783</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1783"></a> -<span class="sourceLineNo">1784</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1784"></a> -<span class="sourceLineNo">1785</span> }<a name="line.1785"></a> -<span class="sourceLineNo">1786</span><a name="line.1786"></a> -<span class="sourceLineNo">1787</span> @Override<a name="line.1787"></a> -<span class="sourceLineNo">1788</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1788"></a> -<span class="sourceLineNo">1789</span> if (START_TEST.get()) {<a name="line.1789"></a> -<span class="sourceLineNo">1790</span> try {<a name="line.1790"></a> -<span class="sourceLineNo">1791</span> getScannerLatch.countDown();<a name="line.1791"></a> -<span class="sourceLineNo">1792</span> snapshotLatch.await();<a name="line.1792"></a> -<span class="sourceLineNo">1793</span> } catch (InterruptedException e) {<a name="line.1793"></a> -<span class="sourceLineNo">1794</span> throw new RuntimeException(e);<a name="line.1794"></a> -<span class="sourceLineNo">1795</span> }<a name="line.1795"></a> -<span class="sourceLineNo">1796</span> }<a name="line.1796"></a> -<span class="sourceLineNo">1797</span> return new ArrayList<>(capacity);<a name="line.1797"></a> -<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> -<span class="sourceLineNo">1799</span> @Override<a name="line.1799"></a> -<span class="sourceLineNo">1800</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1800"></a> -<span class="sourceLineNo">1801</span> if (START_TEST.get()) {<a name="line.1801"></a> -<span class="sourceLineNo">1802</span> try {<a name="line.1802"></a> -<span class="sourceLineNo">1803</span> getScannerLatch.await();<a name="line.1803"></a> -<span class="sourceLineNo">1804</span> } catch (InterruptedException e) {<a name="line.1804"></a> -<span class="sourceLineNo">1805</span> throw new RuntimeException(e);<a name="line.1805"></a> -<span class="sourceLineNo">1806</span> }<a name="line.1806"></a> -<span class="sourceLineNo">1807</span> }<a name="line.1807"></a> -<span class="sourceLineNo">1808</span><a name="line.1808"></a> -<span class="sourceLineNo">1809</span> super.pushActiveToPipeline(active);<a name="line.1809"></a> -<span class="sourceLineNo">1810</span> if (START_TEST.get()) {<a name="line.1810"></a> -<span class="sourceLineNo">1811</span> snapshotLatch.countDown();<a name="line.1811"></a> -<span class="sourceLineNo">1812</span> }<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> }<a name="line.1813"></a> -<span class="sourceLineNo">1814</span> }<a name="line.1814"></a> -<span class="sourceLineNo">1815</span><a name="line.1815"></a> -<span class="sourceLineNo">1816</span> interface MyListHook {<a name="line.1816"></a> -<span class="sourceLineNo">1817</span> void hook(int currentSize);<a name="line.1817"></a> -<span class="sourceLineNo">1818</span> }<a name="line.1818"></a> -<span class="sourceLineNo">1819</span><a name="line.1819"></a> -<span class="sourceLineNo">1820</span> private static class MyList<T> implements List<T> {<a name="line.1820"></a> -<span class="sourceLineNo">1821</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1821"></a> -<span class="sourceLineNo">1822</span> private final MyListHook hookAtAdd;<a name="line.1822"></a> -<span class="sourceLineNo">1823</span> MyList(final MyListHook hookAtAdd) {<a name="line.1823"></a> -<span class="sourceLineNo">1824</span> this.hookAtAdd = hookAtAdd;<a name="line.1824"></a> -<span class="sourceLineNo">1825</span> }<a name="line.1825"></a> -<span class="sourceLineNo">1826</span> @Override<a name="line.1826"></a> -<span class="sourceLineNo">1827</span> public int size() {return delegatee.size();}<a name="line.1827"></a> -<span class="sourceLineNo">1828</span><a name="line.1828"></a> +<span class="sourceLineNo">1768</span> protected boolean setInMemoryCompactionFlag() {<a name="line.1768"></a> +<span class="sourceLineNo">1769</span> boolean rval = super.setInMemoryCompactionFlag();<a name="line.1769"></a> +<span class="sourceLineNo">1770</span> if (rval) {<a name="line.1770"></a> +<span class="sourceLineNo">1771</span> RUNNER_COUNT.incrementAndGet();<a name="line.1771"></a> +<span class="sourceLineNo">1772</span> if (LOG.isDebugEnabled()) {<a name="line.1772"></a> +<span class="sourceLineNo">1773</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1773"></a> +<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> +<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> +<span class="sourceLineNo">1776</span> return rval;<a name="line.1776"></a> +<span class="sourceLineNo">1777</span> }<a name="line.1777"></a> +<span class="sourceLineNo">1778</span> }<a name="line.1778"></a> +<span class="sourceLineNo">1779</span><a name="line.1779"></a> +<span class="sourceLineNo">1780</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1780"></a> +<span class="sourceLineNo">1781</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1781"></a> +<span class="sourceLineNo">1782</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1782"></a> +<span class="sourceLineNo">1783</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1783"></a> +<span class="sourceLineNo">1784</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1784"></a> +<span class="sourceLineNo">1785</span> HStore store, RegionServicesForStores regionServices,<a name="line.1785"></a> +<span class="sourceLineNo">1786</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1786"></a> +<span class="sourceLineNo">1787</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1787"></a> +<span class="sourceLineNo">1788</span> }<a name="line.1788"></a> +<span class="sourceLineNo">1789</span><a name="line.1789"></a> +<span class="sourceLineNo">1790</span> @Override<a name="line.1790"></a> +<span class="sourceLineNo">1791</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1791"></a> +<span class="sourceLineNo">1792</span> if (START_TEST.get()) {<a name="line.1792"></a> +<span class="sourceLineNo">1793</span> try {<a name="line.1793"></a> +<span class="sourceLineNo">1794</span> getScannerLatch.countDown();<a name="line.1794"></a> +<span class="sourceLineNo">1795</span> snapshotLatch.await();<a name="line.1795"></a> +<span class="sourceLineNo">1796</span> } catch (InterruptedException e) {<a name="line.1796"></a> +<span class="sourceLineNo">1797</span> throw new RuntimeException(e);<a name="line.1797"></a> +<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> +<span class="sourceLineNo">1799</span> }<a name="line.1799"></a> +<span class="sourceLineNo">1800</span> return new ArrayList<>(capacity);<a name="line.1800"></a> +<span class="sourceLineNo">1801</span> }<a name="line.1801"></a> +<span class="sourceLineNo">1802</span> @Override<a name="line.1802"></a> +<span class="sourceLineNo">1803</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1803"></a> +<span class="sourceLineNo">1804</span> if (START_TEST.get()) {<a name="line.1804"></a> +<span class="sourceLineNo">1805</span> try {<a name="line.1805"></a> +<span class="sourceLineNo">1806</span> getScannerLatch.await();<a name="line.1806"></a> +<span class="sourceLineNo">1807</span> } catch (InterruptedException e) {<a name="line.1807"></a> +<span class="sourceLineNo">1808</span> throw new RuntimeException(e);<a name="line.1808"></a> +<span class="sourceLineNo">1809</span> }<a name="line.1809"></a> +<span class="sourceLineNo">1810</span> }<a name="line.1810"></a> +<span class="sourceLineNo">1811</span><a name="line.1811"></a> +<span class="sourceLineNo">1812</span> super.pushActiveToPipeline(active);<a name="line.1812"></a> +<span class="sourceLineNo">1813</span> if (START_TEST.get()) {<a name="line.1813"></a> +<span class="sourceLineNo">1814</span> snapshotLatch.countDown();<a name="line.1814"></a> +<span class="sourceLineNo">1815</span> }<a name="line.1815"></a> +<span class="sourceLineNo">1816</span> }<a name="line.1816"></a> +<span class="sourceLineNo">1817</span> }<a name="line.1817"></a> +<span class="sourceLineNo">1818</span><a name="line.1818"></a> +<span class="sourceLineNo">1819</span> interface MyListHook {<a name="line.1819"></a> +<span class="sourceLineNo">1820</span> void hook(int currentSize);<a name="line.1820"></a> +<span class="sourceLineNo">1821</span> }<a name="line.1821"></a> +<span class="sourceLineNo">1822</span><a name="line.1822"></a> +<span class="sourceLineNo">1823</span> private static class MyList<T> implements List<T> {<a name="line.1823"></a> +<span class="sourceLineNo">1824</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1824"></a> +<span class="sourceLineNo">1825</span> private final MyListHook hookAtAdd;<a name="line.1825"></a> +<span class="sourceLineNo">1826</span> MyList(final MyListHook hookAtAdd) {<a name="line.1826"></a> +<span class="sourceLineNo">1827</span> this.hookAtAdd = hookAtAdd;<a name="line.1827"></a> +<span class="sourceLineNo">1828</span> }<a name="line.1828"></a> <span class="sourceLineNo">1829</span> @Override<a name="line.1829"></a> -<span class="sourceLineNo">1830</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1830"></a> +<span class="sourceLineNo">1830</span> public int size() {return delegatee.size();}<a name="line.1830"></a> <span class="sourceLineNo">1831</span><a name="line.1831"></a> <span class="sourceLineNo">1832</span> @Override<a name="line.1832"></a> -<span class="sourceLineNo">1833</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1833"></a> +<span class="sourceLineNo">1833</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1833"></a> <span class="sourceLineNo">1834</span><a name="line.1834"></a> <span class="sourceLineNo">1835</span> @Override<a name="line.1835"></a> -<span class="sourceLineNo">1836</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1836"></a> +<span class="sourceLineNo">1836</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1836"></a> <span class="sourceLineNo">1837</span><a name="line.1837"></a> <span class="sourceLineNo">1838</span> @Override<a name="line.1838"></a> -<span class="sourceLineNo">1839</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1839"></a> +<span class="sourceLineNo">1839</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1839"></a> <span class="sourceLineNo">1840</span><a name="line.1840"></a> <span class="sourceLineNo">1841</span> @Override<a name="line.1841"></a> -<span class="sourceLineNo">1842</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1842"></a> +<span class="sourceLineNo">1842</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1842"></a> <span class="sourceLineNo">1843</span><a name="line.1843"></a> <span class="sourceLineNo">1844</span> @Override<a name="line.1844"></a> -<span class="sourceLineNo">1845</span> public boolean add(T e) {<a name="line.1845"></a> -<span class="sourceLineNo">1846</span> hookAtAdd.hook(size());<a name="line.1846"></a> -<span class="sourceLineNo">1847</span> return delegatee.add(e);<a name="line.1847"></a> -<span class="sourceLineNo">1848</span> }<a name="line.1848"></a> -<span class="sourceLineNo">1849</span><a name="line.1849"></a> -<span class="sourceLineNo">1850</span> @Override<a name="line.1850"></a> -<span class="sourceLineNo">1851</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1851"></a> +<span class="sourceLineNo">1845</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1845"></a> +<span class="sourceLineNo">1846</span><a name="line.1846"></a> +<span class="sourceLineNo">1847</span> @Override<a name="line.1847"></a> +<span class="sourceLineNo">1848</span> public boolean add(T e) {<a name="line.1848"></a> +<span class="sourceLineNo">1849</span> hookAtAdd.hook(size());<a name="line.1849"></a> +<span class="sourceLineNo">1850</span> return delegatee.add(e);<a name="line.1850"></a> +<span class="sourceLineNo">1851</span> }<a name="line.1851"></a> <span class="sourceLineNo">1852</span><a name="line.1852"></a> <span class="sourceLineNo">1853</span> @Override<a name="line.1853"></a> -<span class="sourceLineNo">1854</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1854"></a> +<span class="sourceLineNo">1854</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1854"></a> <span class="sourceLineNo">1855</span><a name="line.1855"></a> <span class="sourceLineNo">1856</span> @Override<a name="line.1856"></a> -<span class="sourceLineNo">1857</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1857"></a> +<span class="sourceLineNo">1857</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1857"></a> <span class="sourceLineNo">1858</span><a name="line.1858"></a> <span class="sourceLineNo">1859</span> @Override<a name="line.1859"></a> -<span class="sourceLineNo">1860</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1860"></a> +<span class="sourceLineNo">1860</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1860"></a> <span class="sourceLineNo">1861</span><a name="line.1861"></a> <span class="sourceLineNo">1862</span> @Override<a name="line.1862"></a> -<span class="sourceLineNo">1863</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1863"></a> +<span class="sourceLineNo">1863</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1863"></a> <span class="sourceLineNo">1864</span><a name="line.1864"></a> <span class="sourceLineNo">1865</span> @Override<a name="line.1865"></a> -<span class="sourceLineNo">1866</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1866"></a> +<span class="sourceLineNo">1866</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1866"></a> <span class="sourceLineNo">1867</span><a name="line.1867"></a> <span class="sourceLineNo">1868</span> @Override<a name="line.1868"></a> -<span class="sourceLineNo">1869</span> public void clear() {delegatee.clear();}<a name="line.1869"></a> +<span class="sourceLineNo">1869</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1869"></a> <span class="sourceLineNo">1870</span><a name="line.1870"></a> <span class="sourceLineNo">1871</span> @Override<a name="line.1871"></a> -<span class="sourceLineNo">1872</span> public T get(int index) {return delegatee.get(index);}<a name="line.1872"></a> +<span class="sourceLineNo">1872</span> public void clear() {delegatee.clear();}<a name="line.1872"></a> <span class="sourceLineNo">1873</span><a name="line.1873"></a> <span class="sourceLineNo">1874</span> @Override<a name="line.1874"></a> -<span class="sourceLineNo">1875</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1875"></a> +<span class="sourceLineNo">1875</span> public T get(int index) {return delegatee.get(index);}<a name="line.1875"></a> <span class="sourceLineNo">1876</span><a name="line.1876"></a> <span class="sourceLineNo">1877</span> @Override<a name="line.1877"></a> -<span class="sourceLineNo">1878</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1878"></a> +<span class="sourceLineNo">1878</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1878"></a> <span class="sourceLineNo">1879</span><a name="line.1879"></a> <span class="sourceLineNo">1880</span> @Override<a name="line.1880"></a> -<span class="sourceLineNo">1881</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1881"></a> +<span class="sourceLineNo">1881</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1881"></a> <span class="sourceLineNo">1882</span><a name="line.1882"></a> <span class="sourceLineNo">1883</span> @Override<a name="line.1883"></a> -<span class="sourceLineNo">1884</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1884"></a> +<span class="sourceLineNo">1884</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1884"></a> <span class="sourceLineNo">1885</span><a name="line.1885"></a> <span class="sourceLineNo">1886</span> @Override<a name="line.1886"></a> -<span class="sourceLineNo">1887</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1887"></a> +<span class="sourceLineNo">1887</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1887"></a> <span class="sourceLineNo">1888</span><a name="line.1888"></a> <span class="sourceLineNo">1889</span> @Override<a name="line.1889"></a> -<span class="sourceLineNo">1890</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1890"></a> +<span class="sourceLineNo">1890</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1890"></a> <span class="sourceLineNo">1891</span><a name="line.1891"></a> <span class="sourceLineNo">1892</span> @Override<a name="line.1892"></a> -<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1893"></a> +<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1893"></a> <span class="sourceLineNo">1894</span><a name="line.1894"></a> <span class="sourceLineNo">1895</span> @Override<a name="line.1895"></a> -<span class="sourceLineNo">1896</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1896"></a> -<span class="sourceLineNo">1897</span> }<a name="line.1897"></a> -<span class="sourceLineNo">1898</span>}<a name="line.1898"></a> +<span class="sourceLineNo">1896</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1896"></a> +<span class="sourceLineNo">1897</span><a name="line.1897"></a> +<span class="sourceLineNo">1898</span> @Override<a name="line.1898"></a> +<span class="sourceLineNo">1899</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1899"></a> +<span class="sourceLineNo">1900</span> }<a name="line.1900"></a> +<span class="sourceLineNo">1901</span>}<a name="line.1901"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c91fafb4/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStoreWithCustomCompactor.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStoreWithCustomCompactor.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStoreWithCustomCompactor.html index 3aed8f0..16d7d26 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStoreWithCustomCompactor.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyCompactingMemStoreWithCustomCompactor.html @@ -1746,15 +1746,15 @@ <span class="sourceLineNo">1738</span> @Override<a name="line.1738"></a> <span class="sourceLineNo">1739</span> public boolean start() throws IOException {<a name="line.1739"></a> <span class="sourceLineNo">1740</span> boolean isFirst = RUNNER_COUNT.getAndIncrement() == 0;<a name="line.1740"></a> -<span class="sourceLineNo">1741</span> boolean rval = super.start();<a name="line.1741"></a> -<span class="sourceLineNo">1742</span> if (isFirst) {<a name="line.1742"></a> -<span class="sourceLineNo">1743</span> try {<a name="line.1743"></a> -<span class="sourceLineNo">1744</span> START_COMPACTOR_LATCH.await();<a name="line.1744"></a> +<span class="sourceLineNo">1741</span> if (isFirst) {<a name="line.1741"></a> +<span class="sourceLineNo">1742</span> try {<a name="line.1742"></a> +<span class="sourceLineNo">1743</span> START_COMPACTOR_LATCH.await();<a name="line.1743"></a> +<span class="sourceLineNo">1744</span> return super.start();<a name="line.1744"></a> <span class="sourceLineNo">1745</span> } catch (InterruptedException ex) {<a name="line.1745"></a> <span class="sourceLineNo">1746</span> throw new RuntimeException(ex);<a name="line.1746"></a> <span class="sourceLineNo">1747</span> }<a name="line.1747"></a> <span class="sourceLineNo">1748</span> }<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> return rval;<a name="line.1749"></a> +<span class="sourceLineNo">1749</span> return super.start();<a name="line.1749"></a> <span class="sourceLineNo">1750</span> }<a name="line.1750"></a> <span class="sourceLineNo">1751</span> }<a name="line.1751"></a> <span class="sourceLineNo">1752</span><a name="line.1752"></a> @@ -1773,137 +1773,140 @@ <span class="sourceLineNo">1765</span> }<a name="line.1765"></a> <span class="sourceLineNo">1766</span><a name="line.1766"></a> <span class="sourceLineNo">1767</span> @Override<a name="line.1767"></a> -<span class="sourceLineNo">1768</span> void inMemoryCompaction() {<a name="line.1768"></a> -<span class="sourceLineNo">1769</span> RUNNER_COUNT.incrementAndGet();<a name="line.1769"></a> -<span class="sourceLineNo">1770</span> if (LOG.isDebugEnabled()) {<a name="line.1770"></a> -<span class="sourceLineNo">1771</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1771"></a> -<span class="sourceLineNo">1772</span> }<a name="line.1772"></a> -<span class="sourceLineNo">1773</span> super.inMemoryCompaction();<a name="line.1773"></a> -<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> -<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> -<span class="sourceLineNo">1776</span><a name="line.1776"></a> -<span class="sourceLineNo">1777</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1777"></a> -<span class="sourceLineNo">1778</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1778"></a> -<span class="sourceLineNo">1779</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1779"></a> -<span class="sourceLineNo">1780</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1780"></a> -<span class="sourceLineNo">1781</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1781"></a> -<span class="sourceLineNo">1782</span> HStore store, RegionServicesForStores regionServices,<a name="line.1782"></a> -<span class="sourceLineNo">1783</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1783"></a> -<span class="sourceLineNo">1784</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1784"></a> -<span class="sourceLineNo">1785</span> }<a name="line.1785"></a> -<span class="sourceLineNo">1786</span><a name="line.1786"></a> -<span class="sourceLineNo">1787</span> @Override<a name="line.1787"></a> -<span class="sourceLineNo">1788</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1788"></a> -<span class="sourceLineNo">1789</span> if (START_TEST.get()) {<a name="line.1789"></a> -<span class="sourceLineNo">1790</span> try {<a name="line.1790"></a> -<span class="sourceLineNo">1791</span> getScannerLatch.countDown();<a name="line.1791"></a> -<span class="sourceLineNo">1792</span> snapshotLatch.await();<a name="line.1792"></a> -<span class="sourceLineNo">1793</span> } catch (InterruptedException e) {<a name="line.1793"></a> -<span class="sourceLineNo">1794</span> throw new RuntimeException(e);<a name="line.1794"></a> -<span class="sourceLineNo">1795</span> }<a name="line.1795"></a> -<span class="sourceLineNo">1796</span> }<a name="line.1796"></a> -<span class="sourceLineNo">1797</span> return new ArrayList<>(capacity);<a name="line.1797"></a> -<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> -<span class="sourceLineNo">1799</span> @Override<a name="line.1799"></a> -<span class="sourceLineNo">1800</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1800"></a> -<span class="sourceLineNo">1801</span> if (START_TEST.get()) {<a name="line.1801"></a> -<span class="sourceLineNo">1802</span> try {<a name="line.1802"></a> -<span class="sourceLineNo">1803</span> getScannerLatch.await();<a name="line.1803"></a> -<span class="sourceLineNo">1804</span> } catch (InterruptedException e) {<a name="line.1804"></a> -<span class="sourceLineNo">1805</span> throw new RuntimeException(e);<a name="line.1805"></a> -<span class="sourceLineNo">1806</span> }<a name="line.1806"></a> -<span class="sourceLineNo">1807</span> }<a name="line.1807"></a> -<span class="sourceLineNo">1808</span><a name="line.1808"></a> -<span class="sourceLineNo">1809</span> super.pushActiveToPipeline(active);<a name="line.1809"></a> -<span class="sourceLineNo">1810</span> if (START_TEST.get()) {<a name="line.1810"></a> -<span class="sourceLineNo">1811</span> snapshotLatch.countDown();<a name="line.1811"></a> -<span class="sourceLineNo">1812</span> }<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> }<a name="line.1813"></a> -<span class="sourceLineNo">1814</span> }<a name="line.1814"></a> -<span class="sourceLineNo">1815</span><a name="line.1815"></a> -<span class="sourceLineNo">1816</span> interface MyListHook {<a name="line.1816"></a> -<span class="sourceLineNo">1817</span> void hook(int currentSize);<a name="line.1817"></a> -<span class="sourceLineNo">1818</span> }<a name="line.1818"></a> -<span class="sourceLineNo">1819</span><a name="line.1819"></a> -<span class="sourceLineNo">1820</span> private static class MyList<T> implements List<T> {<a name="line.1820"></a> -<span class="sourceLineNo">1821</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1821"></a> -<span class="sourceLineNo">1822</span> private final MyListHook hookAtAdd;<a name="line.1822"></a> -<span class="sourceLineNo">1823</span> MyList(final MyListHook hookAtAdd) {<a name="line.1823"></a> -<span class="sourceLineNo">1824</span> this.hookAtAdd = hookAtAdd;<a name="line.1824"></a> -<span class="sourceLineNo">1825</span> }<a name="line.1825"></a> -<span class="sourceLineNo">1826</span> @Override<a name="line.1826"></a> -<span class="sourceLineNo">1827</span> public int size() {return delegatee.size();}<a name="line.1827"></a> -<span class="sourceLineNo">1828</span><a name="line.1828"></a> +<span class="sourceLineNo">1768</span> protected boolean setInMemoryCompactionFlag() {<a name="line.1768"></a> +<span class="sourceLineNo">1769</span> boolean rval = super.setInMemoryCompactionFlag();<a name="line.1769"></a> +<span class="sourceLineNo">1770</span> if (rval) {<a name="line.1770"></a> +<span class="sourceLineNo">1771</span> RUNNER_COUNT.incrementAndGet();<a name="line.1771"></a> +<span class="sourceLineNo">1772</span> if (LOG.isDebugEnabled()) {<a name="line.1772"></a> +<span class="sourceLineNo">1773</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1773"></a> +<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> +<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> +<span class="sourceLineNo">1776</span> return rval;<a name="line.1776"></a> +<span class="sourceLineNo">1777</span> }<a name="line.1777"></a> +<span class="sourceLineNo">1778</span> }<a name="line.1778"></a> +<span class="sourceLineNo">1779</span><a name="line.1779"></a> +<span class="sourceLineNo">1780</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1780"></a> +<span class="sourceLineNo">1781</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1781"></a> +<span class="sourceLineNo">1782</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1782"></a> +<span class="sourceLineNo">1783</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1783"></a> +<span class="sourceLineNo">1784</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1784"></a> +<span class="sourceLineNo">1785</span> HStore store, RegionServicesForStores regionServices,<a name="line.1785"></a> +<span class="sourceLineNo">1786</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1786"></a> +<span class="sourceLineNo">1787</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1787"></a> +<span class="sourceLineNo">1788</span> }<a name="line.1788"></a> +<span class="sourceLineNo">1789</span><a name="line.1789"></a> +<span class="sourceLineNo">1790</span> @Override<a name="line.1790"></a> +<span class="sourceLineNo">1791</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1791"></a> +<span class="sourceLineNo">1792</span> if (START_TEST.get()) {<a name="line.1792"></a> +<span class="sourceLineNo">1793</span> try {<a name="line.1793"></a> +<span class="sourceLineNo">1794</span> getScannerLatch.countDown();<a name="line.1794"></a> +<span class="sourceLineNo">1795</span> snapshotLatch.await();<a name="line.1795"></a> +<span class="sourceLineNo">1796</span> } catch (InterruptedException e) {<a name="line.1796"></a> +<span class="sourceLineNo">1797</span> throw new RuntimeException(e);<a name="line.1797"></a> +<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> +<span class="sourceLineNo">1799</span> }<a name="line.1799"></a> +<span class="sourceLineNo">1800</span> return new ArrayList<>(capacity);<a name="line.1800"></a> +<span class="sourceLineNo">1801</span> }<a name="line.1801"></a> +<span class="sourceLineNo">1802</span> @Override<a name="line.1802"></a> +<span class="sourceLineNo">1803</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1803"></a> +<span class="sourceLineNo">1804</span> if (START_TEST.get()) {<a name="line.1804"></a> +<span class="sourceLineNo">1805</span> try {<a name="line.1805"></a> +<span class="sourceLineNo">1806</span> getScannerLatch.await();<a name="line.1806"></a> +<span class="sourceLineNo">1807</span> } catch (InterruptedException e) {<a name="line.1807"></a> +<span class="sourceLineNo">1808</span> throw new RuntimeException(e);<a name="line.1808"></a> +<span class="sourceLineNo">1809</span> }<a name="line.1809"></a> +<span class="sourceLineNo">1810</span> }<a name="line.1810"></a> +<span class="sourceLineNo">1811</span><a name="line.1811"></a> +<span class="sourceLineNo">1812</span> super.pushActiveToPipeline(active);<a name="line.1812"></a> +<span class="sourceLineNo">1813</span> if (START_TEST.get()) {<a name="line.1813"></a> +<span class="sourceLineNo">1814</span> snapshotLatch.countDown();<a name="line.1814"></a> +<span class="sourceLineNo">1815</span> }<a name="line.1815"></a> +<span class="sourceLineNo">1816</span> }<a name="line.1816"></a> +<span class="sourceLineNo">1817</span> }<a name="line.1817"></a> +<span class="sourceLineNo">1818</span><a name="line.1818"></a> +<span class="sourceLineNo">1819</span> interface MyListHook {<a name="line.1819"></a> +<span class="sourceLineNo">1820</span> void hook(int currentSize);<a name="line.1820"></a> +<span class="sourceLineNo">1821</span> }<a name="line.1821"></a> +<span class="sourceLineNo">1822</span><a name="line.1822"></a> +<span class="sourceLineNo">1823</span> private static class MyList<T> implements List<T> {<a name="line.1823"></a> +<span class="sourceLineNo">1824</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1824"></a> +<span class="sourceLineNo">1825</span> private final MyListHook hookAtAdd;<a name="line.1825"></a> +<span class="sourceLineNo">1826</span> MyList(final MyListHook hookAtAdd) {<a name="line.1826"></a> +<span class="sourceLineNo">1827</span> this.hookAtAdd = hookAtAdd;<a name="line.1827"></a> +<span class="sourceLineNo">1828</span> }<a name="line.1828"></a> <span class="sourceLineNo">1829</span> @Override<a name="line.1829"></a> -<span class="sourceLineNo">1830</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1830"></a> +<span class="sourceLineNo">1830</span> public int size() {return delegatee.size();}<a name="line.1830"></a> <span class="sourceLineNo">1831</span><a name="line.1831"></a> <span class="sourceLineNo">1832</span> @Override<a name="line.1832"></a> -<span class="sourceLineNo">1833</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1833"></a> +<span class="sourceLineNo">1833</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1833"></a> <span class="sourceLineNo">1834</span><a name="line.1834"></a> <span class="sourceLineNo">1835</span> @Override<a name="line.1835"></a> -<span class="sourceLineNo">1836</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1836"></a> +<span class="sourceLineNo">1836</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1836"></a> <span class="sourceLineNo">1837</span><a name="line.1837"></a> <span class="sourceLineNo">1838</span> @Override<a name="line.1838"></a> -<span class="sourceLineNo">1839</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1839"></a> +<span class="sourceLineNo">1839</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1839"></a> <span class="sourceLineNo">1840</span><a name="line.1840"></a> <span class="sourceLineNo">1841</span> @Override<a name="line.1841"></a> -<span class="sourceLineNo">1842</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1842"></a> +<span class="sourceLineNo">1842</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1842"></a> <span class="sourceLineNo">1843</span><a name="line.1843"></a> <span class="sourceLineNo">1844</span> @Override<a name="line.1844"></a> -<span class="sourceLineNo">1845</span> public boolean add(T e) {<a name="line.1845"></a> -<span class="sourceLineNo">1846</span> hookAtAdd.hook(size());<a name="line.1846"></a> -<span class="sourceLineNo">1847</span> return delegatee.add(e);<a name="line.1847"></a> -<span class="sourceLineNo">1848</span> }<a name="line.1848"></a> -<span class="sourceLineNo">1849</span><a name="line.1849"></a> -<span class="sourceLineNo">1850</span> @Override<a name="line.1850"></a> -<span class="sourceLineNo">1851</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1851"></a> +<span class="sourceLineNo">1845</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1845"></a> +<span class="sourceLineNo">1846</span><a name="line.1846"></a> +<span class="sourceLineNo">1847</span> @Override<a name="line.1847"></a> +<span class="sourceLineNo">1848</span> public boolean add(T e) {<a name="line.1848"></a> +<span class="sourceLineNo">1849</span> hookAtAdd.hook(size());<a name="line.1849"></a> +<span class="sourceLineNo">1850</span> return delegatee.add(e);<a name="line.1850"></a> +<span class="sourceLineNo">1851</span> }<a name="line.1851"></a> <span class="sourceLineNo">1852</span><a name="line.1852"></a> <span class="sourceLineNo">1853</span> @Override<a name="line.1853"></a> -<span class="sourceLineNo">1854</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1854"></a> +<span class="sourceLineNo">1854</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1854"></a> <span class="sourceLineNo">1855</span><a name="line.1855"></a> <span class="sourceLineNo">1856</span> @Override<a name="line.1856"></a> -<span class="sourceLineNo">1857</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1857"></a> +<span class="sourceLineNo">1857</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1857"></a> <span class="sourceLineNo">1858</span><a name="line.1858"></a> <span class="sourceLineNo">1859</span> @Override<a name="line.1859"></a> -<span class="sourceLineNo">1860</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1860"></a> +<span class="sourceLineNo">1860</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1860"></a> <span class="sourceLineNo">1861</span><a name="line.1861"></a> <span class="sourceLineNo">1862</span> @Override<a name="line.1862"></a> -<span class="sourceLineNo">1863</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1863"></a> +<span class="sourceLineNo">1863</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1863"></a> <span class="sourceLineNo">1864</span><a name="line.1864"></a> <span class="sourceLineNo">1865</span> @Override<a name="line.1865"></a> -<span class="sourceLineNo">1866</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1866"></a> +<span class="sourceLineNo">1866</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1866"></a> <span class="sourceLineNo">1867</span><a name="line.1867"></a> <span class="sourceLineNo">1868</span> @Override<a name="line.1868"></a> -<span class="sourceLineNo">1869</span> public void clear() {delegatee.clear();}<a name="line.1869"></a> +<span class="sourceLineNo">1869</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1869"></a> <span class="sourceLineNo">1870</span><a name="line.1870"></a> <span class="sourceLineNo">1871</span> @Override<a name="line.1871"></a> -<span class="sourceLineNo">1872</span> public T get(int index) {return delegatee.get(index);}<a name="line.1872"></a> +<span class="sourceLineNo">1872</span> public void clear() {delegatee.clear();}<a name="line.1872"></a> <span class="sourceLineNo">1873</span><a name="line.1873"></a> <span class="sourceLineNo">1874</span> @Override<a name="line.1874"></a> -<span class="sourceLineNo">1875</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1875"></a> +<span class="sourceLineNo">1875</span> public T get(int index) {return delegatee.get(index);}<a name="line.1875"></a> <span class="sourceLineNo">1876</span><a name="line.1876"></a> <span class="sourceLineNo">1877</span> @Override<a name="line.1877"></a> -<span class="sourceLineNo">1878</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1878"></a> +<span class="sourceLineNo">1878</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1878"></a> <span class="sourceLineNo">1879</span><a name="line.1879"></a> <span class="sourceLineNo">1880</span> @Override<a name="line.1880"></a> -<span class="sourceLineNo">1881</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1881"></a> +<span class="sourceLineNo">1881</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1881"></a> <span class="sourceLineNo">1882</span><a name="line.1882"></a> <span class="sourceLineNo">1883</span> @Override<a name="line.1883"></a> -<span class="sourceLineNo">1884</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1884"></a> +<span class="sourceLineNo">1884</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1884"></a> <span class="sourceLineNo">1885</span><a name="line.1885"></a> <span class="sourceLineNo">1886</span> @Override<a name="line.1886"></a> -<span class="sourceLineNo">1887</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1887"></a> +<span class="sourceLineNo">1887</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1887"></a> <span class="sourceLineNo">1888</span><a name="line.1888"></a> <span class="sourceLineNo">1889</span> @Override<a name="line.1889"></a> -<span class="sourceLineNo">1890</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1890"></a> +<span class="sourceLineNo">1890</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1890"></a> <span class="sourceLineNo">1891</span><a name="line.1891"></a> <span class="sourceLineNo">1892</span> @Override<a name="line.1892"></a> -<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1893"></a> +<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1893"></a> <span class="sourceLineNo">1894</span><a name="line.1894"></a> <span class="sourceLineNo">1895</span> @Override<a name="line.1895"></a> -<span class="sourceLineNo">1896</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1896"></a> -<span class="sourceLineNo">1897</span> }<a name="line.1897"></a> -<span class="sourceLineNo">1898</span>}<a name="line.1898"></a> +<span class="sourceLineNo">1896</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1896"></a> +<span class="sourceLineNo">1897</span><a name="line.1897"></a> +<span class="sourceLineNo">1898</span> @Override<a name="line.1898"></a> +<span class="sourceLineNo">1899</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1899"></a> +<span class="sourceLineNo">1900</span> }<a name="line.1900"></a> +<span class="sourceLineNo">1901</span>}<a name="line.1901"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c91fafb4/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyList.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyList.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyList.html index 3aed8f0..16d7d26 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyList.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHStore.MyList.html @@ -1746,15 +1746,15 @@ <span class="sourceLineNo">1738</span> @Override<a name="line.1738"></a> <span class="sourceLineNo">1739</span> public boolean start() throws IOException {<a name="line.1739"></a> <span class="sourceLineNo">1740</span> boolean isFirst = RUNNER_COUNT.getAndIncrement() == 0;<a name="line.1740"></a> -<span class="sourceLineNo">1741</span> boolean rval = super.start();<a name="line.1741"></a> -<span class="sourceLineNo">1742</span> if (isFirst) {<a name="line.1742"></a> -<span class="sourceLineNo">1743</span> try {<a name="line.1743"></a> -<span class="sourceLineNo">1744</span> START_COMPACTOR_LATCH.await();<a name="line.1744"></a> +<span class="sourceLineNo">1741</span> if (isFirst) {<a name="line.1741"></a> +<span class="sourceLineNo">1742</span> try {<a name="line.1742"></a> +<span class="sourceLineNo">1743</span> START_COMPACTOR_LATCH.await();<a name="line.1743"></a> +<span class="sourceLineNo">1744</span> return super.start();<a name="line.1744"></a> <span class="sourceLineNo">1745</span> } catch (InterruptedException ex) {<a name="line.1745"></a> <span class="sourceLineNo">1746</span> throw new RuntimeException(ex);<a name="line.1746"></a> <span class="sourceLineNo">1747</span> }<a name="line.1747"></a> <span class="sourceLineNo">1748</span> }<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> return rval;<a name="line.1749"></a> +<span class="sourceLineNo">1749</span> return super.start();<a name="line.1749"></a> <span class="sourceLineNo">1750</span> }<a name="line.1750"></a> <span class="sourceLineNo">1751</span> }<a name="line.1751"></a> <span class="sourceLineNo">1752</span><a name="line.1752"></a> @@ -1773,137 +1773,140 @@ <span class="sourceLineNo">1765</span> }<a name="line.1765"></a> <span class="sourceLineNo">1766</span><a name="line.1766"></a> <span class="sourceLineNo">1767</span> @Override<a name="line.1767"></a> -<span class="sourceLineNo">1768</span> void inMemoryCompaction() {<a name="line.1768"></a> -<span class="sourceLineNo">1769</span> RUNNER_COUNT.incrementAndGet();<a name="line.1769"></a> -<span class="sourceLineNo">1770</span> if (LOG.isDebugEnabled()) {<a name="line.1770"></a> -<span class="sourceLineNo">1771</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1771"></a> -<span class="sourceLineNo">1772</span> }<a name="line.1772"></a> -<span class="sourceLineNo">1773</span> super.inMemoryCompaction();<a name="line.1773"></a> -<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> -<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> -<span class="sourceLineNo">1776</span><a name="line.1776"></a> -<span class="sourceLineNo">1777</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1777"></a> -<span class="sourceLineNo">1778</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1778"></a> -<span class="sourceLineNo">1779</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1779"></a> -<span class="sourceLineNo">1780</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1780"></a> -<span class="sourceLineNo">1781</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1781"></a> -<span class="sourceLineNo">1782</span> HStore store, RegionServicesForStores regionServices,<a name="line.1782"></a> -<span class="sourceLineNo">1783</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1783"></a> -<span class="sourceLineNo">1784</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1784"></a> -<span class="sourceLineNo">1785</span> }<a name="line.1785"></a> -<span class="sourceLineNo">1786</span><a name="line.1786"></a> -<span class="sourceLineNo">1787</span> @Override<a name="line.1787"></a> -<span class="sourceLineNo">1788</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1788"></a> -<span class="sourceLineNo">1789</span> if (START_TEST.get()) {<a name="line.1789"></a> -<span class="sourceLineNo">1790</span> try {<a name="line.1790"></a> -<span class="sourceLineNo">1791</span> getScannerLatch.countDown();<a name="line.1791"></a> -<span class="sourceLineNo">1792</span> snapshotLatch.await();<a name="line.1792"></a> -<span class="sourceLineNo">1793</span> } catch (InterruptedException e) {<a name="line.1793"></a> -<span class="sourceLineNo">1794</span> throw new RuntimeException(e);<a name="line.1794"></a> -<span class="sourceLineNo">1795</span> }<a name="line.1795"></a> -<span class="sourceLineNo">1796</span> }<a name="line.1796"></a> -<span class="sourceLineNo">1797</span> return new ArrayList<>(capacity);<a name="line.1797"></a> -<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> -<span class="sourceLineNo">1799</span> @Override<a name="line.1799"></a> -<span class="sourceLineNo">1800</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1800"></a> -<span class="sourceLineNo">1801</span> if (START_TEST.get()) {<a name="line.1801"></a> -<span class="sourceLineNo">1802</span> try {<a name="line.1802"></a> -<span class="sourceLineNo">1803</span> getScannerLatch.await();<a name="line.1803"></a> -<span class="sourceLineNo">1804</span> } catch (InterruptedException e) {<a name="line.1804"></a> -<span class="sourceLineNo">1805</span> throw new RuntimeException(e);<a name="line.1805"></a> -<span class="sourceLineNo">1806</span> }<a name="line.1806"></a> -<span class="sourceLineNo">1807</span> }<a name="line.1807"></a> -<span class="sourceLineNo">1808</span><a name="line.1808"></a> -<span class="sourceLineNo">1809</span> super.pushActiveToPipeline(active);<a name="line.1809"></a> -<span class="sourceLineNo">1810</span> if (START_TEST.get()) {<a name="line.1810"></a> -<span class="sourceLineNo">1811</span> snapshotLatch.countDown();<a name="line.1811"></a> -<span class="sourceLineNo">1812</span> }<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> }<a name="line.1813"></a> -<span class="sourceLineNo">1814</span> }<a name="line.1814"></a> -<span class="sourceLineNo">1815</span><a name="line.1815"></a> -<span class="sourceLineNo">1816</span> interface MyListHook {<a name="line.1816"></a> -<span class="sourceLineNo">1817</span> void hook(int currentSize);<a name="line.1817"></a> -<span class="sourceLineNo">1818</span> }<a name="line.1818"></a> -<span class="sourceLineNo">1819</span><a name="line.1819"></a> -<span class="sourceLineNo">1820</span> private static class MyList<T> implements List<T> {<a name="line.1820"></a> -<span class="sourceLineNo">1821</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1821"></a> -<span class="sourceLineNo">1822</span> private final MyListHook hookAtAdd;<a name="line.1822"></a> -<span class="sourceLineNo">1823</span> MyList(final MyListHook hookAtAdd) {<a name="line.1823"></a> -<span class="sourceLineNo">1824</span> this.hookAtAdd = hookAtAdd;<a name="line.1824"></a> -<span class="sourceLineNo">1825</span> }<a name="line.1825"></a> -<span class="sourceLineNo">1826</span> @Override<a name="line.1826"></a> -<span class="sourceLineNo">1827</span> public int size() {return delegatee.size();}<a name="line.1827"></a> -<span class="sourceLineNo">1828</span><a name="line.1828"></a> +<span class="sourceLineNo">1768</span> protected boolean setInMemoryCompactionFlag() {<a name="line.1768"></a> +<span class="sourceLineNo">1769</span> boolean rval = super.setInMemoryCompactionFlag();<a name="line.1769"></a> +<span class="sourceLineNo">1770</span> if (rval) {<a name="line.1770"></a> +<span class="sourceLineNo">1771</span> RUNNER_COUNT.incrementAndGet();<a name="line.1771"></a> +<span class="sourceLineNo">1772</span> if (LOG.isDebugEnabled()) {<a name="line.1772"></a> +<span class="sourceLineNo">1773</span> LOG.debug("runner count: " + RUNNER_COUNT.get());<a name="line.1773"></a> +<span class="sourceLineNo">1774</span> }<a name="line.1774"></a> +<span class="sourceLineNo">1775</span> }<a name="line.1775"></a> +<span class="sourceLineNo">1776</span> return rval;<a name="line.1776"></a> +<span class="sourceLineNo">1777</span> }<a name="line.1777"></a> +<span class="sourceLineNo">1778</span> }<a name="line.1778"></a> +<span class="sourceLineNo">1779</span><a name="line.1779"></a> +<span class="sourceLineNo">1780</span> public static class MyCompactingMemStore extends CompactingMemStore {<a name="line.1780"></a> +<span class="sourceLineNo">1781</span> private static final AtomicBoolean START_TEST = new AtomicBoolean(false);<a name="line.1781"></a> +<span class="sourceLineNo">1782</span> private final CountDownLatch getScannerLatch = new CountDownLatch(1);<a name="line.1782"></a> +<span class="sourceLineNo">1783</span> private final CountDownLatch snapshotLatch = new CountDownLatch(1);<a name="line.1783"></a> +<span class="sourceLineNo">1784</span> public MyCompactingMemStore(Configuration conf, CellComparatorImpl c,<a name="line.1784"></a> +<span class="sourceLineNo">1785</span> HStore store, RegionServicesForStores regionServices,<a name="line.1785"></a> +<span class="sourceLineNo">1786</span> MemoryCompactionPolicy compactionPolicy) throws IOException {<a name="line.1786"></a> +<span class="sourceLineNo">1787</span> super(conf, c, store, regionServices, compactionPolicy);<a name="line.1787"></a> +<span class="sourceLineNo">1788</span> }<a name="line.1788"></a> +<span class="sourceLineNo">1789</span><a name="line.1789"></a> +<span class="sourceLineNo">1790</span> @Override<a name="line.1790"></a> +<span class="sourceLineNo">1791</span> protected List<KeyValueScanner> createList(int capacity) {<a name="line.1791"></a> +<span class="sourceLineNo">1792</span> if (START_TEST.get()) {<a name="line.1792"></a> +<span class="sourceLineNo">1793</span> try {<a name="line.1793"></a> +<span class="sourceLineNo">1794</span> getScannerLatch.countDown();<a name="line.1794"></a> +<span class="sourceLineNo">1795</span> snapshotLatch.await();<a name="line.1795"></a> +<span class="sourceLineNo">1796</span> } catch (InterruptedException e) {<a name="line.1796"></a> +<span class="sourceLineNo">1797</span> throw new RuntimeException(e);<a name="line.1797"></a> +<span class="sourceLineNo">1798</span> }<a name="line.1798"></a> +<span class="sourceLineNo">1799</span> }<a name="line.1799"></a> +<span class="sourceLineNo">1800</span> return new ArrayList<>(capacity);<a name="line.1800"></a> +<span class="sourceLineNo">1801</span> }<a name="line.1801"></a> +<span class="sourceLineNo">1802</span> @Override<a name="line.1802"></a> +<span class="sourceLineNo">1803</span> protected void pushActiveToPipeline(MutableSegment active) {<a name="line.1803"></a> +<span class="sourceLineNo">1804</span> if (START_TEST.get()) {<a name="line.1804"></a> +<span class="sourceLineNo">1805</span> try {<a name="line.1805"></a> +<span class="sourceLineNo">1806</span> getScannerLatch.await();<a name="line.1806"></a> +<span class="sourceLineNo">1807</span> } catch (InterruptedException e) {<a name="line.1807"></a> +<span class="sourceLineNo">1808</span> throw new RuntimeException(e);<a name="line.1808"></a> +<span class="sourceLineNo">1809</span> }<a name="line.1809"></a> +<span class="sourceLineNo">1810</span> }<a name="line.1810"></a> +<span class="sourceLineNo">1811</span><a name="line.1811"></a> +<span class="sourceLineNo">1812</span> super.pushActiveToPipeline(active);<a name="line.1812"></a> +<span class="sourceLineNo">1813</span> if (START_TEST.get()) {<a name="line.1813"></a> +<span class="sourceLineNo">1814</span> snapshotLatch.countDown();<a name="line.1814"></a> +<span class="sourceLineNo">1815</span> }<a name="line.1815"></a> +<span class="sourceLineNo">1816</span> }<a name="line.1816"></a> +<span class="sourceLineNo">1817</span> }<a name="line.1817"></a> +<span class="sourceLineNo">1818</span><a name="line.1818"></a> +<span class="sourceLineNo">1819</span> interface MyListHook {<a name="line.1819"></a> +<span class="sourceLineNo">1820</span> void hook(int currentSize);<a name="line.1820"></a> +<span class="sourceLineNo">1821</span> }<a name="line.1821"></a> +<span class="sourceLineNo">1822</span><a name="line.1822"></a> +<span class="sourceLineNo">1823</span> private static class MyList<T> implements List<T> {<a name="line.1823"></a> +<span class="sourceLineNo">1824</span> private final List<T> delegatee = new ArrayList<>();<a name="line.1824"></a> +<span class="sourceLineNo">1825</span> private final MyListHook hookAtAdd;<a name="line.1825"></a> +<span class="sourceLineNo">1826</span> MyList(final MyListHook hookAtAdd) {<a name="line.1826"></a> +<span class="sourceLineNo">1827</span> this.hookAtAdd = hookAtAdd;<a name="line.1827"></a> +<span class="sourceLineNo">1828</span> }<a name="line.1828"></a> <span class="sourceLineNo">1829</span> @Override<a name="line.1829"></a> -<span class="sourceLineNo">1830</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1830"></a> +<span class="sourceLineNo">1830</span> public int size() {return delegatee.size();}<a name="line.1830"></a> <span class="sourceLineNo">1831</span><a name="line.1831"></a> <span class="sourceLineNo">1832</span> @Override<a name="line.1832"></a> -<span class="sourceLineNo">1833</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1833"></a> +<span class="sourceLineNo">1833</span> public boolean isEmpty() {return delegatee.isEmpty();}<a name="line.1833"></a> <span class="sourceLineNo">1834</span><a name="line.1834"></a> <span class="sourceLineNo">1835</span> @Override<a name="line.1835"></a> -<span class="sourceLineNo">1836</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1836"></a> +<span class="sourceLineNo">1836</span> public boolean contains(Object o) {return delegatee.contains(o);}<a name="line.1836"></a> <span class="sourceLineNo">1837</span><a name="line.1837"></a> <span class="sourceLineNo">1838</span> @Override<a name="line.1838"></a> -<span class="sourceLineNo">1839</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1839"></a> +<span class="sourceLineNo">1839</span> public Iterator<T> iterator() {return delegatee.iterator();}<a name="line.1839"></a> <span class="sourceLineNo">1840</span><a name="line.1840"></a> <span class="sourceLineNo">1841</span> @Override<a name="line.1841"></a> -<span class="sourceLineNo">1842</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1842"></a> +<span class="sourceLineNo">1842</span> public Object[] toArray() {return delegatee.toArray();}<a name="line.1842"></a> <span class="sourceLineNo">1843</span><a name="line.1843"></a> <span class="sourceLineNo">1844</span> @Override<a name="line.1844"></a> -<span class="sourceLineNo">1845</span> public boolean add(T e) {<a name="line.1845"></a> -<span class="sourceLineNo">1846</span> hookAtAdd.hook(size());<a name="line.1846"></a> -<span class="sourceLineNo">1847</span> return delegatee.add(e);<a name="line.1847"></a> -<span class="sourceLineNo">1848</span> }<a name="line.1848"></a> -<span class="sourceLineNo">1849</span><a name="line.1849"></a> -<span class="sourceLineNo">1850</span> @Override<a name="line.1850"></a> -<span class="sourceLineNo">1851</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1851"></a> +<span class="sourceLineNo">1845</span> public <R> R[] toArray(R[] a) {return delegatee.toArray(a);}<a name="line.1845"></a> +<span class="sourceLineNo">1846</span><a name="line.1846"></a> +<span class="sourceLineNo">1847</span> @Override<a name="line.1847"></a> +<span class="sourceLineNo">1848</span> public boolean add(T e) {<a name="line.1848"></a> +<span class="sourceLineNo">1849</span> hookAtAdd.hook(size());<a name="line.1849"></a> +<span class="sourceLineNo">1850</span> return delegatee.add(e);<a name="line.1850"></a> +<span class="sourceLineNo">1851</span> }<a name="line.1851"></a> <span class="sourceLineNo">1852</span><a name="line.1852"></a> <span class="sourceLineNo">1853</span> @Override<a name="line.1853"></a> -<span class="sourceLineNo">1854</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1854"></a> +<span class="sourceLineNo">1854</span> public boolean remove(Object o) {return delegatee.remove(o);}<a name="line.1854"></a> <span class="sourceLineNo">1855</span><a name="line.1855"></a> <span class="sourceLineNo">1856</span> @Override<a name="line.1856"></a> -<span class="sourceLineNo">1857</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1857"></a> +<span class="sourceLineNo">1857</span> public boolean containsAll(Collection<?> c) {return delegatee.containsAll(c);}<a name="line.1857"></a> <span class="sourceLineNo">1858</span><a name="line.1858"></a> <span class="sourceLineNo">1859</span> @Override<a name="line.1859"></a> -<span class="sourceLineNo">1860</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1860"></a> +<span class="sourceLineNo">1860</span> public boolean addAll(Collection<? extends T> c) {return delegatee.addAll(c);}<a name="line.1860"></a> <span class="sourceLineNo">1861</span><a name="line.1861"></a> <span class="sourceLineNo">1862</span> @Override<a name="line.1862"></a> -<span class="sourceLineNo">1863</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1863"></a> +<span class="sourceLineNo">1863</span> public boolean addAll(int index, Collection<? extends T> c) {return delegatee.addAll(index, c);}<a name="line.1863"></a> <span class="sourceLineNo">1864</span><a name="line.1864"></a> <span class="sourceLineNo">1865</span> @Override<a name="line.1865"></a> -<span class="sourceLineNo">1866</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1866"></a> +<span class="sourceLineNo">1866</span> public boolean removeAll(Collection<?> c) {return delegatee.removeAll(c);}<a name="line.1866"></a> <span class="sourceLineNo">1867</span><a name="line.1867"></a> <span class="sourceLineNo">1868</span> @Override<a name="line.1868"></a> -<span class="sourceLineNo">1869</span> public void clear() {delegatee.clear();}<a name="line.1869"></a> +<span class="sourceLineNo">1869</span> public boolean retainAll(Collection<?> c) {return delegatee.retainAll(c);}<a name="line.1869"></a> <span class="sourceLineNo">1870</span><a name="line.1870"></a> <span class="sourceLineNo">1871</span> @Override<a name="line.1871"></a> -<span class="sourceLineNo">1872</span> public T get(int index) {return delegatee.get(index);}<a name="line.1872"></a> +<span class="sourceLineNo">1872</span> public void clear() {delegatee.clear();}<a name="line.1872"></a> <span class="sourceLineNo">1873</span><a name="line.1873"></a> <span class="sourceLineNo">1874</span> @Override<a name="line.1874"></a> -<span class="sourceLineNo">1875</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1875"></a> +<span class="sourceLineNo">1875</span> public T get(int index) {return delegatee.get(index);}<a name="line.1875"></a> <span class="sourceLineNo">1876</span><a name="line.1876"></a> <span class="sourceLineNo">1877</span> @Override<a name="line.1877"></a> -<span class="sourceLineNo">1878</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1878"></a> +<span class="sourceLineNo">1878</span> public T set(int index, T element) {return delegatee.set(index, element);}<a name="line.1878"></a> <span class="sourceLineNo">1879</span><a name="line.1879"></a> <span class="sourceLineNo">1880</span> @Override<a name="line.1880"></a> -<span class="sourceLineNo">1881</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1881"></a> +<span class="sourceLineNo">1881</span> public void add(int index, T element) {delegatee.add(index, element);}<a name="line.1881"></a> <span class="sourceLineNo">1882</span><a name="line.1882"></a> <span class="sourceLineNo">1883</span> @Override<a name="line.1883"></a> -<span class="sourceLineNo">1884</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1884"></a> +<span class="sourceLineNo">1884</span> public T remove(int index) {return delegatee.remove(index);}<a name="line.1884"></a> <span class="sourceLineNo">1885</span><a name="line.1885"></a> <span class="sourceLineNo">1886</span> @Override<a name="line.1886"></a> -<span class="sourceLineNo">1887</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1887"></a> +<span class="sourceLineNo">1887</span> public int indexOf(Object o) {return delegatee.indexOf(o);}<a name="line.1887"></a> <span class="sourceLineNo">1888</span><a name="line.1888"></a> <span class="sourceLineNo">1889</span> @Override<a name="line.1889"></a> -<span class="sourceLineNo">1890</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1890"></a> +<span class="sourceLineNo">1890</span> public int lastIndexOf(Object o) {return delegatee.lastIndexOf(o);}<a name="line.1890"></a> <span class="sourceLineNo">1891</span><a name="line.1891"></a> <span class="sourceLineNo">1892</span> @Override<a name="line.1892"></a> -<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1893"></a> +<span class="sourceLineNo">1893</span> public ListIterator<T> listIterator() {return delegatee.listIterator();}<a name="line.1893"></a> <span class="sourceLineNo">1894</span><a name="line.1894"></a> <span class="sourceLineNo">1895</span> @Override<a name="line.1895"></a> -<span class="sourceLineNo">1896</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1896"></a> -<span class="sourceLineNo">1897</span> }<a name="line.1897"></a> -<span class="sourceLineNo">1898</span>}<a name="line.1898"></a> +<span class="sourceLineNo">1896</span> public ListIterator<T> listIterator(int index) {return delegatee.listIterator(index);}<a name="line.1896"></a> +<span class="sourceLineNo">1897</span><a name="line.1897"></a> +<span class="sourceLineNo">1898</span> @Override<a name="line.1898"></a> +<span class="sourceLineNo">1899</span> public List<T> subList(int fromIndex, int toIndex) {return delegatee.subList(fromIndex, toIndex);}<a name="line.1899"></a> +<span class="sourceLineNo">1900</span> }<a name="line.1900"></a> +<span class="sourceLineNo">1901</span>}<a name="line.1901"></a>