diff --git a/pom.xml b/pom.xml index c1b7c85..469afa7 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ hugegraph com.baidu.hugegraph - 0.12.0 + 0.13.0 ../hugegraph/pom.xml 4.0.0 diff --git a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStdSessions.java b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStdSessions.java index 7613c57..8eb4c48 100644 --- a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStdSessions.java +++ b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStdSessions.java @@ -590,7 +590,8 @@ private boolean match(int expected) { @Override public boolean hasNext() { // Update position for paging - if (!this.iter.hasNext()) { + matched = this.iter.hasNext(); + if (!matched) { this.position = null; this.close(); return false; diff --git a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStoreProvider.java b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStoreProvider.java index b40256a..fc593d7 100644 --- a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStoreProvider.java +++ b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvStoreProvider.java @@ -23,6 +23,7 @@ import com.baidu.hugegraph.backend.store.BackendStore; import com.baidu.hugegraph.backend.store.tikv.TikvStore.TikvGraphStore; import com.baidu.hugegraph.backend.store.tikv.TikvStore.TikvSchemaStore; +import com.baidu.hugegraph.config.HugeConfig; public class TikvStoreProvider extends AbstractBackendStoreProvider { @@ -33,12 +34,12 @@ protected String namespace() { } @Override - protected BackendStore newSchemaStore(String store) { + protected BackendStore newSchemaStore(HugeConfig config, String store) { return new TikvSchemaStore(this, this.namespace(), store); } @Override - protected BackendStore newGraphStore(String store) { + protected BackendStore newGraphStore(HugeConfig config, String store) { return new TikvGraphStore(this, this.namespace(), store); } diff --git a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvTable.java b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvTable.java index c2fa869..afb5515 100644 --- a/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvTable.java +++ b/src/main/java/com/baidu/hugegraph/backend/store/tikv/TikvTable.java @@ -44,7 +44,7 @@ import com.baidu.hugegraph.backend.store.BackendEntry; import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumn; import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumnIterator; -import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumnIteratorWrapper; +import com.baidu.hugegraph.backend.store.BackendEntry.BackendColumnIterator.BackendColumnIteratorWrapper; import com.baidu.hugegraph.backend.store.BackendEntryIterator; import com.baidu.hugegraph.backend.store.BackendTable; import com.baidu.hugegraph.backend.store.Shard; @@ -210,7 +210,7 @@ protected BackendColumnIterator getById(Session session, Id id) { return BackendColumnIterator.empty(); } BackendColumn col = BackendColumn.of(id.asBytes(), value); - return new BackendEntry.BackendColumnIteratorWrapper(col); + return BackendColumnIterator.iterator(col); } protected BackendColumnIterator queryByPrefix(Session session, @@ -259,7 +259,7 @@ protected BackendColumnIterator queryByRange(Session session, Shard shard, start = position; } if (start == null) { - start = ShardSpliter.START_BYTES; + start = ShardSplitter.START_BYTES; } int type = Session.SCAN_GTE_BEGIN; if (end != null) { @@ -281,7 +281,7 @@ protected static final BackendEntryIterator newEntryIterator( }); } - private static class TikvShardSpliter extends ShardSpliter { + private static class TikvShardSpliter extends ShardSplitter { public TikvShardSpliter(String table) { super(table); diff --git a/src/main/java/com/baidu/hugegraph/tikv/TikvPlugin.java b/src/main/java/com/baidu/hugegraph/tikv/TikvPlugin.java index e6f9cc4..ddce43d 100644 --- a/src/main/java/com/baidu/hugegraph/tikv/TikvPlugin.java +++ b/src/main/java/com/baidu/hugegraph/tikv/TikvPlugin.java @@ -32,12 +32,12 @@ public void register() { @Override public String supportsMinVersion() { - return "0.12.0"; + return "0.13.0"; } @Override public String supportsMaxVersion() { - return "0.13"; + return "0.14"; } public static void main(String[] args) {