http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/ImmutableSegment.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/ImmutableSegment.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/ImmutableSegment.html index c8cdcb6..166edcf 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/ImmutableSegment.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/ImmutableSegment.html @@ -43,68 +43,47 @@ <span class="sourceLineNo">035</span>@InterfaceAudience.Private<a name="line.35"></a> <span class="sourceLineNo">036</span>public abstract class ImmutableSegment extends Segment {<a name="line.36"></a> <span class="sourceLineNo">037</span><a name="line.37"></a> -<span class="sourceLineNo">038</span> public static final long DEEP_OVERHEAD = Segment.DEEP_OVERHEAD<a name="line.38"></a> -<span class="sourceLineNo">039</span> + ClassSize.align(ClassSize.REFERENCE // Referent to timeRange<a name="line.39"></a> -<span class="sourceLineNo">040</span> + ClassSize.TIMERANGE);<a name="line.40"></a> -<span class="sourceLineNo">041</span><a name="line.41"></a> -<span class="sourceLineNo">042</span> /**<a name="line.42"></a> -<span class="sourceLineNo">043</span> * This is an immutable segment so use the read-only TimeRange rather than the heavy-weight<a name="line.43"></a> -<span class="sourceLineNo">044</span> * TimeRangeTracker with all its synchronization when doing time range stuff.<a name="line.44"></a> -<span class="sourceLineNo">045</span> */<a name="line.45"></a> -<span class="sourceLineNo">046</span> private final TimeRange timeRange;<a name="line.46"></a> -<span class="sourceLineNo">047</span><a name="line.47"></a> -<span class="sourceLineNo">048</span> // each sub-type of immutable segment knows whether it is flat or not<a name="line.48"></a> -<span class="sourceLineNo">049</span> protected abstract boolean canBeFlattened();<a name="line.49"></a> +<span class="sourceLineNo">038</span> public static final long DEEP_OVERHEAD = Segment.DEEP_OVERHEAD + ClassSize.NON_SYNC_TIMERANGE_TRACKER;<a name="line.38"></a> +<span class="sourceLineNo">039</span><a name="line.39"></a> +<span class="sourceLineNo">040</span> // each sub-type of immutable segment knows whether it is flat or not<a name="line.40"></a> +<span class="sourceLineNo">041</span> protected abstract boolean canBeFlattened();<a name="line.41"></a> +<span class="sourceLineNo">042</span><a name="line.42"></a> +<span class="sourceLineNo">043</span> ///////////////////// CONSTRUCTORS /////////////////////<a name="line.43"></a> +<span class="sourceLineNo">044</span> /**------------------------------------------------------------------------<a name="line.44"></a> +<span class="sourceLineNo">045</span> * Empty C-tor to be used only for CompositeImmutableSegment<a name="line.45"></a> +<span class="sourceLineNo">046</span> */<a name="line.46"></a> +<span class="sourceLineNo">047</span> protected ImmutableSegment(CellComparator comparator) {<a name="line.47"></a> +<span class="sourceLineNo">048</span> super(comparator, TimeRangeTracker.create(TimeRangeTracker.Type.NON_SYNC));<a name="line.48"></a> +<span class="sourceLineNo">049</span> }<a name="line.49"></a> <span class="sourceLineNo">050</span><a name="line.50"></a> -<span class="sourceLineNo">051</span> ///////////////////// CONSTRUCTORS /////////////////////<a name="line.51"></a> -<span class="sourceLineNo">052</span> /**------------------------------------------------------------------------<a name="line.52"></a> -<span class="sourceLineNo">053</span> * Empty C-tor to be used only for CompositeImmutableSegment<a name="line.53"></a> -<span class="sourceLineNo">054</span> */<a name="line.54"></a> -<span class="sourceLineNo">055</span> protected ImmutableSegment(CellComparator comparator) {<a name="line.55"></a> -<span class="sourceLineNo">056</span> super(comparator);<a name="line.56"></a> -<span class="sourceLineNo">057</span> this.timeRange = null;<a name="line.57"></a> -<span class="sourceLineNo">058</span> }<a name="line.58"></a> -<span class="sourceLineNo">059</span><a name="line.59"></a> -<span class="sourceLineNo">060</span> /**------------------------------------------------------------------------<a name="line.60"></a> -<span class="sourceLineNo">061</span> * C-tor to be used to build the derived classes<a name="line.61"></a> +<span class="sourceLineNo">051</span> /**------------------------------------------------------------------------<a name="line.51"></a> +<span class="sourceLineNo">052</span> * C-tor to be used to build the derived classes<a name="line.52"></a> +<span class="sourceLineNo">053</span> */<a name="line.53"></a> +<span class="sourceLineNo">054</span> protected ImmutableSegment(CellSet cs, CellComparator comparator, MemStoreLAB memStoreLAB) {<a name="line.54"></a> +<span class="sourceLineNo">055</span> super(cs, comparator, memStoreLAB, TimeRangeTracker.create(TimeRangeTracker.Type.NON_SYNC));<a name="line.55"></a> +<span class="sourceLineNo">056</span> }<a name="line.56"></a> +<span class="sourceLineNo">057</span><a name="line.57"></a> +<span class="sourceLineNo">058</span> /**------------------------------------------------------------------------<a name="line.58"></a> +<span class="sourceLineNo">059</span> * Copy C-tor to be used when new CSLMImmutableSegment (derived) is being built from a Mutable one.<a name="line.59"></a> +<span class="sourceLineNo">060</span> * This C-tor should be used when active MutableSegment is pushed into the compaction<a name="line.60"></a> +<span class="sourceLineNo">061</span> * pipeline and becomes an ImmutableSegment.<a name="line.61"></a> <span class="sourceLineNo">062</span> */<a name="line.62"></a> -<span class="sourceLineNo">063</span> protected ImmutableSegment(CellSet cs, CellComparator comparator, MemStoreLAB memStoreLAB) {<a name="line.63"></a> -<span class="sourceLineNo">064</span> super(cs, comparator, memStoreLAB);<a name="line.64"></a> -<span class="sourceLineNo">065</span> this.timeRange = this.timeRangeTracker == null ? null : this.timeRangeTracker.toTimeRange();<a name="line.65"></a> -<span class="sourceLineNo">066</span> }<a name="line.66"></a> +<span class="sourceLineNo">063</span> protected ImmutableSegment(Segment segment) {<a name="line.63"></a> +<span class="sourceLineNo">064</span> super(segment);<a name="line.64"></a> +<span class="sourceLineNo">065</span> }<a name="line.65"></a> +<span class="sourceLineNo">066</span><a name="line.66"></a> <span class="sourceLineNo">067</span><a name="line.67"></a> -<span class="sourceLineNo">068</span> /**------------------------------------------------------------------------<a name="line.68"></a> -<span class="sourceLineNo">069</span> * Copy C-tor to be used when new CSLMImmutableSegment (derived) is being built from a Mutable one.<a name="line.69"></a> -<span class="sourceLineNo">070</span> * This C-tor should be used when active MutableSegment is pushed into the compaction<a name="line.70"></a> -<span class="sourceLineNo">071</span> * pipeline and becomes an ImmutableSegment.<a name="line.71"></a> -<span class="sourceLineNo">072</span> */<a name="line.72"></a> -<span class="sourceLineNo">073</span> protected ImmutableSegment(Segment segment) {<a name="line.73"></a> -<span class="sourceLineNo">074</span> super(segment);<a name="line.74"></a> -<span class="sourceLineNo">075</span> this.timeRange = this.timeRangeTracker == null ? null : this.timeRangeTracker.toTimeRange();<a name="line.75"></a> -<span class="sourceLineNo">076</span> }<a name="line.76"></a> -<span class="sourceLineNo">077</span><a name="line.77"></a> -<span class="sourceLineNo">078</span><a name="line.78"></a> -<span class="sourceLineNo">079</span> ///////////////////// PUBLIC METHODS /////////////////////<a name="line.79"></a> -<span class="sourceLineNo">080</span> @Override<a name="line.80"></a> -<span class="sourceLineNo">081</span> public boolean shouldSeek(TimeRange tr, long oldestUnexpiredTS) {<a name="line.81"></a> -<span class="sourceLineNo">082</span> return this.timeRange.includesTimeRange(tr) &&<a name="line.82"></a> -<span class="sourceLineNo">083</span> this.timeRange.getMax() >= oldestUnexpiredTS;<a name="line.83"></a> -<span class="sourceLineNo">084</span> }<a name="line.84"></a> -<span class="sourceLineNo">085</span><a name="line.85"></a> -<span class="sourceLineNo">086</span> @Override<a name="line.86"></a> -<span class="sourceLineNo">087</span> public long getMinTimestamp() {<a name="line.87"></a> -<span class="sourceLineNo">088</span> return this.timeRange.getMin();<a name="line.88"></a> -<span class="sourceLineNo">089</span> }<a name="line.89"></a> -<span class="sourceLineNo">090</span><a name="line.90"></a> -<span class="sourceLineNo">091</span> public int getNumOfSegments() {<a name="line.91"></a> -<span class="sourceLineNo">092</span> return 1;<a name="line.92"></a> -<span class="sourceLineNo">093</span> }<a name="line.93"></a> -<span class="sourceLineNo">094</span><a name="line.94"></a> -<span class="sourceLineNo">095</span> public List<Segment> getAllSegments() {<a name="line.95"></a> -<span class="sourceLineNo">096</span> List<Segment> res = new ArrayList<>(Arrays.asList(this));<a name="line.96"></a> -<span class="sourceLineNo">097</span> return res;<a name="line.97"></a> -<span class="sourceLineNo">098</span> }<a name="line.98"></a> -<span class="sourceLineNo">099</span>}<a name="line.99"></a> +<span class="sourceLineNo">068</span> ///////////////////// PUBLIC METHODS /////////////////////<a name="line.68"></a> +<span class="sourceLineNo">069</span><a name="line.69"></a> +<span class="sourceLineNo">070</span> public int getNumOfSegments() {<a name="line.70"></a> +<span class="sourceLineNo">071</span> return 1;<a name="line.71"></a> +<span class="sourceLineNo">072</span> }<a name="line.72"></a> +<span class="sourceLineNo">073</span><a name="line.73"></a> +<span class="sourceLineNo">074</span> public List<Segment> getAllSegments() {<a name="line.74"></a> +<span class="sourceLineNo">075</span> List<Segment> res = new ArrayList<>(Arrays.asList(this));<a name="line.75"></a> +<span class="sourceLineNo">076</span> return res;<a name="line.76"></a> +<span class="sourceLineNo">077</span> }<a name="line.77"></a> +<span class="sourceLineNo">078</span>}<a name="line.78"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/MutableSegment.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/MutableSegment.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/MutableSegment.html index 3a75b04..78ed911 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/MutableSegment.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/MutableSegment.html @@ -46,95 +46,86 @@ <span class="sourceLineNo">038</span>@InterfaceAudience.Private<a name="line.38"></a> <span class="sourceLineNo">039</span>public class MutableSegment extends Segment {<a name="line.39"></a> <span class="sourceLineNo">040</span><a name="line.40"></a> -<span class="sourceLineNo">041</span> public final static long DEEP_OVERHEAD = Segment.DEEP_OVERHEAD + ClassSize.CONCURRENT_SKIPLISTMAP;<a name="line.41"></a> -<span class="sourceLineNo">042</span><a name="line.42"></a> -<span class="sourceLineNo">043</span> protected MutableSegment(CellSet cellSet, CellComparator comparator, MemStoreLAB memStoreLAB) {<a name="line.43"></a> -<span class="sourceLineNo">044</span> super(cellSet, comparator, memStoreLAB);<a name="line.44"></a> -<span class="sourceLineNo">045</span> incSize(0,DEEP_OVERHEAD); // update the mutable segment metadata<a name="line.45"></a> -<span class="sourceLineNo">046</span> }<a name="line.46"></a> -<span class="sourceLineNo">047</span><a name="line.47"></a> -<span class="sourceLineNo">048</span> /**<a name="line.48"></a> -<span class="sourceLineNo">049</span> * Adds the given cell into the segment<a name="line.49"></a> -<span class="sourceLineNo">050</span> * @param cell the cell to add<a name="line.50"></a> -<span class="sourceLineNo">051</span> * @param mslabUsed whether using MSLAB<a name="line.51"></a> -<span class="sourceLineNo">052</span> * @param memstoreSize<a name="line.52"></a> -<span class="sourceLineNo">053</span> */<a name="line.53"></a> -<span class="sourceLineNo">054</span> public void add(Cell cell, boolean mslabUsed, MemStoreSize memstoreSize) {<a name="line.54"></a> -<span class="sourceLineNo">055</span> internalAdd(cell, mslabUsed, memstoreSize);<a name="line.55"></a> -<span class="sourceLineNo">056</span> }<a name="line.56"></a> -<span class="sourceLineNo">057</span><a name="line.57"></a> -<span class="sourceLineNo">058</span> public void upsert(Cell cell, long readpoint, MemStoreSize memstoreSize) {<a name="line.58"></a> -<span class="sourceLineNo">059</span> internalAdd(cell, false, memstoreSize);<a name="line.59"></a> -<span class="sourceLineNo">060</span><a name="line.60"></a> -<span class="sourceLineNo">061</span> // Get the Cells for the row/family/qualifier regardless of timestamp.<a name="line.61"></a> -<span class="sourceLineNo">062</span> // For this case we want to clean up any other puts<a name="line.62"></a> -<span class="sourceLineNo">063</span> Cell firstCell = CellUtil.createFirstOnRowColTS(cell, HConstants.LATEST_TIMESTAMP);<a name="line.63"></a> -<span class="sourceLineNo">064</span> SortedSet<Cell> ss = this.tailSet(firstCell);<a name="line.64"></a> -<span class="sourceLineNo">065</span> Iterator<Cell> it = ss.iterator();<a name="line.65"></a> -<span class="sourceLineNo">066</span> // versions visible to oldest scanner<a name="line.66"></a> -<span class="sourceLineNo">067</span> int versionsVisible = 0;<a name="line.67"></a> -<span class="sourceLineNo">068</span> while (it.hasNext()) {<a name="line.68"></a> -<span class="sourceLineNo">069</span> Cell cur = it.next();<a name="line.69"></a> -<span class="sourceLineNo">070</span><a name="line.70"></a> -<span class="sourceLineNo">071</span> if (cell == cur) {<a name="line.71"></a> -<span class="sourceLineNo">072</span> // ignore the one just put in<a name="line.72"></a> -<span class="sourceLineNo">073</span> continue;<a name="line.73"></a> -<span class="sourceLineNo">074</span> }<a name="line.74"></a> -<span class="sourceLineNo">075</span> // check that this is the row and column we are interested in, otherwise bail<a name="line.75"></a> -<span class="sourceLineNo">076</span> if (CellUtil.matchingRows(cell, cur) && CellUtil.matchingQualifier(cell, cur)) {<a name="line.76"></a> -<span class="sourceLineNo">077</span> // only remove Puts that concurrent scanners cannot possibly see<a name="line.77"></a> -<span class="sourceLineNo">078</span> if (cur.getTypeByte() == KeyValue.Type.Put.getCode() && cur.getSequenceId() <= readpoint) {<a name="line.78"></a> -<span class="sourceLineNo">079</span> if (versionsVisible >= 1) {<a name="line.79"></a> -<span class="sourceLineNo">080</span> // if we get here we have seen at least one version visible to the oldest scanner,<a name="line.80"></a> -<span class="sourceLineNo">081</span> // which means we can prove that no scanner will see this version<a name="line.81"></a> -<span class="sourceLineNo">082</span><a name="line.82"></a> -<span class="sourceLineNo">083</span> // false means there was a change, so give us the size.<a name="line.83"></a> -<span class="sourceLineNo">084</span> // TODO when the removed cell ie.'cur' having its data in MSLAB, we can not release that<a name="line.84"></a> -<span class="sourceLineNo">085</span> // area. Only the Cell object as such going way. We need to consider cellLen to be<a name="line.85"></a> -<span class="sourceLineNo">086</span> // decreased there as 0 only. Just keeping it as existing code now. We need to know the<a name="line.86"></a> -<span class="sourceLineNo">087</span> // removed cell is from MSLAB or not. Will do once HBASE-16438 is in<a name="line.87"></a> -<span class="sourceLineNo">088</span> int cellLen = getCellLength(cur);<a name="line.88"></a> -<span class="sourceLineNo">089</span> long heapSize = heapSizeChange(cur, true);<a name="line.89"></a> -<span class="sourceLineNo">090</span> this.incSize(-cellLen, -heapSize);<a name="line.90"></a> -<span class="sourceLineNo">091</span> if (memstoreSize != null) {<a name="line.91"></a> -<span class="sourceLineNo">092</span> memstoreSize.decMemStoreSize(cellLen, heapSize);<a name="line.92"></a> -<span class="sourceLineNo">093</span> }<a name="line.93"></a> -<span class="sourceLineNo">094</span> it.remove();<a name="line.94"></a> -<span class="sourceLineNo">095</span> } else {<a name="line.95"></a> -<span class="sourceLineNo">096</span> versionsVisible++;<a name="line.96"></a> -<span class="sourceLineNo">097</span> }<a name="line.97"></a> -<span class="sourceLineNo">098</span> }<a name="line.98"></a> -<span class="sourceLineNo">099</span> } else {<a name="line.99"></a> -<span class="sourceLineNo">100</span> // past the row or column, done<a name="line.100"></a> -<span class="sourceLineNo">101</span> break;<a name="line.101"></a> -<span class="sourceLineNo">102</span> }<a name="line.102"></a> -<span class="sourceLineNo">103</span> }<a name="line.103"></a> -<span class="sourceLineNo">104</span> }<a name="line.104"></a> -<span class="sourceLineNo">105</span><a name="line.105"></a> -<span class="sourceLineNo">106</span> /**<a name="line.106"></a> -<span class="sourceLineNo">107</span> * Returns the first cell in the segment<a name="line.107"></a> -<span class="sourceLineNo">108</span> * @return the first cell in the segment<a name="line.108"></a> -<span class="sourceLineNo">109</span> */<a name="line.109"></a> -<span class="sourceLineNo">110</span> @VisibleForTesting<a name="line.110"></a> -<span class="sourceLineNo">111</span> Cell first() {<a name="line.111"></a> -<span class="sourceLineNo">112</span> return this.getCellSet().first();<a name="line.112"></a> -<span class="sourceLineNo">113</span> }<a name="line.113"></a> -<span class="sourceLineNo">114</span><a name="line.114"></a> -<span class="sourceLineNo">115</span> @Override<a name="line.115"></a> -<span class="sourceLineNo">116</span> public boolean shouldSeek(TimeRange tr, long oldestUnexpiredTS) {<a name="line.116"></a> -<span class="sourceLineNo">117</span> return (this.timeRangeTracker.includesTimeRange(tr)<a name="line.117"></a> -<span class="sourceLineNo">118</span> && (this.timeRangeTracker.getMax() >= oldestUnexpiredTS));<a name="line.118"></a> +<span class="sourceLineNo">041</span> public final static long DEEP_OVERHEAD = Segment.DEEP_OVERHEAD<a name="line.41"></a> +<span class="sourceLineNo">042</span> + ClassSize.CONCURRENT_SKIPLISTMAP<a name="line.42"></a> +<span class="sourceLineNo">043</span> + ClassSize.SYNC_TIMERANGE_TRACKER;<a name="line.43"></a> +<span class="sourceLineNo">044</span><a name="line.44"></a> +<span class="sourceLineNo">045</span> protected MutableSegment(CellSet cellSet, CellComparator comparator, MemStoreLAB memStoreLAB) {<a name="line.45"></a> +<span class="sourceLineNo">046</span> super(cellSet, comparator, memStoreLAB, TimeRangeTracker.create(TimeRangeTracker.Type.SYNC));<a name="line.46"></a> +<span class="sourceLineNo">047</span> incSize(0,DEEP_OVERHEAD); // update the mutable segment metadata<a name="line.47"></a> +<span class="sourceLineNo">048</span> }<a name="line.48"></a> +<span class="sourceLineNo">049</span><a name="line.49"></a> +<span class="sourceLineNo">050</span> /**<a name="line.50"></a> +<span class="sourceLineNo">051</span> * Adds the given cell into the segment<a name="line.51"></a> +<span class="sourceLineNo">052</span> * @param cell the cell to add<a name="line.52"></a> +<span class="sourceLineNo">053</span> * @param mslabUsed whether using MSLAB<a name="line.53"></a> +<span class="sourceLineNo">054</span> * @param memstoreSize<a name="line.54"></a> +<span class="sourceLineNo">055</span> */<a name="line.55"></a> +<span class="sourceLineNo">056</span> public void add(Cell cell, boolean mslabUsed, MemStoreSize memstoreSize) {<a name="line.56"></a> +<span class="sourceLineNo">057</span> internalAdd(cell, mslabUsed, memstoreSize);<a name="line.57"></a> +<span class="sourceLineNo">058</span> }<a name="line.58"></a> +<span class="sourceLineNo">059</span><a name="line.59"></a> +<span class="sourceLineNo">060</span> public void upsert(Cell cell, long readpoint, MemStoreSize memstoreSize) {<a name="line.60"></a> +<span class="sourceLineNo">061</span> internalAdd(cell, false, memstoreSize);<a name="line.61"></a> +<span class="sourceLineNo">062</span><a name="line.62"></a> +<span class="sourceLineNo">063</span> // Get the Cells for the row/family/qualifier regardless of timestamp.<a name="line.63"></a> +<span class="sourceLineNo">064</span> // For this case we want to clean up any other puts<a name="line.64"></a> +<span class="sourceLineNo">065</span> Cell firstCell = CellUtil.createFirstOnRowColTS(cell, HConstants.LATEST_TIMESTAMP);<a name="line.65"></a> +<span class="sourceLineNo">066</span> SortedSet<Cell> ss = this.tailSet(firstCell);<a name="line.66"></a> +<span class="sourceLineNo">067</span> Iterator<Cell> it = ss.iterator();<a name="line.67"></a> +<span class="sourceLineNo">068</span> // versions visible to oldest scanner<a name="line.68"></a> +<span class="sourceLineNo">069</span> int versionsVisible = 0;<a name="line.69"></a> +<span class="sourceLineNo">070</span> while (it.hasNext()) {<a name="line.70"></a> +<span class="sourceLineNo">071</span> Cell cur = it.next();<a name="line.71"></a> +<span class="sourceLineNo">072</span><a name="line.72"></a> +<span class="sourceLineNo">073</span> if (cell == cur) {<a name="line.73"></a> +<span class="sourceLineNo">074</span> // ignore the one just put in<a name="line.74"></a> +<span class="sourceLineNo">075</span> continue;<a name="line.75"></a> +<span class="sourceLineNo">076</span> }<a name="line.76"></a> +<span class="sourceLineNo">077</span> // check that this is the row and column we are interested in, otherwise bail<a name="line.77"></a> +<span class="sourceLineNo">078</span> if (CellUtil.matchingRows(cell, cur) && CellUtil.matchingQualifier(cell, cur)) {<a name="line.78"></a> +<span class="sourceLineNo">079</span> // only remove Puts that concurrent scanners cannot possibly see<a name="line.79"></a> +<span class="sourceLineNo">080</span> if (cur.getTypeByte() == KeyValue.Type.Put.getCode() && cur.getSequenceId() <= readpoint) {<a name="line.80"></a> +<span class="sourceLineNo">081</span> if (versionsVisible >= 1) {<a name="line.81"></a> +<span class="sourceLineNo">082</span> // if we get here we have seen at least one version visible to the oldest scanner,<a name="line.82"></a> +<span class="sourceLineNo">083</span> // which means we can prove that no scanner will see this version<a name="line.83"></a> +<span class="sourceLineNo">084</span><a name="line.84"></a> +<span class="sourceLineNo">085</span> // false means there was a change, so give us the size.<a name="line.85"></a> +<span class="sourceLineNo">086</span> // TODO when the removed cell ie.'cur' having its data in MSLAB, we can not release that<a name="line.86"></a> +<span class="sourceLineNo">087</span> // area. Only the Cell object as such going way. We need to consider cellLen to be<a name="line.87"></a> +<span class="sourceLineNo">088</span> // decreased there as 0 only. Just keeping it as existing code now. We need to know the<a name="line.88"></a> +<span class="sourceLineNo">089</span> // removed cell is from MSLAB or not. Will do once HBASE-16438 is in<a name="line.89"></a> +<span class="sourceLineNo">090</span> int cellLen = getCellLength(cur);<a name="line.90"></a> +<span class="sourceLineNo">091</span> long heapSize = heapSizeChange(cur, true);<a name="line.91"></a> +<span class="sourceLineNo">092</span> this.incSize(-cellLen, -heapSize);<a name="line.92"></a> +<span class="sourceLineNo">093</span> if (memstoreSize != null) {<a name="line.93"></a> +<span class="sourceLineNo">094</span> memstoreSize.decMemStoreSize(cellLen, heapSize);<a name="line.94"></a> +<span class="sourceLineNo">095</span> }<a name="line.95"></a> +<span class="sourceLineNo">096</span> it.remove();<a name="line.96"></a> +<span class="sourceLineNo">097</span> } else {<a name="line.97"></a> +<span class="sourceLineNo">098</span> versionsVisible++;<a name="line.98"></a> +<span class="sourceLineNo">099</span> }<a name="line.99"></a> +<span class="sourceLineNo">100</span> }<a name="line.100"></a> +<span class="sourceLineNo">101</span> } else {<a name="line.101"></a> +<span class="sourceLineNo">102</span> // past the row or column, done<a name="line.102"></a> +<span class="sourceLineNo">103</span> break;<a name="line.103"></a> +<span class="sourceLineNo">104</span> }<a name="line.104"></a> +<span class="sourceLineNo">105</span> }<a name="line.105"></a> +<span class="sourceLineNo">106</span> }<a name="line.106"></a> +<span class="sourceLineNo">107</span><a name="line.107"></a> +<span class="sourceLineNo">108</span> /**<a name="line.108"></a> +<span class="sourceLineNo">109</span> * Returns the first cell in the segment<a name="line.109"></a> +<span class="sourceLineNo">110</span> * @return the first cell in the segment<a name="line.110"></a> +<span class="sourceLineNo">111</span> */<a name="line.111"></a> +<span class="sourceLineNo">112</span> @VisibleForTesting<a name="line.112"></a> +<span class="sourceLineNo">113</span> Cell first() {<a name="line.113"></a> +<span class="sourceLineNo">114</span> return this.getCellSet().first();<a name="line.114"></a> +<span class="sourceLineNo">115</span> }<a name="line.115"></a> +<span class="sourceLineNo">116</span><a name="line.116"></a> +<span class="sourceLineNo">117</span> @Override protected long indexEntrySize() {<a name="line.117"></a> +<span class="sourceLineNo">118</span> return ClassSize.CONCURRENT_SKIPLISTMAP_ENTRY;<a name="line.118"></a> <span class="sourceLineNo">119</span> }<a name="line.119"></a> -<span class="sourceLineNo">120</span><a name="line.120"></a> -<span class="sourceLineNo">121</span> @Override<a name="line.121"></a> -<span class="sourceLineNo">122</span> public long getMinTimestamp() {<a name="line.122"></a> -<span class="sourceLineNo">123</span> return this.timeRangeTracker.getMin();<a name="line.123"></a> -<span class="sourceLineNo">124</span> }<a name="line.124"></a> -<span class="sourceLineNo">125</span><a name="line.125"></a> -<span class="sourceLineNo">126</span> @Override protected long indexEntrySize() {<a name="line.126"></a> -<span class="sourceLineNo">127</span> return ClassSize.CONCURRENT_SKIPLISTMAP_ENTRY;<a name="line.127"></a> -<span class="sourceLineNo">128</span> }<a name="line.128"></a> -<span class="sourceLineNo">129</span>}<a name="line.129"></a> +<span class="sourceLineNo">120</span>}<a name="line.120"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html index ff4d273..c1e6578 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html @@ -558,7 +558,7 @@ <span class="sourceLineNo">550</span> private void mutateRows(final HRegion region,<a name="line.550"></a> <span class="sourceLineNo">551</span> final List<ClientProtos.Action> actions,<a name="line.551"></a> <span class="sourceLineNo">552</span> final CellScanner cellScanner, RegionActionResult.Builder builder) throws IOException {<a name="line.552"></a> -<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.553"></a> +<span class="sourceLineNo">553</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.553"></a> <span class="sourceLineNo">554</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.554"></a> <span class="sourceLineNo">555</span> }<a name="line.555"></a> <span class="sourceLineNo">556</span> RowMutations rm = null;<a name="line.556"></a> @@ -612,7 +612,7 @@ <span class="sourceLineNo">604</span> final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier,<a name="line.604"></a> <span class="sourceLineNo">605</span> CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder,<a name="line.605"></a> <span class="sourceLineNo">606</span> ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException {<a name="line.606"></a> -<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.607"></a> +<span class="sourceLineNo">607</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.607"></a> <span class="sourceLineNo">608</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.608"></a> <span class="sourceLineNo">609</span> }<a name="line.609"></a> <span class="sourceLineNo">610</span> RowMutations rm = null;<a name="line.610"></a> @@ -991,7 +991,7 @@ <span class="sourceLineNo">983</span> quota.addMutation(mutation);<a name="line.983"></a> <span class="sourceLineNo">984</span> }<a name="line.984"></a> <span class="sourceLineNo">985</span><a name="line.985"></a> -<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.986"></a> +<span class="sourceLineNo">986</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.986"></a> <span class="sourceLineNo">987</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.987"></a> <span class="sourceLineNo">988</span> }<a name="line.988"></a> <span class="sourceLineNo">989</span><a name="line.989"></a> @@ -1103,7 +1103,7 @@ <span class="sourceLineNo">1095</span> }<a name="line.1095"></a> <span class="sourceLineNo">1096</span> requestCount.increment();<a name="line.1096"></a> <span class="sourceLineNo">1097</span> requestRowActionCount.add(mutations.size());<a name="line.1097"></a> -<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.1098"></a> +<span class="sourceLineNo">1098</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.1098"></a> <span class="sourceLineNo">1099</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.1099"></a> <span class="sourceLineNo">1100</span> }<a name="line.1100"></a> <span class="sourceLineNo">1101</span> return region.batchReplay(mutations.toArray(<a name="line.1101"></a> @@ -2705,7 +2705,7 @@ <span class="sourceLineNo">2697</span> HRegion region = getRegion(request.getRegion());<a name="line.2697"></a> <span class="sourceLineNo">2698</span> MutateResponse.Builder builder = MutateResponse.newBuilder();<a name="line.2698"></a> <span class="sourceLineNo">2699</span> MutationProto mutation = request.getMutation();<a name="line.2699"></a> -<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaTable()) {<a name="line.2700"></a> +<span class="sourceLineNo">2700</span> if (!region.getRegionInfo().isMetaRegion()) {<a name="line.2700"></a> <span class="sourceLineNo">2701</span> regionServer.cacheFlusher.reclaimMemStoreMemory();<a name="line.2701"></a> <span class="sourceLineNo">2702</span> }<a name="line.2702"></a> <span class="sourceLineNo">2703</span> long nonceGroup = request.hasNonceGroup() ? request.getNonceGroup() : HConstants.NO_NONCE;<a name="line.2703"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.Operation.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.Operation.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.Operation.html index 22c8c0a..7155188 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.Operation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.Operation.html @@ -461,40 +461,36 @@ <span class="sourceLineNo">453</span> */<a name="line.453"></a> <span class="sourceLineNo">454</span> void put(Put put) throws IOException;<a name="line.454"></a> <span class="sourceLineNo">455</span><a name="line.455"></a> -<span class="sourceLineNo">456</span> /** @return the coprocessor host */<a name="line.456"></a> -<span class="sourceLineNo">457</span> // TODO To be removed by HBASE-18954<a name="line.457"></a> -<span class="sourceLineNo">458</span> RegionCoprocessorHost getCoprocessorHost();<a name="line.458"></a> +<span class="sourceLineNo">456</span> ///////////////////////////////////////////////////////////////////////////<a name="line.456"></a> +<span class="sourceLineNo">457</span> // Flushes, compactions, splits, etc.<a name="line.457"></a> +<span class="sourceLineNo">458</span> // Wizards only, please<a name="line.458"></a> <span class="sourceLineNo">459</span><a name="line.459"></a> -<span class="sourceLineNo">460</span> ///////////////////////////////////////////////////////////////////////////<a name="line.460"></a> -<span class="sourceLineNo">461</span> // Flushes, compactions, splits, etc.<a name="line.461"></a> -<span class="sourceLineNo">462</span> // Wizards only, please<a name="line.462"></a> -<span class="sourceLineNo">463</span><a name="line.463"></a> -<span class="sourceLineNo">464</span> /**<a name="line.464"></a> -<span class="sourceLineNo">465</span> * Trigger major compaction on all stores in the region.<a name="line.465"></a> -<span class="sourceLineNo">466</span> * <p><a name="line.466"></a> -<span class="sourceLineNo">467</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.467"></a> -<span class="sourceLineNo">468</span> * CompactSplitThread.<a name="line.468"></a> -<span class="sourceLineNo">469</span> * @throws IOException<a name="line.469"></a> -<span class="sourceLineNo">470</span> */<a name="line.470"></a> -<span class="sourceLineNo">471</span> void triggerMajorCompaction() throws IOException;<a name="line.471"></a> -<span class="sourceLineNo">472</span><a name="line.472"></a> -<span class="sourceLineNo">473</span> /**<a name="line.473"></a> -<span class="sourceLineNo">474</span> * @return if a given region is in compaction now.<a name="line.474"></a> -<span class="sourceLineNo">475</span> */<a name="line.475"></a> -<span class="sourceLineNo">476</span> CompactionState getCompactionState();<a name="line.476"></a> -<span class="sourceLineNo">477</span><a name="line.477"></a> -<span class="sourceLineNo">478</span> /**<a name="line.478"></a> -<span class="sourceLineNo">479</span> * Request compaction on this region.<a name="line.479"></a> -<span class="sourceLineNo">480</span> */<a name="line.480"></a> -<span class="sourceLineNo">481</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.481"></a> -<span class="sourceLineNo">482</span> throws IOException;<a name="line.482"></a> -<span class="sourceLineNo">483</span><a name="line.483"></a> -<span class="sourceLineNo">484</span> /**<a name="line.484"></a> -<span class="sourceLineNo">485</span> * Request compaction for the given family<a name="line.485"></a> -<span class="sourceLineNo">486</span> */<a name="line.486"></a> -<span class="sourceLineNo">487</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.487"></a> -<span class="sourceLineNo">488</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.488"></a> -<span class="sourceLineNo">489</span>}<a name="line.489"></a> +<span class="sourceLineNo">460</span> /**<a name="line.460"></a> +<span class="sourceLineNo">461</span> * Trigger major compaction on all stores in the region.<a name="line.461"></a> +<span class="sourceLineNo">462</span> * <p><a name="line.462"></a> +<span class="sourceLineNo">463</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.463"></a> +<span class="sourceLineNo">464</span> * CompactSplitThread.<a name="line.464"></a> +<span class="sourceLineNo">465</span> * @throws IOException<a name="line.465"></a> +<span class="sourceLineNo">466</span> */<a name="line.466"></a> +<span class="sourceLineNo">467</span> void triggerMajorCompaction() throws IOException;<a name="line.467"></a> +<span class="sourceLineNo">468</span><a name="line.468"></a> +<span class="sourceLineNo">469</span> /**<a name="line.469"></a> +<span class="sourceLineNo">470</span> * @return if a given region is in compaction now.<a name="line.470"></a> +<span class="sourceLineNo">471</span> */<a name="line.471"></a> +<span class="sourceLineNo">472</span> CompactionState getCompactionState();<a name="line.472"></a> +<span class="sourceLineNo">473</span><a name="line.473"></a> +<span class="sourceLineNo">474</span> /**<a name="line.474"></a> +<span class="sourceLineNo">475</span> * Request compaction on this region.<a name="line.475"></a> +<span class="sourceLineNo">476</span> */<a name="line.476"></a> +<span class="sourceLineNo">477</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.477"></a> +<span class="sourceLineNo">478</span> throws IOException;<a name="line.478"></a> +<span class="sourceLineNo">479</span><a name="line.479"></a> +<span class="sourceLineNo">480</span> /**<a name="line.480"></a> +<span class="sourceLineNo">481</span> * Request compaction for the given family<a name="line.481"></a> +<span class="sourceLineNo">482</span> */<a name="line.482"></a> +<span class="sourceLineNo">483</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.483"></a> +<span class="sourceLineNo">484</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.484"></a> +<span class="sourceLineNo">485</span>}<a name="line.485"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.RowLock.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.RowLock.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.RowLock.html index 22c8c0a..7155188 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.RowLock.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.RowLock.html @@ -461,40 +461,36 @@ <span class="sourceLineNo">453</span> */<a name="line.453"></a> <span class="sourceLineNo">454</span> void put(Put put) throws IOException;<a name="line.454"></a> <span class="sourceLineNo">455</span><a name="line.455"></a> -<span class="sourceLineNo">456</span> /** @return the coprocessor host */<a name="line.456"></a> -<span class="sourceLineNo">457</span> // TODO To be removed by HBASE-18954<a name="line.457"></a> -<span class="sourceLineNo">458</span> RegionCoprocessorHost getCoprocessorHost();<a name="line.458"></a> +<span class="sourceLineNo">456</span> ///////////////////////////////////////////////////////////////////////////<a name="line.456"></a> +<span class="sourceLineNo">457</span> // Flushes, compactions, splits, etc.<a name="line.457"></a> +<span class="sourceLineNo">458</span> // Wizards only, please<a name="line.458"></a> <span class="sourceLineNo">459</span><a name="line.459"></a> -<span class="sourceLineNo">460</span> ///////////////////////////////////////////////////////////////////////////<a name="line.460"></a> -<span class="sourceLineNo">461</span> // Flushes, compactions, splits, etc.<a name="line.461"></a> -<span class="sourceLineNo">462</span> // Wizards only, please<a name="line.462"></a> -<span class="sourceLineNo">463</span><a name="line.463"></a> -<span class="sourceLineNo">464</span> /**<a name="line.464"></a> -<span class="sourceLineNo">465</span> * Trigger major compaction on all stores in the region.<a name="line.465"></a> -<span class="sourceLineNo">466</span> * <p><a name="line.466"></a> -<span class="sourceLineNo">467</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.467"></a> -<span class="sourceLineNo">468</span> * CompactSplitThread.<a name="line.468"></a> -<span class="sourceLineNo">469</span> * @throws IOException<a name="line.469"></a> -<span class="sourceLineNo">470</span> */<a name="line.470"></a> -<span class="sourceLineNo">471</span> void triggerMajorCompaction() throws IOException;<a name="line.471"></a> -<span class="sourceLineNo">472</span><a name="line.472"></a> -<span class="sourceLineNo">473</span> /**<a name="line.473"></a> -<span class="sourceLineNo">474</span> * @return if a given region is in compaction now.<a name="line.474"></a> -<span class="sourceLineNo">475</span> */<a name="line.475"></a> -<span class="sourceLineNo">476</span> CompactionState getCompactionState();<a name="line.476"></a> -<span class="sourceLineNo">477</span><a name="line.477"></a> -<span class="sourceLineNo">478</span> /**<a name="line.478"></a> -<span class="sourceLineNo">479</span> * Request compaction on this region.<a name="line.479"></a> -<span class="sourceLineNo">480</span> */<a name="line.480"></a> -<span class="sourceLineNo">481</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.481"></a> -<span class="sourceLineNo">482</span> throws IOException;<a name="line.482"></a> -<span class="sourceLineNo">483</span><a name="line.483"></a> -<span class="sourceLineNo">484</span> /**<a name="line.484"></a> -<span class="sourceLineNo">485</span> * Request compaction for the given family<a name="line.485"></a> -<span class="sourceLineNo">486</span> */<a name="line.486"></a> -<span class="sourceLineNo">487</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.487"></a> -<span class="sourceLineNo">488</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.488"></a> -<span class="sourceLineNo">489</span>}<a name="line.489"></a> +<span class="sourceLineNo">460</span> /**<a name="line.460"></a> +<span class="sourceLineNo">461</span> * Trigger major compaction on all stores in the region.<a name="line.461"></a> +<span class="sourceLineNo">462</span> * <p><a name="line.462"></a> +<span class="sourceLineNo">463</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.463"></a> +<span class="sourceLineNo">464</span> * CompactSplitThread.<a name="line.464"></a> +<span class="sourceLineNo">465</span> * @throws IOException<a name="line.465"></a> +<span class="sourceLineNo">466</span> */<a name="line.466"></a> +<span class="sourceLineNo">467</span> void triggerMajorCompaction() throws IOException;<a name="line.467"></a> +<span class="sourceLineNo">468</span><a name="line.468"></a> +<span class="sourceLineNo">469</span> /**<a name="line.469"></a> +<span class="sourceLineNo">470</span> * @return if a given region is in compaction now.<a name="line.470"></a> +<span class="sourceLineNo">471</span> */<a name="line.471"></a> +<span class="sourceLineNo">472</span> CompactionState getCompactionState();<a name="line.472"></a> +<span class="sourceLineNo">473</span><a name="line.473"></a> +<span class="sourceLineNo">474</span> /**<a name="line.474"></a> +<span class="sourceLineNo">475</span> * Request compaction on this region.<a name="line.475"></a> +<span class="sourceLineNo">476</span> */<a name="line.476"></a> +<span class="sourceLineNo">477</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.477"></a> +<span class="sourceLineNo">478</span> throws IOException;<a name="line.478"></a> +<span class="sourceLineNo">479</span><a name="line.479"></a> +<span class="sourceLineNo">480</span> /**<a name="line.480"></a> +<span class="sourceLineNo">481</span> * Request compaction for the given family<a name="line.481"></a> +<span class="sourceLineNo">482</span> */<a name="line.482"></a> +<span class="sourceLineNo">483</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.483"></a> +<span class="sourceLineNo">484</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.484"></a> +<span class="sourceLineNo">485</span>}<a name="line.485"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5a2158f2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.html index 22c8c0a..7155188 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/Region.html @@ -461,40 +461,36 @@ <span class="sourceLineNo">453</span> */<a name="line.453"></a> <span class="sourceLineNo">454</span> void put(Put put) throws IOException;<a name="line.454"></a> <span class="sourceLineNo">455</span><a name="line.455"></a> -<span class="sourceLineNo">456</span> /** @return the coprocessor host */<a name="line.456"></a> -<span class="sourceLineNo">457</span> // TODO To be removed by HBASE-18954<a name="line.457"></a> -<span class="sourceLineNo">458</span> RegionCoprocessorHost getCoprocessorHost();<a name="line.458"></a> +<span class="sourceLineNo">456</span> ///////////////////////////////////////////////////////////////////////////<a name="line.456"></a> +<span class="sourceLineNo">457</span> // Flushes, compactions, splits, etc.<a name="line.457"></a> +<span class="sourceLineNo">458</span> // Wizards only, please<a name="line.458"></a> <span class="sourceLineNo">459</span><a name="line.459"></a> -<span class="sourceLineNo">460</span> ///////////////////////////////////////////////////////////////////////////<a name="line.460"></a> -<span class="sourceLineNo">461</span> // Flushes, compactions, splits, etc.<a name="line.461"></a> -<span class="sourceLineNo">462</span> // Wizards only, please<a name="line.462"></a> -<span class="sourceLineNo">463</span><a name="line.463"></a> -<span class="sourceLineNo">464</span> /**<a name="line.464"></a> -<span class="sourceLineNo">465</span> * Trigger major compaction on all stores in the region.<a name="line.465"></a> -<span class="sourceLineNo">466</span> * <p><a name="line.466"></a> -<span class="sourceLineNo">467</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.467"></a> -<span class="sourceLineNo">468</span> * CompactSplitThread.<a name="line.468"></a> -<span class="sourceLineNo">469</span> * @throws IOException<a name="line.469"></a> -<span class="sourceLineNo">470</span> */<a name="line.470"></a> -<span class="sourceLineNo">471</span> void triggerMajorCompaction() throws IOException;<a name="line.471"></a> -<span class="sourceLineNo">472</span><a name="line.472"></a> -<span class="sourceLineNo">473</span> /**<a name="line.473"></a> -<span class="sourceLineNo">474</span> * @return if a given region is in compaction now.<a name="line.474"></a> -<span class="sourceLineNo">475</span> */<a name="line.475"></a> -<span class="sourceLineNo">476</span> CompactionState getCompactionState();<a name="line.476"></a> -<span class="sourceLineNo">477</span><a name="line.477"></a> -<span class="sourceLineNo">478</span> /**<a name="line.478"></a> -<span class="sourceLineNo">479</span> * Request compaction on this region.<a name="line.479"></a> -<span class="sourceLineNo">480</span> */<a name="line.480"></a> -<span class="sourceLineNo">481</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.481"></a> -<span class="sourceLineNo">482</span> throws IOException;<a name="line.482"></a> -<span class="sourceLineNo">483</span><a name="line.483"></a> -<span class="sourceLineNo">484</span> /**<a name="line.484"></a> -<span class="sourceLineNo">485</span> * Request compaction for the given family<a name="line.485"></a> -<span class="sourceLineNo">486</span> */<a name="line.486"></a> -<span class="sourceLineNo">487</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.487"></a> -<span class="sourceLineNo">488</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.488"></a> -<span class="sourceLineNo">489</span>}<a name="line.489"></a> +<span class="sourceLineNo">460</span> /**<a name="line.460"></a> +<span class="sourceLineNo">461</span> * Trigger major compaction on all stores in the region.<a name="line.461"></a> +<span class="sourceLineNo">462</span> * <p><a name="line.462"></a> +<span class="sourceLineNo">463</span> * Compaction will be performed asynchronously to this call by the RegionServer's<a name="line.463"></a> +<span class="sourceLineNo">464</span> * CompactSplitThread.<a name="line.464"></a> +<span class="sourceLineNo">465</span> * @throws IOException<a name="line.465"></a> +<span class="sourceLineNo">466</span> */<a name="line.466"></a> +<span class="sourceLineNo">467</span> void triggerMajorCompaction() throws IOException;<a name="line.467"></a> +<span class="sourceLineNo">468</span><a name="line.468"></a> +<span class="sourceLineNo">469</span> /**<a name="line.469"></a> +<span class="sourceLineNo">470</span> * @return if a given region is in compaction now.<a name="line.470"></a> +<span class="sourceLineNo">471</span> */<a name="line.471"></a> +<span class="sourceLineNo">472</span> CompactionState getCompactionState();<a name="line.472"></a> +<span class="sourceLineNo">473</span><a name="line.473"></a> +<span class="sourceLineNo">474</span> /**<a name="line.474"></a> +<span class="sourceLineNo">475</span> * Request compaction on this region.<a name="line.475"></a> +<span class="sourceLineNo">476</span> */<a name="line.476"></a> +<span class="sourceLineNo">477</span> void requestCompaction(String why, int priority, CompactionLifeCycleTracker tracker, User user)<a name="line.477"></a> +<span class="sourceLineNo">478</span> throws IOException;<a name="line.478"></a> +<span class="sourceLineNo">479</span><a name="line.479"></a> +<span class="sourceLineNo">480</span> /**<a name="line.480"></a> +<span class="sourceLineNo">481</span> * Request compaction for the given family<a name="line.481"></a> +<span class="sourceLineNo">482</span> */<a name="line.482"></a> +<span class="sourceLineNo">483</span> void requestCompaction(byte[] family, String why, int priority,<a name="line.483"></a> +<span class="sourceLineNo">484</span> CompactionLifeCycleTracker tracker, User user) throws IOException;<a name="line.484"></a> +<span class="sourceLineNo">485</span>}<a name="line.485"></a>
