public static class ResourceDeduplicationTask.Job extends Object implements org.apache.tinkerpop.gremlin.process.computer.MapReduce<String,ConceptId,String,Long,Long>
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<K,V>, org.apache.tinkerpop.gremlin.process.computer.MapReduce.NullObject, org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<OK,OV>, org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage| Constructor and Description |
|---|
Job() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.tinkerpop.gremlin.process.computer.MapReduce<String,ConceptId,String,Long,Long> |
clone() |
boolean |
deleteUnattached()
Return
true if this job will delete unattached resources and false
otherwise. |
ResourceDeduplicationTask.Job |
deleteUnattached(boolean deleteUnattached)
Specify whether resources that are not associated with any entity or relationship should be
deleted from the database.
|
boolean |
doStage(org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage stage)
We skip the combine stage and do only MAP and REDUCE.
|
Long |
generateFinalResult(Iterator<org.apache.tinkerpop.gremlin.process.computer.KeyValue<String,Long>> keyValues) |
String |
getMemoryKey() |
ResourceDeduplicationTask.Job |
keyspace(String keyspace)
Specify the keyspace to use for the deduplication job.
|
void |
map(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<String,ConceptId> emitter)
Emit the resoucre index (value + type) mapped to the concept ID of the resource instance.
|
void |
reduce(String key,
Iterator<ConceptId> values,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<String,Long> emitter)
Here we simply collect all concepts for a key and ask our concept fixer to do its thing.
|
ResourceDeduplicationTask.Job |
uri(String uri)
Specify the uri to use for the deduplication job.
|
public ResourceDeduplicationTask.Job uri(String uri)
public ResourceDeduplicationTask.Job keyspace(String keyspace)
public ResourceDeduplicationTask.Job deleteUnattached(boolean deleteUnattached)
public boolean deleteUnattached()
true if this job will delete unattached resources and false
otherwise.public final void map(org.apache.tinkerpop.gremlin.structure.Vertex vertex,
org.apache.tinkerpop.gremlin.process.computer.MapReduce.MapEmitter<String,ConceptId> emitter)
public boolean doStage(org.apache.tinkerpop.gremlin.process.computer.MapReduce.Stage stage)
public void reduce(String key, Iterator<ConceptId> values, org.apache.tinkerpop.gremlin.process.computer.MapReduce.ReduceEmitter<String,Long> emitter)
public String getMemoryKey()
public org.apache.tinkerpop.gremlin.process.computer.MapReduce<String,ConceptId,String,Long,Long> clone()
Copyright © 2017 Grakn Labs Ltd. All rights reserved.