Skip to content

Commit 102ae40

Browse files
deleted not used function 'updateTaskVertexProperty'
1 parent 14db31d commit 102ae40

File tree

1 file changed

+0
-15
lines changed

1 file changed

+0
-15
lines changed

repository/src/main/java/org/apache/atlas/repository/store/graph/v1/DeleteHandlerV1.java

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -98,21 +98,6 @@ public abstract class DeleteHandlerV1 {
9898
private final TaskUtil taskUtil;
9999
private static final int CHUNK_SIZE = AtlasConfiguration.TASKS_GRAPH_COMMIT_CHUNK_SIZE.getInt();
100100

101-
public void updateTaskVertexProperty(String propertyKey, long value, boolean isIncremental, BiConsumer<AtlasTask, Long> taskSetter) {
102-
AtlasTask currentTask = RequestContext.get().getCurrentTask();
103-
AtlasVertex currentTaskVertex = (AtlasVertex) graph.query()
104-
.has(TASK_GUID, currentTask.getGuid())
105-
.vertices().iterator().next();
106-
107-
Long valueFromTaskVertex = currentTaskVertex.getProperty(propertyKey, Long.class);
108-
long valueToPushToTaskVertex = isIncremental ? (valueFromTaskVertex != null ? valueFromTaskVertex : 0L) + value : value;
109-
if (taskSetter != null) {
110-
taskSetter.accept(currentTask, valueToPushToTaskVertex);
111-
}
112-
113-
currentTaskVertex.setProperty(propertyKey, valueToPushToTaskVertex);
114-
}
115-
116101
public DeleteHandlerV1(AtlasGraph graph, AtlasTypeRegistry typeRegistry, boolean shouldUpdateInverseReference, boolean softDelete, TaskManagement taskManagement) {
117102
this.typeRegistry = typeRegistry;
118103
this.graphHelper = new GraphHelper(graph);

0 commit comments

Comments
 (0)