http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteByteBufferCell.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteByteBufferCell.html index 18d00df..3e734a6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteByteBufferCell.html @@ -3143,7 +3143,60 @@ <span class="sourceLineNo">3135</span> return Type.DeleteFamily.getCode();<a name="line.3135"></a> <span class="sourceLineNo">3136</span> }<a name="line.3136"></a> <span class="sourceLineNo">3137</span> }<a name="line.3137"></a> -<span class="sourceLineNo">3138</span>}<a name="line.3138"></a> +<span class="sourceLineNo">3138</span><a name="line.3138"></a> +<span class="sourceLineNo">3139</span> /**<a name="line.3139"></a> +<span class="sourceLineNo">3140</span> * @return An new cell is located following input cell. If both of type and timestamp are<a name="line.3140"></a> +<span class="sourceLineNo">3141</span> * minimum, the input cell will be returned directly.<a name="line.3141"></a> +<span class="sourceLineNo">3142</span> */<a name="line.3142"></a> +<span class="sourceLineNo">3143</span> @InterfaceAudience.Private<a name="line.3143"></a> +<span class="sourceLineNo">3144</span> public static Cell createNextOnRowCol(Cell cell) {<a name="line.3144"></a> +<span class="sourceLineNo">3145</span> long ts = cell.getTimestamp();<a name="line.3145"></a> +<span class="sourceLineNo">3146</span> byte type = cell.getTypeByte();<a name="line.3146"></a> +<span class="sourceLineNo">3147</span> if (type != Type.Minimum.getCode()) {<a name="line.3147"></a> +<span class="sourceLineNo">3148</span> type = KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() - 1].getCode();<a name="line.3148"></a> +<span class="sourceLineNo">3149</span> } else if (ts != HConstants.OLDEST_TIMESTAMP) {<a name="line.3149"></a> +<span class="sourceLineNo">3150</span> ts = ts - 1;<a name="line.3150"></a> +<span class="sourceLineNo">3151</span> type = Type.Maximum.getCode();<a name="line.3151"></a> +<span class="sourceLineNo">3152</span> } else {<a name="line.3152"></a> +<span class="sourceLineNo">3153</span> return cell;<a name="line.3153"></a> +<span class="sourceLineNo">3154</span> }<a name="line.3154"></a> +<span class="sourceLineNo">3155</span> return createNextOnRowCol(cell, ts, type);<a name="line.3155"></a> +<span class="sourceLineNo">3156</span> }<a name="line.3156"></a> +<span class="sourceLineNo">3157</span><a name="line.3157"></a> +<span class="sourceLineNo">3158</span> private static Cell createNextOnRowCol(Cell cell, long ts, byte type) {<a name="line.3158"></a> +<span class="sourceLineNo">3159</span> if (cell instanceof ByteBufferCell) {<a name="line.3159"></a> +<span class="sourceLineNo">3160</span> return new LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),<a name="line.3160"></a> +<span class="sourceLineNo">3161</span> ((ByteBufferCell) cell).getRowPosition(), cell.getRowLength(),<a name="line.3161"></a> +<span class="sourceLineNo">3162</span> ((ByteBufferCell) cell).getFamilyByteBuffer(),<a name="line.3162"></a> +<span class="sourceLineNo">3163</span> ((ByteBufferCell) cell).getFamilyPosition(), cell.getFamilyLength(),<a name="line.3163"></a> +<span class="sourceLineNo">3164</span> ((ByteBufferCell) cell).getQualifierByteBuffer(),<a name="line.3164"></a> +<span class="sourceLineNo">3165</span> ((ByteBufferCell) cell).getQualifierPosition(), cell.getQualifierLength()) {<a name="line.3165"></a> +<span class="sourceLineNo">3166</span> @Override<a name="line.3166"></a> +<span class="sourceLineNo">3167</span> public long getTimestamp() {<a name="line.3167"></a> +<span class="sourceLineNo">3168</span> return ts;<a name="line.3168"></a> +<span class="sourceLineNo">3169</span> }<a name="line.3169"></a> +<span class="sourceLineNo">3170</span><a name="line.3170"></a> +<span class="sourceLineNo">3171</span> @Override<a name="line.3171"></a> +<span class="sourceLineNo">3172</span> public byte getTypeByte() {<a name="line.3172"></a> +<span class="sourceLineNo">3173</span> return type;<a name="line.3173"></a> +<span class="sourceLineNo">3174</span> }<a name="line.3174"></a> +<span class="sourceLineNo">3175</span> };<a name="line.3175"></a> +<span class="sourceLineNo">3176</span> }<a name="line.3176"></a> +<span class="sourceLineNo">3177</span> return new LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength(),<a name="line.3177"></a> +<span class="sourceLineNo">3178</span> cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength(),<a name="line.3178"></a> +<span class="sourceLineNo">3179</span> cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength()) {<a name="line.3179"></a> +<span class="sourceLineNo">3180</span> @Override<a name="line.3180"></a> +<span class="sourceLineNo">3181</span> public long getTimestamp() {<a name="line.3181"></a> +<span class="sourceLineNo">3182</span> return ts;<a name="line.3182"></a> +<span class="sourceLineNo">3183</span> }<a name="line.3183"></a> +<span class="sourceLineNo">3184</span><a name="line.3184"></a> +<span class="sourceLineNo">3185</span> @Override<a name="line.3185"></a> +<span class="sourceLineNo">3186</span> public byte getTypeByte() {<a name="line.3186"></a> +<span class="sourceLineNo">3187</span> return type;<a name="line.3187"></a> +<span class="sourceLineNo">3188</span> }<a name="line.3188"></a> +<span class="sourceLineNo">3189</span> };<a name="line.3189"></a> +<span class="sourceLineNo">3190</span> }<a name="line.3190"></a> +<span class="sourceLineNo">3191</span>}<a name="line.3191"></a>
