Java AstyanaxContext类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.netflix.astyanax.AstyanaxContext类的典型用法代码示例。如果您正苦于以下问题：Java AstyanaxContext类的具体用法？Java AstyanaxContext怎么用？Java AstyanaxContext使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AstyanaxContext类属于com.netflix.astyanax包，在下文中一共展示了AstyanaxContext类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getContext

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private Keyspace getContext(final byte[] table) {
  Keyspace keyspace = keyspaces.get(table);
  if (keyspace == null) {
    synchronized (keyspaces) {
      // avoid race conditions where another thread put the client
      keyspace = keyspaces.get(table);
      AstyanaxContext<Keyspace> context = contexts.get(table);
      if (context != null) {
        LOG.warn("Context wasn't null for new keyspace " + Bytes.pretty(table));
      }
      context = new AstyanaxContext.Builder()
        .forCluster("localhost")
        .forKeyspace(new String(table))
        .withAstyanaxConfiguration(ast_config)
        .withConnectionPoolConfiguration(pool)
        .withConnectionPoolMonitor(monitor)
        .buildKeyspace(ThriftFamilyFactory.getInstance());
      contexts.put(table, context);
      context.start();
      
      keyspace = context.getClient();
      keyspaces.put(table, keyspace);
    }
  }
  return keyspace;
}

开发者ID:OpenTSDB，项目名称:asynccassandra，代码行数:27，代码来源:HBaseClient.java

示例2: setupAstyanaxContext

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private Keyspace setupAstyanaxContext(String clusterName)
{
    AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
            .forCluster(clusterName)
            .forKeyspace("CrawlerKS")
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                            .setDiscoveryType(NodeDiscoveryType.NONE)
                            .setConnectionPoolType(ConnectionPoolType.TOKEN_AWARE)
            )
            .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("CassandraPool")
                            .setPort(9160)
                            .setMaxConnsPerHost(3)
                            .setSeeds("127.0.0.1:9160")
            )
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());


    context.start();
    return context.getClient();
}

开发者ID:Esquive，项目名称:iticrawler，代码行数:22，代码来源:StorageCluster.java

示例3: initialSetup

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public void initialSetup() throws NotFoundException, InvalidRequestException, NoSuchFieldException, UnavailableException, IllegalAccessException, InstantiationException, ClassNotFoundException, TimedOutException, URISyntaxException, IOException, TException {
  context = new AstyanaxContext.Builder()
  .forCluster(_cluster) //"Test Cluster"
  .forKeyspace(_keyspaceName)
  .withAstyanaxConfiguration(new AstyanaxConfigurationImpl().setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE))
  .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl(_pool).setPort(_port).setMaxConnsPerHost(1).setSeeds(_host+":"+_port))
  .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
  .buildKeyspace(ThriftFamilyFactory.getInstance());

  context.start();
  GlobalVariables.KS_AST = context.getClient();

  CF_AST_BACK = ColumnFamily
      .newColumnFamily(_columnFamilyNameBack,
        StringSerializer.get(),  // Key Serializer
        StringSerializer.get()) ;  // Column Serializer 

  CF_AST_DYNA = ColumnFamily
      .newColumnFamily(_columnFamilyNameDyna,
        StringSerializer.get(),  // Key Serializer
        StringSerializer.get()) ;  // Column Serializer

  this.cliSchema();
}

开发者ID:faustineinsun，项目名称:WiseCrowdRec，代码行数:25，代码来源:AstyanaxCassandraManipulator.java

示例4: deleteCassandraKeySpace

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public static void deleteCassandraKeySpace(String cassandraConnString, String keySpace) throws Exception {

        try {
            AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
                    .forCluster("ClusterName")
                    .forKeyspace(keySpace)
                    .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                                    .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
                    )
                    .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
                                    .setMaxConnsPerHost(1)
                                    .setSeeds(cassandraConnString)
                    )
                    .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
                    .buildKeyspace(ThriftFamilyFactory.getInstance());

            context.start();
            Keyspace keyspace = context.getClient();
            keyspace.dropKeyspace();
            context.shutdown();
        } catch (BadRequestException e) {
            LOG.warn("Could not delete cassandra keyspace, assuming it does not exist.", e);
        }
    }

