in gremlin/gremlin-java-client-demo/src/main/java/com/amazonaws/services/neptune/GremlinClientDemo.java [69:108]
public void run() {
// Turn on low-level Gremlin driver logging
System.setProperty("org.slf4j.simpleLogger.defaultLogLevel", "trace");
try {
Cluster cluster = NeptuneClusterBuilder.build()
.enableSsl(enableSsl)
.enableIamAuth(enableIamAuth)
.addContactPoints(neptuneEndpoints)
.port(neptunePort)
.networkLoadBalancerEndpoint(networkLoadBalancerEndpoint)
.applicationLoadBalancerEndpoint(applicationLoadBalancerEndpoint)
.loadBalancerPort(loadBalancerPort)
.create();
Client client = cluster.connect();
DriverRemoteConnection connection = DriverRemoteConnection.using(client);
GraphTraversalSource g = AnonymousTraversalSource.traversal().withRemote(connection);
List<Map<Object, Object>> results =
g.V().limit(10)
.valueMap().with(WithOptions.tokens)
.toList();
for (Map<Object, Object> result : results) {
System.out.println(result);
}
client.close();
cluster.closeAsync();
} catch (Exception e) {
System.err.println("An error occurred while connecting to Neptune:");
e.printStackTrace();
System.exit(-1);
}
}