hbase-store: fix build error

This commit is contained in:
disksing
2015-11-06 10:24:29 +08:00
parent 48b1a00771
commit 1912b28f4f
2 changed files with 3 additions and 3 deletions

View File

@ -142,10 +142,10 @@ type hbaseIter struct {
valid bool
}
func (it *hbaseIter) Next() (kv.Iterator, error) {
func (it *hbaseIter) Next() error {
it.rs = it.ThemisScanner.Next()
it.valid = it.rs != nil && len(it.rs.Columns) > 0 && !it.ThemisScanner.Closed()
return it, nil
return nil
}
func (it *hbaseIter) Valid() bool {

View File

@ -154,7 +154,7 @@ func (txn *hbaseTxn) Delete(k kv.Key) error {
func (txn *hbaseTxn) each(f func(kv.Iterator) error) error {
iter := txn.UnionStore.Dirty.NewIterator(nil)
defer iter.Close()
for ; iter.Valid(); iter, _ = iter.Next() {
for ; iter.Valid(); iter.Next() {
if err := f(iter); err != nil {
return errors.Trace(err)
}