开发者ID:Parth-Brahmbhatt，项目名称:storm-smoke-test，代码行数:25，代码来源:CleanupUtils.java

示例5: createCacheLoader

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@Override
CacheLoader<DefaultAstyanaxKeyspaceFactory.KeyspaceKey, AstyanaxContext<Keyspace>> createCacheLoader(AstyanaxConfiguration astyanaxConfiguration,
                                                                                                     ConnectionPoolConfiguration connectionPoolConfiguration,
                                                                                                     KeyspaceConnectionPoolMonitorFactory connectionPoolMonitorFactory,
                                                                                                     ClusterHostSupplierFactory hostSupplierFactory,
                                                                                                     KeyspaceInitializer keyspaceInitializer) {

    final CacheLoader<KeyspaceKey, AstyanaxContext<Keyspace>> delegate = super.createCacheLoader(astyanaxConfiguration, connectionPoolConfiguration, connectionPoolMonitorFactory, hostSupplierFactory, keyspaceInitializer);
    return new CacheLoader<KeyspaceKey, AstyanaxContext<Keyspace>>() {
        @Override
        public AstyanaxContext<Keyspace> load(KeyspaceKey key) throws Exception {
            createCount.incrementAndGet();
            return delegate.load(key);
        }
    };
}

开发者ID:spinnaker，项目名称:kork，代码行数:17，代码来源:DefaultAstyanaxKeyspaceFactoryTest.java

示例6: getConnection

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
/**
 * Creates connection to Cassandra
 */
public static Keyspace getConnection() {
    final AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
            .forCluster("ClusterName")
            .forKeyspace(KEYSPACE_NAME)
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                    .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
            )
            .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
                    .setPort(9160)
                    .setMaxConnsPerHost(1)
                    .setSeeds("127.0.0.1:9160")
                    .setSocketTimeout(60000)
            )
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                    .setCqlVersion("3.0.0")
                    .setTargetCassandraVersion("1.2")
            )
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());

    context.start();
    return context.getClient();
}

开发者ID:Benky，项目名称:webdav-cassandra，代码行数:27，代码来源:CassandraUtils.java

示例7: initWithThriftDriverWithEurekaHostsSupplier

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private AstyanaxContext<Keyspace> initWithThriftDriverWithEurekaHostsSupplier() {
    logger.info("Boot cluster (BOOT_CLUSTER) is {}, keyspace name (KS_NAME) is {}", BOOT_CLUSTER, KS_NAME);

    return new AstyanaxContext.Builder()
            .forCluster(BOOT_CLUSTER)
            .forKeyspace(KS_NAME)
            .withAstyanaxConfiguration(
                    new AstyanaxConfigurationImpl()
                            .setDiscoveryType(
                                    NodeDiscoveryType.DISCOVERY_SERVICE))
            .withConnectionPoolConfiguration(
                    new ConnectionPoolConfigurationImpl(
                            "MyConnectionPool")
                            .setMaxConnsPerHost(3)
                            .setPort(thriftPortForAstyanax))
            .withHostSupplier(eurekaHostsSupplier.getSupplier(BOOT_CLUSTER))
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());

}

开发者ID:Netflix，项目名称:Raigad，代码行数:21，代码来源:InstanceDataDAOCassandra.java

示例8: initWithThriftDriverWithExternalHostsSupplier

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private AstyanaxContext<Keyspace> initWithThriftDriverWithExternalHostsSupplier() {
    logger.info("Boot cluster (BOOT_CLUSTER) is {}, keyspace name (KS_NAME) is {}", BOOT_CLUSTER, KS_NAME);

    return new AstyanaxContext.Builder()
            .forCluster(BOOT_CLUSTER)
            .forKeyspace(KS_NAME)
            .withAstyanaxConfiguration(
                    new AstyanaxConfigurationImpl()
                            .setDiscoveryType(
                                    NodeDiscoveryType.DISCOVERY_SERVICE)
                            .setConnectionPoolType(
                                    ConnectionPoolType.ROUND_ROBIN))
            .withConnectionPoolConfiguration(
                    new ConnectionPoolConfigurationImpl(
                            "MyConnectionPool")
                            .setMaxConnsPerHost(3)
                            .setPort(thriftPortForAstyanax))
            .withHostSupplier(getSupplier())
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());

}

