Java ColumnFamilyResult类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getLicenses

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
protected List<License> getLicenses( String projectVersionMetadataKey )
{
    List<License> licenses = new ArrayList<>();

    QueryResult<OrderedRows<String, String, String>> result =
        HFactory.createRangeSlicesQuery( cassandraArchivaManager.getKeyspace(), ss, ss, ss ) //
            .setColumnFamily( cassandraArchivaManager.getLicenseFamilyName() ) //
            .setColumnNames( "projectVersionMetadataModel.key" ) //
            .setRowCount( Integer.MAX_VALUE ) //
            .addEqualsExpression( "projectVersionMetadataModel.key", projectVersionMetadataKey ) //
            .execute();

    for ( Row<String, String, String> row : result.get() )
    {
        ColumnFamilyResult<String, String> columnFamilyResult = this.licenseTemplate.queryColumns( row.getKey() );

        licenses.add(
            new License( columnFamilyResult.getString( NAME.toString() ), columnFamilyResult.getString( URL.toString() ) ) );
    }

    return licenses;
}

开发者ID:ruikom，项目名称:apache-archiva，代码行数:23，代码来源:CassandraMetadataRepository.java

示例2: readAllColumns

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
public CassandraResultSet<K, String> readAllColumns(K key) throws HectorException {
	try {
		if (maxColumnCount > 0) {
			return readColumnSlice(key, null, null, false, maxColumnCount);
		} else {
			ColumnFamilyResult<K, String> queriedColumns = getColumnFamily().queryColumns(key);
			if (isClientAdapterDebugMessagesEnabled) {
				log.info("Row retrieved from Cassandra. Exec Time (micro-sec) = " +
						queriedColumns.getExecutionTimeMicro() +
						", Host used = " + queriedColumns.getHostUsed() + ", Key = " + key);
			}
			return new HectorResultSet<K, String>(queriedColumns);
		}

	} catch (HectorException e) {
		log.debug("HecubaClientManager error while reading key " + key.toString());
		if (log.isDebugEnabled()) {
			log.debug("Caught Exception", e);

			// lets see whether we have any issues with the downed nodes.
			logDownedHosts();
		}
		throw e;
	}
}

开发者ID:WizeCommerce，项目名称:hecuba，代码行数:26，代码来源:HectorBasedHecubaClientManager.java

示例3: readColumns

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
public CassandraResultSet<K, String> readColumns(K key, List<String> columns) throws HectorException {
	ColumnFamilyResult<K, String> queriedColumns;
	try {
		queriedColumns = getColumnFamily().queryColumns(key, columns);
		if (isClientAdapterDebugMessagesEnabled) {
			log.info(columns.size() + " columns retrieved from Cassandra. Exec Time = " +
					queriedColumns.getExecutionTimeMicro() + ", Host used = " +
					queriedColumns.getHostUsed());
		}
		return new HectorResultSet<K, String>(queriedColumns);
	} catch (HectorException e) {
		log.error("HecubaClientManager error while retrieving " + columns.size() + " columns for key " +
				key.toString());
		if (log.isDebugEnabled()) {
			log.debug("Caught Exception", e);
		}
		throw e;
	}
}

开发者ID:WizeCommerce，项目名称:hecuba，代码行数:20，代码来源:HectorBasedHecubaClientManager.java

示例4: mapRow

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
@Override
public List<ActorSystemEventListener> mapRow(final ColumnFamilyResult<Composite, String> results) {
    List<ActorSystemEventListener> resultList = new ArrayList<>(1024);

    if(results.hasResults()) {
        Collection<String> actorIds = results.getColumnNames();
        for (String actorId : actorIds) {
            try {
                resultList.add(ActorSystemEventListenerDeserializer.get().deserialize(results.getByteArray(actorId)));
            } catch(IOException e)  {
                logger.error("IOException while deserializing ActorSystemEventListener",e);
            }
        }
    }
    return resultList;
}

开发者ID:elasticsoftwarefoundation，项目名称:elasticactors，代码行数:17，代码来源:CassandraActorSystemEventListenerRepository.java

示例5: mapRow

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
@Override
public List<ScheduledMessage> mapRow(final ColumnFamilyResult<Composite, Composite> results) {
    List<ScheduledMessage> resultList = new LinkedList<>();

    if(results.hasResults()) {
        Collection<Composite> scheduledMessages = results.getColumnNames();
        for (Composite columnName : scheduledMessages) {
            try {
                resultList.add(scheduledMessageDeserializer.deserialize(results.getByteArray(columnName)));
            } catch(IOException e)  {
                logger.error(e);
            }
        }
    }
    return resultList;
}

