public class ResourceDeduplicationTask extends BackgroundTask
This is a task meant to be run periodically to eliminate resource duplication. The task performs a map-reduce job using
the GraknComputer where each resource index key, i.e. the resource value+type combination, is mapped
to all its corresponding resource instances. The reduction steps, delete superfluous duplicates and forces instances
referring to them to point to the unique remaining resource instance for that key.
| Modifier and Type | Class and Description |
|---|---|
static class |
ResourceDeduplicationTask.Job
The map-reduce job submitted to the GraknGraphComputer that scan the whole set of resources in the graph and
reduces by eliminating duplicates.
|
| Modifier and Type | Field and Description |
|---|---|
static String |
DELETE_UNATTACHED_CONFIG |
static boolean |
DELETE_UNATTACHED_DEFAULT |
static String |
KEYSPACE_CONFIG |
static String |
KEYSPACE_DEFAULT |
| Constructor and Description |
|---|
ResourceDeduplicationTask() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
start()
Called to start execution of the task, may be called on a newly scheduled or previously stopped task.
|
boolean |
stop()
Called to stop execution of the task, may be called on a running or paused task.
|
Long |
totalElimintated() |
addTask, configuration, engineConfiguration, factory, initialize, pause, redis, resume, saveCheckpointpublic static final String KEYSPACE_CONFIG
public static final String KEYSPACE_DEFAULT
public static final String DELETE_UNATTACHED_CONFIG
public static final boolean DELETE_UNATTACHED_DEFAULT
public boolean start()
BackgroundTaskstart in class BackgroundTaskpublic boolean stop()
BackgroundTask
This implementation always throws UnsupportedOperationException.
stop in class BackgroundTaskpublic Long totalElimintated()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.