@@ -0,0 +1,2665 @@
+package cassandra;%0A%0Aimport java.io.IOException;%0Aimport java.net.InetSocketAddress;%0Aimport java.util.ArrayList;%0Aimport java.util.HashMap;%0Aimport java.util.Map;%0Aimport java.util.Random;%0A%0Aimport com.datastax.driver.core.Cluster;%0Aimport com.datastax.driver.core.Host;%0Aimport com.datastax.driver.core.Metadata;%0Aimport com.datastax.driver.core.Session;%0Aimport com.datastax.driver.core.Statement;%0Aimport com.datastax.driver.core.exceptions.AlreadyExistsException;%0Aimport com.datastax.driver.core.querybuilder.QueryBuilder;%0Aimport com.tinkerpop.blueprints.Edge;%0Aimport com.tinkerpop.blueprints.Vertex;%0A%0Aimport utils.Constants;%0Aimport utils.PerformanceTest;%0Aimport workloads.GraphWorkLoad;%0Aimport workloads.MetaEdge;%0A%0Apublic class CassandraCreateScheme%7B%0A%0A    private Cluster cluster;%0A    private Session session;%0A    private String addr;%0A%0A    public void connect()%7B%0A        InetSocketAddress server = new InetSocketAddress(this.addr, 9042);%0A        ArrayList%3CInetSocketAddress%3E servers = new ArrayList%3CInetSocketAddress%3E();%0A        servers.add(server);%0A%0A        cluster = Cluster.builder().addContactPointsWithPorts(servers).build();%0A        session = cluster.connect();%0A    %7D%0A%0A    public void createSchema()%7B%0A        InetSocketAddress server = new InetSocketAddress(this.addr, 9042);%0A        ArrayList%3CInetSocketAddress%3E servers = new ArrayList%3CInetSocketAddress%3E();%0A        servers.add(server);%0A%0A        Cluster cluster = Cluster.builder().addContactPointsWithPorts(servers)%0A                .build();%0A%0A        Session session = cluster.connect();%0A        session.execute(%22CREATE KEYSPACE importPerf WITH replication %22 +%0A                %22= %7B'class':'SimpleStrategy', 'replication_factor':1%7D;%22);%0A%0A        session.execute(%0A                %22create table importPerf.mg (%22%0A                        + %22gid varint, %22%0A                        + %22edgeType varint,%22%0A                        + %22dstid varint,%22%0A                        + %22edgeAttrs map%3Ctext, bigint%3E,%22%0A                        + %22PRIMARY KEY (gid, edgeType, dstid));%22);%0A        //+ %22nodeAttrs map%3Ctext, text%3E,%22%0A        System.out.println(%22Create Table Schema Return!%22);%0A        session.close();%0A        cluster.close();%0A    %7D%0A%0A    public Session getSession()%7B%0A        return this.session;%0A    %7D%0A%0A    public CassandraCreateScheme(String server) %7B%0A        this.addr = server;%0A        this.connect();%0A    %7D%0A%0A    public void close()%7B%0A        cluster.close();%0A    %7D%0A%0A    public String getTestName() %7B%0A        return %22CassandraTest%22;%0A    %7D%0A%0A    public static void main(String%5B%5D args) throws IOException, InterruptedException%7B%0A        CassandraCreateScheme t = new CassandraCreateScheme(args%5B0%5D);%0A        t.createSchema();%0A    %7D%0A%7D

create scheme