开发者ID:elasticsoftwarefoundation，项目名称:elasticactors，代码行数:17，代码来源:CassandraScheduledMessageRepository.java

示例6: getMailingLists

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
protected List<MailingList> getMailingLists( String projectVersionMetadataKey )
{
    List<MailingList> mailingLists = new ArrayList<>();

    QueryResult<OrderedRows<String, String, String>> result =
        HFactory.createRangeSlicesQuery( cassandraArchivaManager.getKeyspace(), ss, ss, ss ) //
            .setColumnFamily( cassandraArchivaManager.getMailingListFamilyName() ) //
            .setColumnNames( NAME.toString() ) //
            .setRowCount( Integer.MAX_VALUE ) //
            .addEqualsExpression( "projectVersionMetadataModel.key", projectVersionMetadataKey ) //
            .execute();
    for ( Row<String, String, String> row : result.get() )
    {
        ColumnFamilyResult<String, String> columnFamilyResult =
            this.mailingListTemplate.queryColumns( row.getKey() );

        MailingList mailingList = new MailingList();
        mailingList.setName( columnFamilyResult.getString( NAME.toString() ) );
        mailingList.setMainArchiveUrl( columnFamilyResult.getString( "mainArchiveUrl" ) );
        mailingList.setPostAddress( columnFamilyResult.getString( "postAddress" ) );
        mailingList.setSubscribeAddress( columnFamilyResult.getString( "subscribeAddress" ) );
        mailingList.setUnsubscribeAddress( columnFamilyResult.getString( "unsubscribeAddress" ) );

        List<String> otherArchives = new ArrayList<>();

        for ( String columnName : columnFamilyResult.getColumnNames() )
        {
            if ( StringUtils.startsWith( columnName, "otherArchive." ) )
            {
                otherArchives.add( columnFamilyResult.getString( columnName ) );
            }
        }

        mailingList.setOtherArchives( otherArchives );
        mailingLists.add( mailingList );
    }

    return mailingLists;
}

开发者ID:ruikom，项目名称:apache-archiva，代码行数:40，代码来源:CassandraMetadataRepository.java

示例7: getDependencies

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
protected List<Dependency> getDependencies( String projectVersionMetadataKey )
{
    List<Dependency> dependencies = new ArrayList<>();

    QueryResult<OrderedRows<String, String, String>> result =
        HFactory.createRangeSlicesQuery( cassandraArchivaManager.getKeyspace(), ss, ss, ss ) //
            .setColumnFamily( cassandraArchivaManager.getDependencyFamilyName() ) //
            .setColumnNames( "projectVersionMetadataModel.key" ) //
            .setRowCount( Integer.MAX_VALUE ) //
            .addEqualsExpression( "projectVersionMetadataModel.key", projectVersionMetadataKey ) //
            .execute();

    for ( Row<String, String, String> row : result.get() )
    {
        ColumnFamilyResult<String, String> columnFamilyResult =
            this.dependencyTemplate.queryColumns( row.getKey() );

        Dependency dependency = new Dependency();
        dependency.setClassifier( columnFamilyResult.getString( "classifier" ) );

        dependency.setOptional( Boolean.parseBoolean( columnFamilyResult.getString( "optional" ) ) );

        dependency.setScope( columnFamilyResult.getString( "scope" ) );

        dependency.setSystemPath( columnFamilyResult.getString( "systemPath" ) );

        dependency.setType( columnFamilyResult.getString( "type" ) );

        dependency.setArtifactId( columnFamilyResult.getString( ARTIFACT_ID.toString() ) );

        dependency.setGroupId( columnFamilyResult.getString( GROUP_ID.toString() ) );

        dependency.setVersion( columnFamilyResult.getString( VERSION.toString() ) );

        dependencies.add( dependency );
    }

    return dependencies;
}

开发者ID:ruikom，项目名称:apache-archiva，代码行数:40，代码来源:CassandraMetadataRepository.java