开发者ID:Netflix，项目名称:Raigad，代码行数:23，代码来源:InstanceDataDAOCassandra.java

示例9: setProperties

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@Override
public void setProperties(Map<String, Object> properties) {
  super.setProperties(properties);
  AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
  .forCluster("ClusterName")
  .forKeyspace((String) properties.get(KEYSPACE))
  .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()      
      .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
  )
  .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
      .setPort((int)properties.get(PORT))
      .setMaxConnsPerHost(1)
      .setSeeds((String) properties.get(HOST_LIST))
  )
  .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
  .buildKeyspace(ThriftFamilyFactory.getInstance() );
  context.start();
  
  keyspace = context.getEntity(); 
}

开发者ID:edwardcapriolo，项目名称:teknek-cassandra，代码行数:21，代码来源:CassandraOperator.java

示例10: TimedGroupByEngine

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public TimedGroupByEngine(String ks, int port, String hostlist){
  AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
  .forCluster("ClusterName")
  .forKeyspace(ks)
  .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()      
      .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
  )
  .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
      .setPort(port)
      .setMaxConnsPerHost(1)
      .setSeeds(hostlist)
  )
  .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
  .buildKeyspace(ThriftFamilyFactory.getInstance() );
  context.start();
  keyspace = context.getEntity();
}

开发者ID:edwardcapriolo，项目名称:teknek-cassandra，代码行数:18，代码来源:TimedGroupByEngine.java

示例11: setProperties

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@Override
public void setProperties(Map<String, Object> properties) {
  super.setProperties(properties);
  AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
  .forCluster("ClusterName")
  .forKeyspace((String) properties.get(KEYSPACE))
  .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()      
      .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
  )
  .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
      .setPort((int)properties.get(PORT))
      .setMaxConnsPerHost(1)
      .setSeeds((String) properties.get(HOST_LIST))
  )
  .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
  .buildKeyspace(ThriftFamilyFactory.getInstance() );
  context.start();
  batchSize = (Integer) properties.get(BATCH_SIZE);
  keyspace = context.getEntity();
  m = keyspace.prepareMutationBatch();
}

开发者ID:edwardcapriolo，项目名称:teknek-cassandra，代码行数:22，代码来源:CassandraBatchingOperator.java

示例12: CassandraArtifactCache

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public CassandraArtifactCache(
    String hosts,
    int port,
    int timeoutSeconds,
    boolean doStore,
    BuckEventBus buckEventBus)
    throws ConnectionException {
  this(timeoutSeconds, doStore, buckEventBus, new AstyanaxContext.Builder()
          .forCluster(CLUSTER_NAME)
          .forKeyspace(KEYSPACE_NAME)
          .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                  .setCqlVersion("3.0.0")
                  .setTargetCassandraVersion("1.2")
                  .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
          )
          .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl(POOL_NAME)
                  .setSeeds(hosts)
                  .setPort(port)
                  .setMaxConnsPerHost(1)
          )
          .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
          .buildKeyspace(ThriftFamilyFactory.getInstance()));
}

开发者ID:saleehk，项目名称:buck-cutom，代码行数:24，代码来源:CassandraArtifactCache.java

示例13: beforeClass

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@BeforeClass
public static void beforeClass() {

    astyanaxContext =
            new AstyanaxContext.Builder()
                    .forKeyspace("timeSeriesKeyspace")
                    .withConnectionPoolConfiguration(
                            new ConnectionPoolConfigurationImpl("myCPConfig")
                                    .setSeeds("localhost")
                                    .setPort(9171))
                    .withAstyanaxConfiguration(
                            new AstyanaxConfigurationImpl()
                                    .setConnectionPoolType(ConnectionPoolType.TOKEN_AWARE)
                                    .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE))
                    .buildKeyspace(ThriftFamilyFactory.getInstance());

    keyspace = astyanaxContext.getClient();
    astyanaxContext.start();
}

开发者ID:iZettle，项目名称:izettle-toolbox，代码行数:20，代码来源:TimeSeriesIT.java

