Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19178 table.rb use undefined method 'getType' for Cell interface

This commit is contained in:
Guanghao Zhang 2017-11-04 11:02:19 +08:00
parent 35a2b8e53c
commit 349dd5e214
2 changed files with 31 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-shell/src/main/ruby/hbase/table.rb
View File

@ -749,7 +749,7 @@ EOF
end
if org.apache.hadoop.hbase.CellUtil.isDelete(kv)
val = "timestamp=#{kv.getTimestamp}, type=#{org.apache.hadoop.hbase.KeyValue::Type.codeToType(kv.getType)}"
val = "timestamp=#{kv.getTimestamp}, type=#{org.apache.hadoop.hbase.KeyValue::Type.codeToType(kv.getTypeByte)}"
else
val = "timestamp=#{kv.getTimestamp}, value=#{convert(column, kv, converter_class, converter)}"
end

39
hbase-shell/src/test/ruby/hbase/table_test.rb
View File

@ -557,21 +557,40 @@ module Hbase
@test_table.put(2, "x:raw1", 11)
args = {}
numRows = 0
count = @test_table._scan_internal(args) do |row, cells| # Normal Scan
numRows += 1
num_rows = 0
@test_table._scan_internal(args) do # Normal Scan
num_rows += 1
end
assert_equal(numRows, 2, "Num rows scanned without RAW/VERSIONS are not 2")
assert_equal(num_rows, 2,
'Num rows scanned without RAW/VERSIONS are not 2')
args = {VERSIONS=>10,RAW=>true} # Since 4 versions of row with rowkey 2 is been added, we can use any number >= 4 for VERSIONS to scan all 4 versions.
numRows = 0
count = @test_table._scan_internal(args) do |row, cells| # Raw Scan
numRows += 1
args = { VERSIONS => 10, RAW => true } # Since 4 versions of row with rowkey 2 is been added, we can use any number >= 4 for VERSIONS to scan all 4 versions.
num_rows = 0
@test_table._scan_internal(args) do # Raw Scan
num_rows += 1
end
assert_equal(numRows, 5, "Num rows scanned without RAW/VERSIONS are not 5") # 5 since , 1 from row key '1' and other 4 from row key '4'
# 5 since , 1 from row key '1' and other 4 from row key '4'
assert_equal(num_rows, 5,
'Num rows scanned without RAW/VERSIONS are not 5')
@test_table.delete(1, 'x:a')
args = {}
num_rows = 0
@test_table._scan_internal(args) do # Normal Scan
num_rows += 1
end
assert_equal(num_rows, 1,
'Num rows scanned without RAW/VERSIONS are not 1')
args = { VERSIONS => 10, RAW => true }
num_rows = 0
@test_table._scan_internal(args) do # Raw Scan
num_rows += 1
end
# 6 since , 2 from row key '1' and other 4 from row key '4'
assert_equal(num_rows, 6,
'Num rows scanned without RAW/VERSIONS are not 5')
end
define_test "scan should fail on invalid COLUMNS parameter types" do
assert_raise(ArgumentError) do