示例8: getProjectReferences

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
@Override
public Collection<ProjectVersionReference> getProjectReferences( String repoId, String namespace, String projectId,
                                                                 String projectVersion )
    throws MetadataResolutionException
{
    QueryResult<OrderedRows<String, String, String>> result = HFactory //
        .createRangeSlicesQuery( keyspace, ss, ss, ss ) //
        .setColumnFamily( cassandraArchivaManager.getDependencyFamilyName() ) //
        .setColumnNames( "projectVersionMetadataModel.key" ) //
        .addEqualsExpression( REPOSITORY_NAME.toString(), repoId ) //
        .addEqualsExpression( GROUP_ID.toString(), namespace ) //
        .addEqualsExpression( ARTIFACT_ID.toString(), projectId ) //
        .addEqualsExpression( VERSION.toString(), projectVersion ) //
        .execute();

    List<String> dependenciesIds = new ArrayList<>( result.get().getCount() );

    for ( Row<String, String, String> row : result.get().getList() )
    {
        dependenciesIds.add( getStringValue( row.getColumnSlice(), "projectVersionMetadataModel.key" ) );
    }

    List<ProjectVersionReference> references = new ArrayList<>( result.get().getCount() );

    for ( String key : dependenciesIds )
    {
        ColumnFamilyResult<String, String> columnFamilyResult =
            this.projectVersionMetadataTemplate.queryColumns( key );
        references.add( new ProjectVersionReference( ProjectVersionReference.ReferenceType.DEPENDENCY, //
                                                     columnFamilyResult.getString( PROJECT_ID.toString() ), //
                                                     columnFamilyResult.getString( NAMESPACE_ID.toString() ), //
                                                     columnFamilyResult.getString( PROJECT_VERSION.toString() ) ) );
    }

    return references;
}

开发者ID:ruikom，项目名称:apache-archiva，代码行数:37，代码来源:CassandraMetadataRepository.java

示例9: doAuthenticate

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
/**
 * Authenticates a user given the user name and password against the user
 * store.
 */
@Override
public boolean doAuthenticate(String userName, Object credential) throws UserStoreException {

    String password = (String) credential;
    boolean isAuthed = false;
    if (!checkUserNameValid(userName)) {
        log.error("Invalid Username");
        return false;
    }

    if (!checkUserPasswordValid(credential)) {
        log.error("Invalid password");
        return false;
    }

    if (UserCoreUtil.isRegistryAnnonymousUser(userName)) {
        log.error("Anonnymous user trying to login");
        return false;
    }

    Composite key = new Composite();
    key.addComponent(userName, stringSerializer);
    key.addComponent(tenantIdString, stringSerializer);

    ColumnFamilyTemplate<Composite, String> userCFTemplate = new ThriftColumnFamilyTemplate<Composite, String>(
            keyspace, CFConstants.UM_USER, CompositeSerializer.get(), StringSerializer.get());

    ColumnFamilyResult<Composite, String> result = userCFTemplate.queryColumns(key);
    String saltVallue = result.getString(CFConstants.UM_SALT_VALUE);
    String storedPassword = result.getString(CFConstants.UM_SECRET);

    if (TRUE.equalsIgnoreCase(realmConfig.getUserStoreProperty(JDBCRealmConstants.STORE_SALTED_PASSWORDS))) {
        password = Util.preparePassword(password, saltVallue);
        if ((storedPassword != null) && (storedPassword.equals(password))) {
            isAuthed = true;
        }
    }
    return isAuthed;
}

开发者ID:wso2-attic，项目名称:carbon-identity，代码行数:44，代码来源:CassandraUserStoreManager.java

示例10: doGet

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected byte[] doGet(byte[] key) throws StorageException {
	try {
		ColumnFamilyResult<byte[], String> res = template.queryColumns(key);
		return res.getByteArray(CassandraStorageSystem.COLUMN_NAME);
	} catch (HectorException e) {
		handleHectorException(e);
		return null;
	}
}

开发者ID:vimaier，项目名称:conqat，代码行数:12，代码来源:CassandraStore.java

示例11: CassandraBackend

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
/**
 * <p>Constructor for RrdMongoDBBackend.</p>
 *
 * @param path a {@link java.lang.String} object.
 * @param ksp  a {@link Keyspace} object.
 * @param columnFamily name of cassandra column family
 */
protected CassandraBackend(String path, Keyspace ksp, String columnFamily) {
    super(path);

    template = new ThriftColumnFamilyTemplate<String, String>(ksp,
            columnFamily,
            StringSerializer.get(),
            StringSerializer.get());
    ColumnFamilyResult<String,String> columnFamilyResult = template.queryColumns(getPath());
    if(columnFamilyResult.hasResults()){
        buffer = columnFamilyResult.getByteArray(RRD);
    }
}