示例14: setup

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@Before
public void setup() {
	AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
			.forCluster("Test Cluster")
			.forKeyspace(KS)
			.withAstyanaxConfiguration(
					new AstyanaxConfigurationImpl()
							.setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE))
			.withConnectionPoolConfiguration(
					new ConnectionPoolConfigurationImpl("MyConnectionPool")
							.setPort(9160).setMaxConnsPerHost(1)
							.setSeeds("127.0.0.1:9160"))
			.withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
			.buildKeyspace(ThriftFamilyFactory.getInstance());

	context.start();
	keyspace = context.getClient();
}

开发者ID:Netflix，项目名称:staash，代码行数:19，代码来源:TestChunking.java

示例15: acquireCluster

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
@Override
public synchronized Cluster acquireCluster(ClusterKey clusterKey) {
    String clusterName = clusterKey.getClusterName().toLowerCase();
    Preconditions.checkNotNull(clusterName, "Invalid cluster name 'null'");
    
    ClusterContextHolder holder = contextMap.get(clusterName);
    if (holder == null) {
        HostSupplierProvider hostSupplierProvider = hostSupplierProviders.get(clusterKey.getDiscoveryType());
        Preconditions.checkNotNull(hostSupplierProvider, String.format("Unknown host supplier provider '%s' for cluster '%s'", clusterKey.getDiscoveryType(), clusterName));
        
        AstyanaxContext<Cluster> context = new AstyanaxContext.Builder()
            .forCluster(clusterName)
            .withAstyanaxConfiguration(configurationProvider.get(clusterName))
            .withConnectionPoolConfiguration(cpProvider.get(clusterName))
            .withConnectionPoolMonitor(monitorProvider.get(clusterName))
            .withHostSupplier(hostSupplierProvider.getSupplier(clusterName))
            .buildCluster(ThriftFamilyFactory.getInstance());
        
        holder = new ClusterContextHolder(context);
        holder.start();
    }
    holder.addRef();
    
    return holder.getKeyspace();
}

开发者ID:Netflix，项目名称:staash，代码行数:26，代码来源:DefaultAstyanaxClusterClientProvider.java

示例16: connect

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private static AstyanaxContext<Keyspace> connect(String host, int port, String keyspace, int threads, NodeDiscoveryType discovery) {
    AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
                    .forKeyspace(keyspace)
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                .setDiscoveryType(discovery)
                .setRetryPolicy(new RetryNTimes(10)))
                
            .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl(host + ":" + keyspace)
                    .setMaxConns(threads * 2)
                    .setSeeds(host)
                    .setPort(port)
                    .setRetryBackoffStrategy(new FixedRetryBackoffStrategy(1000, 1000)))
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());
    context.start();
    return context;
}

开发者ID:rackerlabs，项目名称:blueflood，代码行数:18，代码来源:Migration.java

示例17: AstyanaxCassandraScheduleStore

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private AstyanaxCassandraScheduleStore(
        AstyanaxContext<Keyspace> context,
        String name,
        ContentStore contentStore,
        MessageSender<ScheduleUpdateMessage> messageSender,
        Clock clock,
        ConsistencyLevel readCl,
        ConsistencyLevel writeCl,
        MetricRegistry metricRegistry,
        String metricPrefix
) {
    super(contentStore, messageSender, metricRegistry, metricPrefix);
    this.serializer = new ItemAndBroadcastSerializer(new ContentSerializer(new ContentSerializationVisitor()));
    this.keyspace = context.getClient();
    this.cf = ColumnFamily.newColumnFamily(
            name,
            StringSerializer.get(),
            StringSerializer.get()
    );
    this.clock = clock;
    this.readCl = readCl;
    this.writeCl = writeCl;
}

开发者ID:atlasapi，项目名称:atlas-deer，代码行数:24，代码来源:AstyanaxCassandraScheduleStore.java

