import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public TitanVertex getVertex(final Object id) {
    if (null == id)
        throw ExceptionFactory.vertexIdCanNotBeNull();
    if (id instanceof Vertex) //allows vertices to be "re-attached" to the current transaction
        return getVertex(((Vertex) id).getId());

    final long longId;
    if (id instanceof Long) {
        longId = (Long) id;
    } else if (id instanceof Number) {
        longId = ((Number) id).longValue();
    } else {
        try {
            longId = Long.valueOf(id.toString()).longValue();
        } catch (NumberFormatException e) {
            return null;
        }
    }
    return getVertex(longId);
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
public CachedChronoEdge addEdge(final Long outVertexIdx, final Long inVertexIdx, final Long labelIdx) {
	if (labelIdx == null)
		throw ExceptionFactory.edgeLabelCanNotBeNull();

	CachedEdgeID edgeID = new CachedEdgeID(outVertexIdx, labelIdx, inVertexIdx);
	CachedChronoEdge edge = this.edges.get(edgeID);
	if (edge == null) {
		CachedChronoVertex out = getChronoVertex(outVertexIdx);
		CachedChronoVertex in = getChronoVertex(inVertexIdx);
		edge = new CachedChronoEdge(out, in, labelIdx, this);
		this.edges.put(edgeID, edge);
		out.addOutEdge(labelIdx, in);
		in.addInEdge(labelIdx, out);
	}
	return edge;
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public Vertex addVertex(Object id) {
  if (id == null) {
    id = AccumuloGraphUtils.generateId();
  }

  String idStr = id.toString();

  Vertex vert = null;
  if (!globals.getConfig().getSkipExistenceChecks()) {
    vert = getVertex(idStr);
    if (vert != null) {
      throw ExceptionFactory.vertexWithIdAlreadyExists(idStr);
    }
  }

  vert = new AccumuloVertex(globals, idStr);

  globals.getVertexWrapper().writeVertex(vert);
  globals.checkedFlush();

  globals.getCaches().cache(vert, Vertex.class);

  return vert;
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public <T extends Element> Index<T> createIndex(String indexName,
    Class<T> indexClass, Parameter... indexParameters) {
  if (indexClass == null) {
    throw ExceptionFactory.classForElementCannotBeNull();
  }
  else if (globals.getConfig().getIndexableGraphDisabled()) {
    throw new UnsupportedOperationException("IndexableGraph is disabled via the configuration");
  }

  for (Index<?> index : globals.getIndexMetadataWrapper().getIndices()) {
    if (index.getIndexName().equals(indexName)) {
      throw ExceptionFactory.indexAlreadyExists(indexName);
    }
  }

  return globals.getIndexMetadataWrapper().createIndex(indexName, indexClass);
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public <T extends Element> void createKeyIndex(String key,
    Class<T> elementClass, Parameter... indexParameters) {
  // TODO Move below to somewhere appropriate.
  if (elementClass == null) {
    throw ExceptionFactory.classForElementCannotBeNull();
  }

  // Add key to indexed keys list.
  globals.getIndexMetadataWrapper().writeKeyMetadataEntry(key, elementClass);
  globals.checkedFlush();

  // Reindex graph.
  globals.getKeyIndexTableWrapper(elementClass).rebuildIndex(key, elementClass);
  globals.getVertexKeyIndexWrapper().dump();
  globals.checkedFlush();
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
/**
 * Add an edge as with {@link #addEdge(String, Vertex)},
 * but with a specified edge id.
 * @param id
 * @param label
 * @param inVertex
 * @return
 */
public Edge addEdge(Object id, String label, Vertex inVertex) {
  if (label == null) {
    throw ExceptionFactory.edgeLabelCanNotBeNull();
  }
  if (id == null) {
    id = AccumuloGraphUtils.generateId();
  }

  String myID = id.toString();

  AccumuloEdge edge = new AccumuloEdge(globals, myID, inVertex, this, label);

  // TODO we arent suppose to make sure the given edge ID doesn't already
  // exist?

  globals.getEdgeWrapper().writeEdge(edge);
  globals.getVertexWrapper().writeEdgeEndpoints(edge);

  globals.checkedFlush();

  globals.getCaches().cache(edge, Edge.class);

  return edge;
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
public <T extends Element> Set<String> getIndexedKeys(Class<T> elementClass) {
  if (elementClass == null) {
    throw ExceptionFactory.classForElementCannotBeNull();
  }

  IndexedItemsListParser parser = new IndexedItemsListParser(elementClass);

  Scanner scan = null;
  try {
    scan = getScanner();
    scan.fetchColumnFamily(new Text(IndexMetadataEntryType.__INDEX_KEY__.name()));

    Set<String> keys = new HashSet<String>();
    for (IndexedItem item : parser.parse(scan)) {
      keys.add(item.getKey());
    }

    return keys;

  } finally {
    if (scan != null) {
      scan.close();
    }
  }
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
public Vertex addVertex(final Object id, String type, final Object... properties) {
    if (id == null) throw ExceptionFactory.vertexIdCanNotBeNull();
    if (retrieveFromCache(id) != null) throw ExceptionFactory.vertexWithIdAlreadyExists(id);
    nextElement();

    Vertex v = baseGraph.addVertexWithLabel(type);
    if (vertexIdKey != null) {
        v.setProperty(vertexIdKey, id);
    }
    cache.set(v, id);
    final BatchVertex newVertex = new BatchVertex(id);

    setProperties(newVertex, properties);

    return newVertex;
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public Edge addEdge(Object id, Vertex outVertex, Vertex inVertex, String label) {
    if (label == null)
        throw ExceptionFactory.edgeLabelCanNotBeNull();

    TitanikVertex titanikOutVertex = (TitanikVertex) outVertex;
    TitanikVertex titanikInVertex = (TitanikVertex) inVertex;

    TitanikEdge outEdge = titanikOutVertex.getOutEdge(label, titanikInVertex.getId());
    if (outEdge == null) {
        NewTitanikEdge edge = new NewTitanikEdge(this, titanikOutVertex, titanikInVertex, label);
        titanikOutVertex.addOutEdge(edge);
        titanikInVertex.addInEdge(edge);
        return edge;
    } else {
        return outEdge;
    }
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
public <T extends Element> Set<String> getIndexedKeys(final Class<T> elementClass) {
    if (elementClass == null)
        throw ExceptionFactory.classForElementCannotBeNull();

    boolean v = isVertexClass(elementClass);
    boolean supported = ((v && supportVertexIds) || (!v && supportEdgeIds));

    if (supported) {
        Set<String> keys = new HashSet<String>();
        keys.addAll(baseGraph.getIndexedKeys(elementClass));
        keys.remove(ID);
        return keys;
    } else {
        return baseGraph.getIndexedKeys(elementClass);
    }
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
static ArangoDBEdge create(ArangoDBGraph graph, Object id, Vertex outVertex, Vertex inVertex, String label) {
	String key = (id != null) ? id.toString() : null;

	if (outVertex instanceof ArangoDBVertex && inVertex instanceof ArangoDBVertex) {
		ArangoDBVertex from = (ArangoDBVertex) outVertex;
		ArangoDBVertex to = (ArangoDBVertex) inVertex;

		try {
			ArangoDBSimpleEdge v = graph.getClient().createEdge(graph.getRawGraph(), key, label,
				from.getRawVertex(), to.getRawVertex(), null);
			return build(graph, v, outVertex, inVertex);
		} catch (ArangoDBException e) {
			if (e.errorNumber() == 1210) {
				throw ExceptionFactory.vertexWithIdAlreadyExists(id);
			}

			logger.debug("error while creating an edge", e);

			throw new IllegalArgumentException(e.getMessage());
		}
	}
	throw new IllegalArgumentException("Wrong vertex class.");

}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
static ArangoDBEdge load(ArangoDBGraph graph, Object id) {
	if (id == null) {
		throw ExceptionFactory.edgeIdCanNotBeNull();
	}

	String key = id.toString();

	try {
		ArangoDBSimpleEdge v = graph.getClient().getEdge(graph.getRawGraph(), key);
		return build(graph, v, null, null);
	} catch (ArangoDBException e) {
		// do nothing
		logger.debug("error while reading an edge", e);

		return null;
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
/**
 * Creates a vertex
 * 
 * @param graph
 *            a ArangoDBGraph
 * @param id
 *            the id (key) of the vertex (can be null)
 * 
 * @throws IllegalArgumentException
 */

static ArangoDBVertex create(ArangoDBGraph graph, Object id) {
	String key = (id != null) ? id.toString() : null;

	try {
		ArangoDBSimpleVertex v = graph.getClient().createVertex(graph.getRawGraph(), key, null);
		return build(graph, v);
	} catch (ArangoDBException e) {
		if (e.errorNumber() == 1210) {
			throw ExceptionFactory.vertexWithIdAlreadyExists(id);
		}
		logger.debug("could not create vertex", e);
		throw new IllegalArgumentException(e.getMessage());
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
/**
 * Creates a vertex by loading it
 * 
 * @param graph
 *            a ArangoDBGraph
 * @param id
 *            the id (key) of the vertex (can be null)
 * 
 * @throws IllegalArgumentException
 */

static ArangoDBVertex load(ArangoDBGraph graph, Object id) {
	if (id == null) {
		throw ExceptionFactory.vertexIdCanNotBeNull();
	}

	String key = id.toString();

	try {
		ArangoDBSimpleVertex v = graph.getClient().getVertex(graph.getRawGraph(), key);
		return build(graph, v);
	} catch (ArangoDBException e) {
		// nothing found
		logger.debug("graph not found", e);
		return null;
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public void setProperty(String key, Object value) {
	if (created) {
		throw new UnsupportedOperationException();
	}

	if (isEmptyString(key))
		throw ExceptionFactory.propertyKeyCanNotBeEmpty();
	if (key.equals(StringFactory.ID))
		throw ExceptionFactory.propertyKeyIdIsReserved();

	try {
		document.setProperty(ArangoDBUtil.normalizeKey(key), value);
	} catch (ArangoDBException e) {
		logger.warn("could not set property", e);
		throw new IllegalArgumentException(e.getMessage());
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
/**
 * Creates a vertex by loading it
 * 
 * @param graph
 *            a ArangoDBGraph
 * @param id
 *            the id (key) of the vertex (can be null)
 */

static ArangoDBBatchVertex load(ArangoDBBatchGraph graph, Object id) {
	if (id == null) {
		throw ExceptionFactory.vertexIdCanNotBeNull();
	}

	String key = id.toString();

	ArangoDBBatchVertex vert = graph.vertexCache.get(key);
	if (vert != null) {
		return vert;
	}

	try {
		ArangoDBSimpleVertex v = graph.client.getVertex(graph.getRawGraph(), key);
		return build(graph, v);
	} catch (ArangoDBException e) {
		logger.warn("could read batch vertex", e);
		return null;
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
public static ArangoDBBatchEdge load(ArangoDBBatchGraph graph, Object id) {
	if (id == null) {
		throw ExceptionFactory.edgeIdCanNotBeNull();
	}

	String key = id.toString();

	ArangoDBBatchEdge edge = graph.edgeCache.get(key);
	if (edge != null) {
		return edge;
	}

	try {
		ArangoDBSimpleEdge v = graph.client.getEdge(graph.getRawGraph(), key);
		return build(graph, v, null, null);
	} catch (ArangoDBException e) {
		// do nothing
		logger.warn("could not load batch edge", e);
		return null;
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public void setProperty(String key, Object value) {

	if (StringFactory.ID.equals(key)) {
		throw ExceptionFactory.propertyKeyIdIsReserved();
	}

	if (StringFactory.LABEL.equals(key) && this instanceof Edge) {
		throw ExceptionFactory.propertyKeyLabelIsReservedForEdges();
	}

	if (StringUtils.isBlank(key)) {
		throw ExceptionFactory.propertyKeyCanNotBeEmpty();
	}

	try {
		document.setProperty(ArangoDBUtil.normalizeKey(key), value);
		save();
	} catch (ArangoDBException e) {
		logger.debug("error while setting a property", e);
		throw new IllegalArgumentException(e.getMessage());
	}
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T> T removeProperty(String key) {

	if (StringUtils.isBlank(key)) {
		throw ExceptionFactory.propertyKeyCanNotBeEmpty();
	}

	if (key.equals(StringFactory.LABEL) && this instanceof Edge) {
		throw ExceptionFactory.propertyKeyLabelIsReservedForEdges();
	}

	T o = null;
	try {
		o = (T) document.removeProperty(ArangoDBUtil.normalizeKey(key));
		save();

	} catch (ArangoDBException e) {
		logger.debug("error while removing a property", e);
		throw new IllegalArgumentException(e.getMessage());
	}
	return o;
}
 

import com.tinkerpop.blueprints.util.ExceptionFactory; //导入依赖的package包/类
@Override
public void setup(final Mapper.Context context) throws IOException, InterruptedException {
    faunusConf = ModifiableHadoopConfiguration.of(DEFAULT_COMPAT.getContextConfiguration(context));
    direction = faunusConf.getEdgeCopyDirection();
    if (direction.equals(Direction.BOTH))
        throw new InterruptedException(ExceptionFactory.bothIsNotSupported().getMessage());
}