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

HBASE-22277 Addendum Also changed references in hbase-shell

This commit is contained in:
Jan Hentschel 2019-05-01 18:11:15 +02:00
parent 32250e55ba
commit 4379fe4ad3
No known key found for this signature in database
GPG Key ID: 5CD818B19CC299A3
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -401,8 +401,8 @@ EOF
end end
# Additional params # Additional params
get.setMaxVersions(vers) get.readVersions(vers)
get.setTimeStamp(args[TIMESTAMP]) if args[TIMESTAMP] get.setTimestamp(args[TIMESTAMP]) if args[TIMESTAMP]
get.setTimeRange(args[TIMERANGE][0], args[TIMERANGE][1]) if args[TIMERANGE] get.setTimeRange(args[TIMERANGE][0], args[TIMERANGE][1]) if args[TIMERANGE]
else else
if attributes if attributes
@ -416,9 +416,9 @@ EOF
end end
end end
get.setMaxVersions(vers) get.readVersions(vers)
# Set the timestamp/timerange # Set the timestamp/timerange
get.setTimeStamp(ts.to_i) if args[TIMESTAMP] get.setTimestamp(ts.to_i) if args[TIMESTAMP]
get.setTimeRange(args[TIMERANGE][0], args[TIMERANGE][1]) if args[TIMERANGE] get.setTimeRange(args[TIMERANGE][0], args[TIMERANGE][1]) if args[TIMERANGE]
end end
set_attributes(get, attributes) if attributes set_attributes(get, attributes) if attributes
@ -473,7 +473,7 @@ EOF
# Format get request # Format get request
get = org.apache.hadoop.hbase.client.Get.new(row.to_s.to_java_bytes) get = org.apache.hadoop.hbase.client.Get.new(row.to_s.to_java_bytes)
get.addColumn(family, qualifier) get.addColumn(family, qualifier)
get.setMaxVersions(1) get.readVersions(1)
# Call hbase # Call hbase
result = @table.get(get) result = @table.get(get)
@ -553,7 +553,7 @@ EOF
scan.setCacheBlocks(cache_blocks) scan.setCacheBlocks(cache_blocks)
scan.setReversed(reversed) scan.setReversed(reversed)
scan.setCaching(cache) if cache > 0 scan.setCaching(cache) if cache > 0
scan.setMaxVersions(versions) if versions > 1 scan.readVersions(versions) if versions > 1
scan.setTimeRange(timerange[0], timerange[1]) if timerange scan.setTimeRange(timerange[0], timerange[1]) if timerange
scan.setRaw(raw) scan.setRaw(raw)
scan.setLimit(limit) if limit > 0 scan.setLimit(limit) if limit > 0