import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
@Override
protected void openDatabase() throws IOException
{
	isNewDatabase = !databaseExists(dbName);
	openNoTxForMassiveInsert();
	graph = BatchGraph.wrap(noTx, 1000);
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
private void doAddNodeToGraph(String baseId, Object[] props, int num)
{
	BatchGraph<?> batchGraph = (BatchGraph<?>) importer.getGraph();

	if (num == Constants.MAX_NODES_FOR_KEY)
		throw new RuntimeException("Too many nodes with the same key: " + baseId);

	// The first node gets the baseId, all others will
	// obtain an additional "_$number" and will be connected to
	// the last alternative.

	String completeId = createCompleteId(baseId, num);

	try
	{
		batchGraph.addVertex(completeId, props);

		if (num != 0)
		{
			linkToPreviousNode(baseId, num);
		}

	} catch (IllegalArgumentException e)
	{
		doAddNodeToGraph(baseId, props, num + 1);
	}
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
private void addNodeToGraphNoReplace(String id, Object[] props)
{
	String completeId = createCompleteId(id, 0);
	BatchGraph<?> batchGraph = (BatchGraph<?>) importer.getGraph();

	try
	{
		batchGraph.addVertex(completeId, props);
	} catch (IllegalArgumentException e)
	{
		return;
	}
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
@Override
public void createGraphForMassiveLoad()
{
    open(true /* batchLoading */);
    createSchema();

    batchGraph = new BatchGraph<TitanGraph>(titanGraph, VertexIDType.NUMBER, 100000 /* bufferSize */);
    batchGraph.setVertexIdKey(NODE_ID);
    batchGraph.setLoadingFromScratch(true /* fromScratch */);
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
@Override
public void open(WriteConfiguration config) {
    super.open(config);
    bgraph = new BatchGraph<StandardTitanGraph>(graph, VertexIDType.NUMBER, BUFFER_SIZE);
    bgraph.setVertexIdKey("uid");
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
private BatchGraph batchGraph(final TransactionalGraph baseGraph) {
    // use BatchGraph for the vertex cache, but don't buffer commits
    return new BatchGraph<TransactionalGraph>(baseGraph, Long.MAX_VALUE);
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
public TitanMassiveInsertion(BatchGraph<TitanGraph> batchGraph, GraphDatabaseType type)
{
    super(type, null /* resultsPath */); // no temp files for massive load
                                         // insert
    this.batchGraph = batchGraph;
}
 

import com.tinkerpop.blueprints.util.wrappers.batch.BatchGraph; //导入依赖的package包/类
/**
 * Initialise the handler using the graph passed as arguments.
 *
 * @param graph
 */
public TitanRDFHandler(TitanGraph graph, String indexes) {
    this.graph = new BatchGraph(graph);

    if (!graph.getIndexedKeys(Vertex.class).contains(VALUE)) {
        graph.createKeyIndex(VALUE, Vertex.class);
    }

    createTripleIndices(indexes, graph);

    namespaces = graph.addVertex(NAMESPACES_VERTEX_ID);

}