From 36125619a25384c7265a0f2185a9ae105339ce2d Mon Sep 17 00:00:00 2001 From: Zhangmei Li Date: Tue, 11 Jan 2022 15:23:29 +0800 Subject: [PATCH 1/2] enhance schama job module Change-Id: I9a81232ec1d0482bf00c53a2499df7d8b9cc53ec --- .../job/schema/EdgeLabelRemoveCallable.java | 12 +++++++++--- .../job/schema/IndexLabelRemoveCallable.java | 10 ++++++++-- .../baidu/hugegraph/job/schema/SchemaCallable.java | 5 +++++ .../job/schema/VertexLabelRemoveCallable.java | 12 ++++++++++-- 4 files changed, 32 insertions(+), 7 deletions(-) diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java index a704e33bdf..cda9f2c8d3 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java @@ -43,7 +43,7 @@ public Object execute() { return null; } - protected static void removeEdgeLabel(HugeGraphParams graph, Id id) { + private static void removeEdgeLabel(HugeGraphParams graph, Id id) { GraphTransaction graphTx = graph.graphTransaction(); SchemaTransaction schemaTx = graph.schemaTransaction(); EdgeLabel edgeLabel = schemaTx.getEdgeLabel(id); @@ -51,7 +51,11 @@ protected static void removeEdgeLabel(HugeGraphParams graph, Id id) { if (edgeLabel == null) { return; } - // TODO: use event to replace direct call + if (edgeLabel.status().deleting()) { + LOG.info("The edge label '{}' has been in {} status, " + + "please check if it's expected to delete it again", + edgeLabel, edgeLabel.status()); + } // Remove index related data(include schema) of this edge label Set indexIds = ImmutableSet.copyOf(edgeLabel.indexLabels()); LockUtil.Locks locks = new LockUtil.Locks(graph.name()); @@ -63,13 +67,15 @@ protected static void removeEdgeLabel(HugeGraphParams graph, Id id) { IndexLabelRemoveCallable.removeIndexLabel(graph, indexId); } // Remove all edges which has matched label + // TODO: use event to replace direct call graphTx.removeEdges(edgeLabel); - removeSchema(schemaTx, edgeLabel); /* * Should commit changes to backend store before release * delete lock */ graph.graph().tx().commit(); + // Remove edge label + removeSchema(schemaTx, edgeLabel); } catch (Throwable e) { schemaTx.updateSchemaStatus(edgeLabel, SchemaStatus.UNDELETED); throw e; diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java index 39803e914e..916182ddc6 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java @@ -48,6 +48,11 @@ protected static void removeIndexLabel(HugeGraphParams graph, Id id) { if (indexLabel == null) { return; } + if (indexLabel.status().deleting()) { + LOG.info("The index label '{}' has been in {} status, " + + "please check if it's expected to delete it again", + indexLabel, indexLabel.status()); + } LockUtil.Locks locks = new LockUtil.Locks(graph.name()); try { locks.lockWrites(LockUtil.INDEX_LABEL_DELETE, id); @@ -60,14 +65,15 @@ protected static void removeIndexLabel(HugeGraphParams graph, Id id) { // Remove index data // TODO: use event to replace direct call graphTx.removeIndex(indexLabel); - removeSchema(schemaTx, indexLabel); /* * Should commit changes to backend store before release * delete lock */ graph.graph().tx().commit(); + // Remove index label + removeSchema(schemaTx, indexLabel); } catch (Throwable e) { - schemaTx.updateSchemaStatus(indexLabel, SchemaStatus.INVALID); + schemaTx.updateSchemaStatus(indexLabel, SchemaStatus.UNDELETED); throw e; } } finally { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java index 51bd714a82..2067df004c 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java @@ -3,6 +3,8 @@ import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; +import org.slf4j.Logger; + import com.baidu.hugegraph.backend.id.Id; import com.baidu.hugegraph.backend.id.IdGenerator; import com.baidu.hugegraph.backend.tx.SchemaTransaction; @@ -13,6 +15,7 @@ import com.baidu.hugegraph.schema.VertexLabel; import com.baidu.hugegraph.type.HugeType; import com.baidu.hugegraph.util.E; +import com.baidu.hugegraph.util.Log; public abstract class SchemaCallable extends SysJob { @@ -23,6 +26,8 @@ public abstract class SchemaCallable extends SysJob { public static final String CLEAR_OLAP = "clear_olap"; public static final String REMOVE_OLAP = "remove_olap"; + protected static final Logger LOG = Log.logger(SchemaCallable.class); + private static final String SPLITOR = ":"; protected HugeType schemaType() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java index fbc9e08c56..1660605b91 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java @@ -54,7 +54,13 @@ private static void removeVertexLabel(HugeGraphParams graph, Id id) { if (vertexLabel == null) { return; } + if (vertexLabel.status().deleting()) { + LOG.info("The vertex label '{}' has been in {} status, " + + "please check if it's expected to delete it again", + vertexLabel, vertexLabel.status()); + } + // Check no edge label use the vertex label List edgeLabels = schemaTx.getEdgeLabels(); for (EdgeLabel edgeLabel : edgeLabels) { if (edgeLabel.linkWithLabel(id)) { @@ -81,14 +87,16 @@ private static void removeVertexLabel(HugeGraphParams graph, Id id) { // TODO: use event to replace direct call // Deleting a vertex will automatically deletes the held edge graphTx.removeVertices(vertexLabel); - removeSchema(schemaTx, vertexLabel); /* * Should commit changes to backend store before release * delete lock */ graph.graph().tx().commit(); + // Remove vertex label + removeSchema(schemaTx, vertexLabel); } catch (Throwable e) { - schemaTx.updateSchemaStatus(vertexLabel, SchemaStatus.UNDELETED); + schemaTx.updateSchemaStatus(vertexLabel, + SchemaStatus.UNDELETED); throw e; } } finally { From 5cd7ea65acabc8a56c41934a70d19cad08588218 Mon Sep 17 00:00:00 2001 From: Zhangmei Li Date: Tue, 11 Jan 2022 15:38:45 +0800 Subject: [PATCH 2/2] rename SchemaCallable to SchemaJob Change-Id: I32938d4a5ed595ceb0f2dc02eb7ee75141f4133a --- .../backend/tx/SchemaTransaction.java | 40 +++++++++---------- ...eCallable.java => EdgeLabelRemoveJob.java} | 4 +- ...allable.java => IndexLabelRebuildJob.java} | 2 +- ...Callable.java => IndexLabelRemoveJob.java} | 2 +- ...able.java => OlapPropertyKeyClearJob.java} | 2 +- ...ble.java => OlapPropertyKeyCreateJob.java} | 2 +- ...ble.java => OlapPropertyKeyRemoveJob.java} | 3 +- .../{SchemaCallable.java => SchemaJob.java} | 4 +- ...allable.java => VertexLabelRemoveJob.java} | 4 +- 9 files changed, 31 insertions(+), 32 deletions(-) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{EdgeLabelRemoveCallable.java => EdgeLabelRemoveJob.java} (95%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{RebuildIndexCallable.java => IndexLabelRebuildJob.java} (99%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{IndexLabelRemoveCallable.java => IndexLabelRemoveJob.java} (98%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{OlapPropertyKeyClearCallable.java => OlapPropertyKeyClearJob.java} (97%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{OlapPropertyKeyCreateCallable.java => OlapPropertyKeyCreateJob.java} (95%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{OlapPropertyKeyRemoveCallable.java => OlapPropertyKeyRemoveJob.java} (95%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{SchemaCallable.java => SchemaJob.java} (97%) rename hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/{VertexLabelRemoveCallable.java => VertexLabelRemoveJob.java} (96%) diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/backend/tx/SchemaTransaction.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/backend/tx/SchemaTransaction.java index 04ba2ccaca..584dccaba0 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/backend/tx/SchemaTransaction.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/backend/tx/SchemaTransaction.java @@ -40,14 +40,14 @@ import com.baidu.hugegraph.config.CoreOptions; import com.baidu.hugegraph.exception.NotAllowException; import com.baidu.hugegraph.job.JobBuilder; -import com.baidu.hugegraph.job.schema.EdgeLabelRemoveCallable; -import com.baidu.hugegraph.job.schema.IndexLabelRemoveCallable; -import com.baidu.hugegraph.job.schema.OlapPropertyKeyClearCallable; -import com.baidu.hugegraph.job.schema.OlapPropertyKeyCreateCallable; -import com.baidu.hugegraph.job.schema.OlapPropertyKeyRemoveCallable; -import com.baidu.hugegraph.job.schema.RebuildIndexCallable; -import com.baidu.hugegraph.job.schema.SchemaCallable; -import com.baidu.hugegraph.job.schema.VertexLabelRemoveCallable; +import com.baidu.hugegraph.job.schema.EdgeLabelRemoveJob; +import com.baidu.hugegraph.job.schema.IndexLabelRebuildJob; +import com.baidu.hugegraph.job.schema.IndexLabelRemoveJob; +import com.baidu.hugegraph.job.schema.OlapPropertyKeyClearJob; +import com.baidu.hugegraph.job.schema.OlapPropertyKeyCreateJob; +import com.baidu.hugegraph.job.schema.OlapPropertyKeyRemoveJob; +import com.baidu.hugegraph.job.schema.SchemaJob; +import com.baidu.hugegraph.job.schema.VertexLabelRemoveJob; import com.baidu.hugegraph.perf.PerfUtil.Watched; import com.baidu.hugegraph.schema.EdgeLabel; import com.baidu.hugegraph.schema.IndexLabel; @@ -200,7 +200,7 @@ public VertexLabel getVertexLabel(String name) { @Watched(prefix = "schema") public Id removeVertexLabel(Id id) { LOG.debug("SchemaTransaction remove vertex label '{}'", id); - SchemaCallable callable = new VertexLabelRemoveCallable(); + SchemaJob callable = new VertexLabelRemoveJob(); VertexLabel schema = this.getVertexLabel(id); return asyncRun(this.graph(), schema, callable); } @@ -226,7 +226,7 @@ public EdgeLabel getEdgeLabel(String name) { @Watched(prefix = "schema") public Id removeEdgeLabel(Id id) { LOG.debug("SchemaTransaction remove edge label '{}'", id); - SchemaCallable callable = new EdgeLabelRemoveCallable(); + SchemaJob callable = new EdgeLabelRemoveJob(); EdgeLabel schema = this.getEdgeLabel(id); return asyncRun(this.graph(), schema, callable); } @@ -262,7 +262,7 @@ public IndexLabel getIndexLabel(String name) { @Watched(prefix = "schema") public Id removeIndexLabel(Id id) { LOG.debug("SchemaTransaction remove index label '{}'", id); - SchemaCallable callable = new IndexLabelRemoveCallable(); + SchemaJob callable = new IndexLabelRemoveJob(); IndexLabel schema = this.getIndexLabel(id); return asyncRun(this.graph(), schema, callable); } @@ -276,7 +276,7 @@ public Id rebuildIndex(SchemaElement schema) { public Id rebuildIndex(SchemaElement schema, Set dependencies) { LOG.debug("SchemaTransaction rebuild index for {} with id '{}'", schema.type(), schema.id()); - SchemaCallable callable = new RebuildIndexCallable(); + SchemaJob callable = new IndexLabelRebuildJob(); return asyncRun(this.graph(), schema, callable, dependencies); } @@ -305,21 +305,21 @@ public void createIndexLabelForOlapPk(PropertyKey propertyKey) { public Id createOlapPk(PropertyKey propertyKey) { LOG.debug("SchemaTransaction create olap property key {} with id '{}'", propertyKey.name(), propertyKey.id()); - SchemaCallable callable = new OlapPropertyKeyCreateCallable(); + SchemaJob callable = new OlapPropertyKeyCreateJob(); return asyncRun(this.graph(), propertyKey, callable); } public Id clearOlapPk(PropertyKey propertyKey) { LOG.debug("SchemaTransaction clear olap property key {} with id '{}'", propertyKey.name(), propertyKey.id()); - SchemaCallable callable = new OlapPropertyKeyClearCallable(); + SchemaJob callable = new OlapPropertyKeyClearJob(); return asyncRun(this.graph(), propertyKey, callable); } public Id removeOlapPk(PropertyKey propertyKey) { LOG.debug("SchemaTransaction remove olap property key {} with id '{}'", propertyKey.name(), propertyKey.id()); - SchemaCallable callable = new OlapPropertyKeyRemoveCallable(); + SchemaJob callable = new OlapPropertyKeyRemoveJob(); return asyncRun(this.graph(), propertyKey, callable); } @@ -543,17 +543,17 @@ private static void setCreateTimeIfNeeded(SchemaElement schema) { } private static Id asyncRun(HugeGraph graph, SchemaElement schema, - SchemaCallable callable) { + SchemaJob callable) { return asyncRun(graph, schema, callable, ImmutableSet.of()); } @Watched(prefix = "schema") private static Id asyncRun(HugeGraph graph, SchemaElement schema, - SchemaCallable callable, Set dependencies) { + SchemaJob callable, Set dependencies) { E.checkArgument(schema != null, "Schema can't be null"); - String name = SchemaCallable.formatTaskName(schema.type(), - schema.id(), - schema.name()); + String name = SchemaJob.formatTaskName(schema.type(), + schema.id(), + schema.name()); JobBuilder builder = JobBuilder.of(graph).name(name) .job(callable) diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveJob.java similarity index 95% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveJob.java index cda9f2c8d3..92bafcd90c 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/EdgeLabelRemoveJob.java @@ -30,7 +30,7 @@ import com.baidu.hugegraph.util.LockUtil; import com.google.common.collect.ImmutableSet; -public class EdgeLabelRemoveCallable extends SchemaCallable { +public class EdgeLabelRemoveJob extends SchemaJob { @Override public String type() { @@ -64,7 +64,7 @@ private static void removeEdgeLabel(HugeGraphParams graph, Id id) { schemaTx.updateSchemaStatus(edgeLabel, SchemaStatus.DELETING); try { for (Id indexId : indexIds) { - IndexLabelRemoveCallable.removeIndexLabel(graph, indexId); + IndexLabelRemoveJob.removeIndexLabel(graph, indexId); } // Remove all edges which has matched label // TODO: use event to replace direct call diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/RebuildIndexCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRebuildJob.java similarity index 99% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/RebuildIndexCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRebuildJob.java index fec44e9629..faeab1d9dd 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/RebuildIndexCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRebuildJob.java @@ -41,7 +41,7 @@ import com.baidu.hugegraph.util.LockUtil; import com.google.common.collect.ImmutableSet; -public class RebuildIndexCallable extends SchemaCallable { +public class IndexLabelRebuildJob extends SchemaJob { @Override public String type() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveJob.java similarity index 98% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveJob.java index 916182ddc6..d81e46022b 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/IndexLabelRemoveJob.java @@ -27,7 +27,7 @@ import com.baidu.hugegraph.type.define.SchemaStatus; import com.baidu.hugegraph.util.LockUtil; -public class IndexLabelRemoveCallable extends SchemaCallable { +public class IndexLabelRemoveJob extends SchemaJob { @Override public String type() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearJob.java similarity index 97% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearJob.java index 5edce68ca8..a1639bdd1c 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyClearJob.java @@ -27,7 +27,7 @@ import com.baidu.hugegraph.type.define.SchemaStatus; import com.baidu.hugegraph.util.LockUtil; -public class OlapPropertyKeyClearCallable extends IndexLabelRemoveCallable { +public class OlapPropertyKeyClearJob extends IndexLabelRemoveJob { @Override public String type() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateJob.java similarity index 95% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateJob.java index ad108a6e61..fe515a635f 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyCreateJob.java @@ -22,7 +22,7 @@ import com.baidu.hugegraph.backend.tx.SchemaTransaction; import com.baidu.hugegraph.schema.PropertyKey; -public class OlapPropertyKeyCreateCallable extends SchemaCallable { +public class OlapPropertyKeyCreateJob extends SchemaJob { @Override public String type() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveJob.java similarity index 95% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveJob.java index 216e4094b6..dec00756e7 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/OlapPropertyKeyRemoveJob.java @@ -23,8 +23,7 @@ import com.baidu.hugegraph.backend.tx.SchemaTransaction; import com.baidu.hugegraph.schema.PropertyKey; -public class OlapPropertyKeyRemoveCallable - extends OlapPropertyKeyClearCallable { +public class OlapPropertyKeyRemoveJob extends OlapPropertyKeyClearJob { @Override public String type() { diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaJob.java similarity index 97% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaJob.java index 2067df004c..ed76824335 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/SchemaJob.java @@ -17,7 +17,7 @@ import com.baidu.hugegraph.util.E; import com.baidu.hugegraph.util.Log; -public abstract class SchemaCallable extends SysJob { +public abstract class SchemaJob extends SysJob { public static final String REMOVE_SCHEMA = "remove_schema"; public static final String REBUILD_INDEX = "rebuild_index"; @@ -26,7 +26,7 @@ public abstract class SchemaCallable extends SysJob { public static final String CLEAR_OLAP = "clear_olap"; public static final String REMOVE_OLAP = "remove_olap"; - protected static final Logger LOG = Log.logger(SchemaCallable.class); + protected static final Logger LOG = Log.logger(SchemaJob.class); private static final String SPLITOR = ":"; diff --git a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveJob.java similarity index 96% rename from hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java rename to hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveJob.java index 1660605b91..1b033c77de 100644 --- a/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveCallable.java +++ b/hugegraph-core/src/main/java/com/baidu/hugegraph/job/schema/VertexLabelRemoveJob.java @@ -33,7 +33,7 @@ import com.baidu.hugegraph.util.LockUtil; import com.google.common.collect.ImmutableSet; -public class VertexLabelRemoveCallable extends SchemaCallable { +public class VertexLabelRemoveJob extends SchemaJob { @Override public String type() { @@ -82,7 +82,7 @@ private static void removeVertexLabel(HugeGraphParams graph, Id id) { schemaTx.updateSchemaStatus(vertexLabel, SchemaStatus.DELETING); try { for (Id ilId : indexLabelIds) { - IndexLabelRemoveCallable.removeIndexLabel(graph, ilId); + IndexLabelRemoveJob.removeIndexLabel(graph, ilId); } // TODO: use event to replace direct call // Deleting a vertex will automatically deletes the held edge