olim7t

import graphql.GraphQL;
import graphql.Scalars;
import graphql.schema.DataFetcher;
import graphql.schema.DataFetchingEnvironment;
import graphql.schema.GraphQLSchema;

import static graphql.schema.FieldCoordinates.coordinates;
import static graphql.schema.GraphQLArgument.newArgument;
import static graphql.schema.GraphQLCodeRegistry.newCodeRegistry;
import static graphql.schema.GraphQLFieldDefinition.newFieldDefinition;

olim7t

// (in src/main/scala/example/)
package example
import com.datastax.oss.driver.api.core.cql.BatchType
import com.datastax.driver.dse.DseCluster

object Hello extends App {

  // Test if JAVA-2365 creates a problem:
  println(BatchType.LOGGED)

olim7t

package com.datastax.oss.driver.mapper;

import static com.datastax.oss.driver.api.querybuilder.QueryBuilder.bindMarker;

import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.BatchStatement;
import com.datastax.oss.driver.api.core.cql.BatchStatementBuilder;
import com.datastax.oss.driver.api.core.cql.BoundStatementBuilder;
import com.datastax.oss.driver.api.core.cql.DefaultBatchType;
import com.datastax.oss.driver.api.core.cql.PreparedStatement;

olim7t

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.PreparedStatement;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;

import java.nio.ByteBuffer;
import java.util.concurrent.TimeUnit;

public class Read2MbBlobs {
    public static void main(String[] args) {

olim7t

import com.datastax.driver.core.*;
import com.datastax.driver.core.exceptions.InvalidTypeException;

import java.nio.ByteBuffer;

public class LongToDateDemo {

    public static class LongToDateCodec extends TypeCodec<Integer> {

        // Piggyback on the default codecs' implementation

olim7t

import com.datastax.driver.core.*;
import com.datastax.driver.core.policies.Policies;

import java.net.InetAddress;

public class GatherAllListenAddresses {
    public static void main(String[] args) {
        Cluster cluster = null;
        try {
            cluster = Cluster.builder()

olim7t

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
import com.datastax.driver.mapping.Mapper;
import com.datastax.driver.mapping.MappingManager;
import com.datastax.driver.mapping.annotations.Frozen;
import com.datastax.driver.mapping.annotations.PartitionKey;
import com.datastax.driver.mapping.annotations.Table;
import com.datastax.driver.mapping.annotations.UDT;

public class DriverDemo {

olim7t

package com.datastax.driver.core;

import java.awt.Component;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.util.Iterator;
import java.util.Set;

import javax.swing.*;

olim7t

import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

import com.codahale.metrics.ConsoleReporter;
import com.google.common.collect.ImmutableMap;
import com.google.common.util.concurrent.MoreExecutors;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
import org.scassandra.http.client.PrimingClient;

olim7t

static void reportInFlightQueries(Session session) {
    Session.State state = session.getState();
    System.out.printf("State of %s:%n", session);
    for (Host host : state.getConnectedHosts()) {
        int connections = state.getOpenConnections(host);
        int inFlight = state.getInFlightQueries(host);
        System.out.printf("\t%s:\tconnections=%2s\tinFlight=%4s\tmean=%4s%n",
            host,
            connections,
            inFlight,