示例18: AstyanaxCassandraContentStore

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
private AstyanaxCassandraContentStore(
        AstyanaxContext<Keyspace> context,
        String cfName,
        ConsistencyLevel readConsistency,
        ConsistencyLevel writeConsistency,
        ContentHasher hasher,
        IdGenerator idGenerator,
        MessageSender<ResourceUpdatedMessage> sender,
        EquivalenceGraphStore graphStore,
        Clock clock,
        MetricRegistry metricRegistry,
        String metricPrefix
) {
    super(hasher, idGenerator, sender, graphStore, clock, metricRegistry, metricPrefix);
    this.keyspace = checkNotNull(context.getClient());
    this.readConsistency = checkNotNull(readConsistency);
    this.writeConsistency = checkNotNull(writeConsistency);
    this.mainCf = ColumnFamily.newColumnFamily(checkNotNull(cfName),
            LongSerializer.get(), StringSerializer.get()
    );
    this.aliasIndex = AliasIndex.create(keyspace, cfName + "_aliases");

}

开发者ID:atlasapi，项目名称:atlas-deer，代码行数:24，代码来源:AstyanaxCassandraContentStore.java

示例19: CassandraTopicStore

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public CassandraTopicStore(
        AstyanaxContext<Keyspace> context,
        String cfName,
        ConsistencyLevel readCl,
        ConsistencyLevel writeCl,
        Equivalence<? super Topic> equivalence,
        IdGenerator idGenerator,
        MessageSender<ResourceUpdatedMessage> sender,
        Clock clock,
        MetricRegistry metricRegistry,
        String metricPrefix
) {
    super(idGenerator, equivalence, sender, clock, metricRegistry, metricPrefix);
    this.keyspace = checkNotNull(context.getClient());
    this.readConsistency = checkNotNull(readCl);
    this.writeConsistency = checkNotNull(writeCl);
    this.mainCf = ColumnFamily.newColumnFamily(checkNotNull(cfName),
            LongSerializer.get(), StringSerializer.get()
    );
    this.aliasIndex = AliasIndex.create(keyspace, cfName + "_aliases");
}

开发者ID:atlasapi，项目名称:atlas-deer，代码行数:22，代码来源:CassandraTopicStore.java

示例20: testCassandraContext

import com.netflix.astyanax.AstyanaxContext; //导入依赖的package包/类
public static AstyanaxContext<Keyspace> testCassandraContext() {
    return new AstyanaxContext.Builder()
            .forCluster(CLUSTER_NAME)
            .forKeyspace(KEYSPACE_NAME)
            .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
                    .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
                    .setConnectionPoolType(ConnectionPoolType.ROUND_ROBIN)
                    .setAsyncExecutor(Executors.newFixedThreadPool(
                            CLIENT_THREADS,
                            new ThreadFactoryBuilder().setDaemon(true)
                                    .setNameFormat("astyanax-%d")
                                    .build()
                    ))
            )
            .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("Atlas")
                    .setPort(PORT)
                    .setMaxBlockedThreadsPerHost(CLIENT_THREADS)
                    .setMaxConnsPerHost(CLIENT_THREADS)
                    .setMaxConns(CLIENT_THREADS * 5)
                    .setConnectTimeout(CONNECTION_TIMEOUT)
                    .setSeeds(SEEDS)
            )
            .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
            .buildKeyspace(ThriftFamilyFactory.getInstance());
}

开发者ID:atlasapi，项目名称:atlas-deer，代码行数:26，代码来源:CassandraHelper.java

注：本文中的com.netflix.astyanax.AstyanaxContext类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ErrorHandlers类代码示例发布时间：2022-05-21

Java BootstrapContext类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：19134|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9973|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8317|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8686|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8627|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9643|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8611|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7991|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8642|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7527|2022-11-06

客服电话

电子邮件

Java AstyanaxContext类代码示例

示例1: getContext

示例2: setupAstyanaxContext

示例3: initialSetup

示例4: deleteCassandraKeySpace

示例5: createCacheLoader

示例6: getConnection

示例7: initWithThriftDriverWithEurekaHostsSupplier

示例8: initWithThriftDriverWithExternalHostsSupplier

示例9: setProperties

示例10: TimedGroupByEngine

示例11: setProperties

示例12: CassandraArtifactCache

示例13: beforeClass

示例14: setup

示例15: acquireCluster

示例16: connect

示例17: AstyanaxCassandraScheduleStore

示例18: AstyanaxCassandraContentStore

示例19: CassandraTopicStore

示例20: testCassandraContext

请发表评论

全部评论

上一篇：

下一篇：

微信小程序元素水平居中或垂直居中

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053