开发者ID:ChaosXu，项目名称:rrd4j-cassandra，代码行数:20，代码来源:CassandraBackend.java

示例12: exists

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
/**
 * Determines if a storage with the given path already exists.
 *
 * @param path Storage path
 * @return True, if such storage exists, false otherwise.
 */
@Override
protected boolean exists(String path) throws IOException {
    ColumnFamilyTemplate<String, String> template =
            new ThriftColumnFamilyTemplate<String, String>(ksp,
                    COLUMN_FAMILY_NAME,
                    StringSerializer.get(),
                    StringSerializer.get());
    ColumnFamilyResult<String, String> res = template.queryColumns(path);
    return res.hasResults();
}

开发者ID:ChaosXu，项目名称:rrd4j-cassandra，代码行数:17，代码来源:CassandraBackendFactory.java

示例13: HectorResultSet

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
public HectorResultSet(ColumnFamilyResult<K, N> originalColFamResult) {
	this.originalColFamResult = originalColFamResult;
}

开发者ID:WizeCommerce，项目名称:hecuba，代码行数:4，代码来源:HectorResultSet.java

示例14: next

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
@Override
public ColumnFamilyResult<K, N> next() {
	return originalColFamResult.next();
}

开发者ID:WizeCommerce，项目名称:hecuba，代码行数:5，代码来源:HectorResultSet.java

示例15: setup

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Before
   public void setup() {
       resultsSet = mock(ColumnFamilyResult.class);
       hectorResultSet = new HectorResultSet<Long, String>(resultsSet);
   }

开发者ID:WizeCommerce，项目名称:hecuba，代码行数:7，代码来源:HectorResultSetTest.java

示例16: delete

import me.prettyprint.cassandra.service.template.ColumnFamilyResult; //导入依赖的package包/类
private void delete(ColumnFamilyTemplate<String, String> template) {
    ColumnFamilyResult<String, String> res = template.queryColumns("a key");
    String value = res.getString("domain");
    template.deleteColumn("key", "column name");
}

开发者ID:ChaosXu，项目名称:rrd4j-cassandra，代码行数:6，代码来源:HectorTest.java

注：本文中的me.prettyprint.cassandra.service.template.ColumnFamilyResult类示例整理自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 ParseException类代码示例发布时间：2022-05-23

Java TypeReference类代码示例发布时间：2022-05-23

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

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

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

阅读：9319|2023-10-27

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

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

阅读：6610|2022-11-06

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

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

阅读：5503|2022-11-06

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

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

阅读：5992|2022-11-06

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

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

阅读：5862|2022-11-06

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

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

阅读：6231|2022-11-06

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

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

阅读：5815|2022-11-06

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

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

阅读：5284|2022-11-06

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

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

阅读：5660|2022-11-06

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

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

阅读：5008|2022-11-06

客服电话

电子邮件

Java ColumnFamilyResult类代码示例

示例1: getLicenses

示例2: readAllColumns

示例3: readColumns

示例4: mapRow

示例5: mapRow

示例6: getMailingLists

示例7: getDependencies

示例8: getProjectReferences

示例9: doAuthenticate

示例10: doGet

示例11: CassandraBackend

示例12: exists

示例13: HectorResultSet

示例14: next

示例15: setup

示例16: delete

请发表评论

全部评论

上一篇：

下一篇：

solegalli/feature-selection-for-machine-

tianli/matlab_offscreen: Matlab offscree

win7系统重装系统初始设置的操作方法

CVE-2022-1860

これがマストドンだ！使い方からインスタ

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

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

doraiso/Mastodon

关于我们

产品与服务

解决方案

139-2527-9053

客服电话

电子邮件

Java ColumnFamilyResult类代码示例

示例1: getLicenses

示例2: readAllColumns

示例3: readColumns

示例4: mapRow

示例5: mapRow

示例6: getMailingLists

示例7: getDependencies

示例8: getProjectReferences

示例9: doAuthenticate

示例10: doGet

示例11: CassandraBackend

示例12: exists

示例13: HectorResultSet

示例14: next

示例15: setup

示例16: delete

请发表评论

全部评论

上一篇：

下一篇：

solegalli/feature-selection-for-machine-

tianli/matlab_offscreen: Matlab offscree

win7系统重装系统初始设置的操作方法

CVE-2022-1860

これがマストドンだ！ 使い方からインスタ

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

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

doraiso/Mastodon

关于我们

产品与服务

解决方案

139-2527-9053

これがマストドンだ！使い方からインスタ