Package com.datastax.driver.core

Examples of com.datastax.driver.core.QueryOptions

292
293
294
295
296
297
298
299
300
301
302
        int port = getInputNativePort(conf);
        Optional<AuthProvider> authProvider = getAuthProvider(conf);
        Optional<SSLOptions> sslOptions = getSSLOptions(conf);
        LoadBalancingPolicy loadBalancingPolicy = getReadLoadBalancingPolicy(conf, host);
        SocketOptions socketOptions = getReadSocketOptions(conf);
        QueryOptions queryOptions = getReadQueryOptions(conf);
        PoolingOptions poolingOptions = getReadPoolingOptions(conf);
       
        Cluster.Builder builder = Cluster.builder()
                                         .addContactPoint(host)
                                         .withPort(port)
View Full Code Here
438
439
440
441
442
443
444
445
446
447
448
449
450
    private static QueryOptions getReadQueryOptions(Configuration conf)
    {
        String CL = ConfigHelper.getReadConsistencyLevel(conf);
        Optional<Integer> fetchSize = getInputPageRowSize(conf);
        QueryOptions queryOptions = new QueryOptions();
        if (CL != null && !CL.isEmpty())
            queryOptions.setConsistencyLevel(com.datastax.driver.core.ConsistencyLevel.valueOf(CL));

        if (fetchSize.isPresent())
            queryOptions.setFetchSize(fetchSize.get());
        return queryOptions;
    }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
123
124
        if (config.getUsername() != null && config.getPassword() != null) {
            clusterBuilder.withCredentials(config.getUsername(), config.getPassword());
        }

        QueryOptions options = new QueryOptions();
        options.setFetchSize(config.getFetchSize());
        options.setConsistencyLevel(config.getConsistencyLevel());
        clusterBuilder.withQueryOptions(options);

        return new CassandraSession(
                connectorId.toString(),
                clusterBuilder,
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
67
68
    {
        Cluster.Builder clusterBuilder = Cluster.builder();
        clusterBuilder.addContactPoints(contactPoints.toArray(new String[contactPoints.size()]));
        clusterBuilder.withPort(nativeProtocolPort);

        QueryOptions options = new QueryOptions();
        options.setFetchSize(fetchSize);
        options.setConsistencyLevel(consistencyLevel);
        clusterBuilder.withQueryOptions(options);

        Cluster cluster = clusterBuilder.build();
        Session session = cluster.connect();
        return new CassandraSession(connectorId.toString(), session, fetchSizeForPartitionKeySelect, limitForPartitionKeySelect);
View Full Code Here
277
278
279
280
281
282
283
284
285
286
287
        int port = getInputNativePort(conf);
        Optional<AuthProvider> authProvider = getAuthProvider(conf);
        Optional<SSLOptions> sslOptions = getSSLOptions(conf);
        LoadBalancingPolicy loadBalancingPolicy = getReadLoadBalancingPolicy(conf, host);
        SocketOptions socketOptions = getReadSocketOptions(conf);
        QueryOptions queryOptions = getReadQueryOptions(conf);
        PoolingOptions poolingOptions = getReadPoolingOptions(conf);
       
        Cluster.Builder builder = Cluster.builder()
                                         .addContactPoint(host)
                                         .withPort(port)
View Full Code Here
423
424
425
426
427
428
429
430
431
432
433
434
435
    private static QueryOptions getReadQueryOptions(Configuration conf)
    {
        String CL = ConfigHelper.getReadConsistencyLevel(conf);
        Optional<Integer> fetchSize = getInputPageRowSize(conf);
        QueryOptions queryOptions = new QueryOptions();
        if (CL != null && !CL.isEmpty())
            queryOptions.setConsistencyLevel(com.datastax.driver.core.ConsistencyLevel.valueOf(CL));

        if (fetchSize.isPresent())
            queryOptions.setFetchSize(fetchSize.get());
        return queryOptions;
    }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
    Policies policies = new Policies(loadBalancingPolicy, reconnectionPolicy, retryPolicy);
    ProtocolOptions protocolOptions = (nativeProtocolPort == -1) ? new ProtocolOptions() : new ProtocolOptions(nativeProtocolPort);
    PoolingOptions poolOptions = poolingOptions;
    SocketOptions sockOptions = socketOptions;
    MetricsOptions metricsOptions = new MetricsOptions(jmxReportingEnabled);
    QueryOptions qOptions = queryOptions;
   
    return new JavaDriverConnectionPoolConfigurationImpl(new Configuration(policies,
                           protocolOptions,
                           poolOptions,
                           sockOptions,
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
    Configuration jdConfig = new Configuration(new Policies(),
               protocolOptions,
               new PoolingOptions(),
               new SocketOptions(),
               new MetricsOptions(),
               new QueryOptions());

    AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
    .forKeyspace(keyspaceName)
    .withHostSupplier(HostSupplier)
    .withAstyanaxConfiguration(new AstyanaxConfigurationImpl())
View Full Code Here
TOP

Related Classes of com.datastax.driver.core.QueryOptions

  • com.facebook.presto.cassandra.CassandraClientModule
  • com.facebook.presto.cassandra.CassandraSessionFactory
  • com.netflix.astyanax.cql.JavaDriverConfigBuilder
  • com.netflix.astyanax.cql.test.utils.AstyanaxContextFactory
  • org.apache.cassandra.hadoop.cql3.CqlConfigHelper
  • com.datastax.driver.core.exceptions.UnsupportedFeatureException
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.