Java QueryValve类代码示例

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

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

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

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

示例1: details

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Directive> details(final long time) throws IOException {
    final Iterator<Item> items = this.table()
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(1)
        )
        .where("url", Conditions.equalTo(this.url))
        .where("time", Conditions.equalTo(time))
        .iterator();
    if (!items.hasNext()) {
        throw new IllegalArgumentException(
            String.format(
                "Request at %d for %s not found",
                time, this.url
            )
        );
    }
    return DyStatus.xembly(items.next(), true);
}

开发者ID:yegor256，项目名称:rehttp，代码行数:23，代码来源:DyStatus.java

示例2: expired

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Take> expired() {
    return new Mapped<>(
        this.table()
            .frame()
            .through(
                new QueryValve()
                    .withIndexName("expired")
                    .withConsistentRead(false)
                    .withSelect(Select.ALL_ATTRIBUTES)
            )
            .where("success", Conditions.equalTo(Boolean.toString(false)))
            .where(
                "when",
                new Condition()
                    .withComparisonOperator(ComparisonOperator.LT)
                    .withAttributeValueList(
                        new AttributeValue().withN(
                            Long.toString(System.currentTimeMillis())
                        )
                    )
            ),
        item -> new DyTake(item, this.delay)
    );
}

开发者ID:yegor256，项目名称:rehttp，代码行数:26，代码来源:DyBase.java

示例3: scripts

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Iterable<Directive>> scripts() {
    return new Mapped<Item, Iterable<Directive>>(
        item -> new Directives()
            .add("script")
            .add("name").set(item.get("name").getS()).up()
            .add("bash").set(item.get("bash").getS()).up()
            .add("paid").set(item.get("paid").getN()).up()
            .add("used").set(item.get("used").getN()).up()
            .add("hour").set(item.get("hour").getN()).up()
            .add("day").set(item.get("day").getN()).up()
            .add("week").set(item.get("week").getN()).up()
            .up(),
        this.region.table("scripts")
            .frame()
            .through(
                new QueryValve()
                    // @checkstyle MagicNumber (1 line)
                    .withLimit(10)
                    .withSelect(Select.ALL_ATTRIBUTES)
            )
            .where("login", this.login)
        );
}

开发者ID:yegor256，项目名称:threecopies，代码行数:25，代码来源:DyUser.java

示例4: logs

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Iterable<Directive>> logs() {
    return new Mapped<Item, Iterable<Directive>>(
        item -> new Directives()
            .add("log")
            .add("group").set(item.get("group").getS()).up()
            .add("start").set(item.get("start").getN()).up()
            .add("finish").set(item.get("finish").getN()).up()
            .add("period").set(item.get("period").getS()).up()
            .add("ocket").set(item.get("ocket").getS()).up()
            .add("exit").set(item.get("exit").getN()).up()
            .up(),
        this.region.table("logs")
            .frame()
            .through(
                new QueryValve()
                    .withIndexName("mine")
                    // @checkstyle MagicNumber (1 line)
                    .withLimit(20)
                    .withConsistentRead(false)
                    .withScanIndexForward(false)
                    .withSelect(Select.ALL_ATTRIBUTES)
            )
            .where("login", this.login)
    );
}

开发者ID:yegor256，项目名称:threecopies，代码行数:27，代码来源:DyUser.java

示例5: ocket

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public String ocket(final long time) throws IOException {
    final Iterator<Item> items = this.region.table("logs")
        .frame()
        .through(new QueryValve().withLimit(1))
        .where("group", this.group())
        .where(
            "start",
            new Condition()
                .withComparisonOperator(ComparisonOperator.EQ)
                .withAttributeValueList(
                    new AttributeValue().withN(Long.toString(time))
                )
        )
        .iterator();
    if (!items.hasNext()) {
        throw new RsForward(
            new RsFlash("Can't find log"),
            "/scripts"
        );
    }
    return items.next().get("ocket").getS();
}

开发者ID:yegor256，项目名称:threecopies，代码行数:24，代码来源:DyScript.java

示例6: recent

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
/**
 * Recent artifacts..
 * @return List of them
 */
public Iterable<Iterable<Directive>> recent() {
    return new Mapped<>(
        item -> {
            final String[] parts = item.get("artifact").getS().split(":");
            return new Directives()
                .add("repo")
                .add("group").set(parts[0]).up()
                .add("artifact").set(parts[1]).up()
                .up();
        },
        this.table.frame()
            .where("good", "true")
            .through(
                new QueryValve()
                    .withScanIndexForward(false)
                    .withIndexName("recent")
                    .withConsistentRead(false)
                    // @checkstyle MagicNumber (1 line)
                    .withLimit(25)
                    .withAttributesToGet("artifact")
            )
    );
}

开发者ID:yegor256，项目名称:jpeek，代码行数:28，代码来源:Results.java

示例7: mine

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Domain> mine() {
    return this.table()
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(Tv.HUNDRED)
                .withConsistentRead(false)
                .withIndexName("mine")
        )
        .where("user", Conditions.equalTo(this.handle))
        .stream()
        .map(DyDomain::new)
        .map(Domain.class::cast)
        .collect(Collectors.toList());
}

开发者ID:yegor256，项目名称:jare，代码行数:18，代码来源:DyUser.java

示例8: domain

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Domain> domain(final String name) {
    return this.table()
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(1)
                .withConsistentRead(true)
        )
        .where(
            "domain",
            Conditions.equalTo(name.toLowerCase(Locale.ENGLISH))
        )
        .stream()
        .map(DyDomain::new)
        .map(Domain.class::cast)
        .collect(Collectors.toList());
}

开发者ID:yegor256，项目名称:jare，代码行数:20，代码来源:DyBase.java

示例9: iterate

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Pipe> iterate() {
    return () -> this.table()
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(Tv.HUNDRED)
                .withConsistentRead(true)
        )
        .where("urn", Conditions.equalTo(this.urn))
        .stream()
        .map(DyPipe::new)
        .map(Pipe.class::cast)
        .iterator();
}

开发者ID:yegor256，项目名称:wring，代码行数:17，代码来源:DyPipes.java

示例10: iterate

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Event> iterate() {
    return () -> this.table()
        .frame()
        .through(
            new QueryValve()
                .withLimit(Tv.TWENTY)
                .withIndexName("top")
                .withSelect(Select.ALL_ATTRIBUTES)
                .withScanIndexForward(false)
                .withConsistentRead(false)
        )
        .where("urn", Conditions.equalTo(this.urn))
        .stream()
        .map(DyEvent::new)
        .map(Event.class::cast)
        .iterator();
}

开发者ID:yegor256，项目名称:wring，代码行数:19，代码来源:DyEvents.java

示例11: get

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Deck get(final String name) throws IOException {
    final Iterator<Item> items = this.region
        .table(DyDeck.TBL)
        .frame()
        .through(new QueryValve().withLimit(1))
        .where(DyDeck.HASH, this.user)
        .where(DyDeck.RANGE, name)
        .iterator();
    if (!items.hasNext()) {
        throw new IOException(
            String.format("deck '%s' not found", name)
        );
    }
    return new DyDeck(
        this.region, this.user, name
    );
}

开发者ID:yegor256，项目名称:thindeck，代码行数:19，代码来源:DyDecks.java

示例12: delete

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public void delete(final String name) {
    final Iterator<Item> items = this.region.table(DyDeck.TBL)
        .frame()
        .through(new QueryValve().withLimit(1))
        .where(DyDeck.HASH, this.user)
        .where(DyDeck.RANGE, name)
        .iterator();
    if (!items.hasNext()) {
        throw new IllegalStateException(
            String.format(
                "deck '%s' not found, can't delete",
                name
            )
        );
    }
    items.next();
    items.remove();
}

开发者ID:yegor256，项目名称:thindeck，代码行数:20，代码来源:DyDecks.java

示例13: iterate

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Iterable<Deck> iterate() {
    return Iterables.transform(
        this.region.table(DyDeck.TBL)
            .frame()
            .through(new QueryValve().withSelect(Select.ALL_ATTRIBUTES))
            .where(DyDeck.HASH, this.user),
        new Function<Item, Deck>() {
            @Override
            public Deck apply(final Item input) {
                try {
                    return DyDecks.this.get(input.get(DyDeck.RANGE).getS());
                } catch (final IOException ex) {
                    throw new IllegalStateException(ex);
                }
            }
        }
    );
}

开发者ID:yegor256，项目名称:thindeck，代码行数:20，代码来源:DyDecks.java

示例14: item

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
/**
 * Item.
 * @return Item
 */
private Item item() {
    final Iterator<Item> items = this.region
        .table(DyDeck.TBL)
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(1)
        )
        .where(DyDeck.HASH, this.user)
        .where(DyDeck.RANGE, this.deck)
        .iterator();
    if (!items.hasNext()) {
        throw new IllegalArgumentException(
            String.format("deck '%s' not found", this.deck)
        );
    }
    return items.next();
}

开发者ID:yegor256，项目名称:thindeck，代码行数:24，代码来源:DyDeck.java

示例15: forward

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
/**
 * Forward search.
 * @param left Left
 * @param cnds Conditions
 * @return Rights
 */
public Iterable<String> forward(final String left,
    final Iterable<Condition> cnds) {
    Frame frame = this.region.table(Refs.TABLE)
        .frame()
        .through(new QueryValve().withScanIndexForward(false))
        .where(Refs.HASH, left);
    for (final Condition cnd : cnds) {
        frame = frame.where(Refs.RANGE, cnd);
    }
    return Iterables.transform(
        frame,
        new Function<Item, String>() {
            @Override
            public String apply(final Item input) {
                try {
                    return input.get(Refs.RANGE).getS();
                } catch (final IOException ex) {
                    throw new IllegalStateException(ex);
                }
            }
        }
    );
}

开发者ID:yegor256，项目名称:bibrarian，代码行数:30，代码来源:Refs.java

示例16: failures

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Collection<Iterable<Directive>> failures(final long after) {
    return new Mapped<>(
        this.table()
            .frame()
            .through(
                new QueryValve()
                    .withIndexName("failures")
                    .withAttributesToGet(
                        "url", "time", "code", "attempts", "when", "ttl"
                    )
                    .withLimit(Tv.TWENTY)
                    .withConsistentRead(false)
                    .withScanIndexForward(false)
            )
            .where("failed_url", Conditions.equalTo(this.url))
            .where(
                "time",
                new Condition()
                    .withComparisonOperator(ComparisonOperator.LT)
                    .withAttributeValueList(
                        new AttributeValue().withN(
                            Long.toString(after)
                        )
                    )
            ),
        item -> DyStatus.xembly(item, false)
    );
}

开发者ID:yegor256，项目名称:rehttp，代码行数:30，代码来源:DyStatus.java

示例17: history

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Collection<Iterable<Directive>> history(final long after) {
    return new Mapped<>(
        this.table()
            .frame()
            .through(
                new QueryValve()
                    .withAttributesToGet(
                        "url", "time", "code", "attempts", "when", "ttl"
                    )
                    .withLimit(Tv.TEN)
                    .withScanIndexForward(false)
            )
            .where("url", Conditions.equalTo(this.url))
            .where(
                "time",
                new Condition()
                    .withComparisonOperator(ComparisonOperator.LT)
                    .withAttributeValueList(
                        new AttributeValue().withN(
                            Long.toString(after)
                        )
                    )
            ),
        item -> DyStatus.xembly(item, false)
    );
}

开发者ID:yegor256，项目名称:rehttp，代码行数:28，代码来源:DyStatus.java

示例18: target

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Take target(final URL url, final long time) throws IOException {
    final Iterator<Item> items = this.table()
        .frame()
        .through(
            new QueryValve()
                .withSelect(Select.ALL_ATTRIBUTES)
                .withLimit(1)
        )
        .where("url", Conditions.equalTo(url))
        .where("time", Conditions.equalTo(time))
        .iterator();
    final Item item;
    if (items.hasNext()) {
        item = items.next();
    } else {
        item = this.table().put(
            new Attributes()
                .with("url", url)
                .with("time", time)
                .with("code", 0)
                .with("attempts", 0)
                .with("when", System.currentTimeMillis())
                .with(
                    "ttl",
                    (System.currentTimeMillis()
                        + TimeUnit.DAYS.toMillis(1L))
                        / TimeUnit.SECONDS.toMillis(1L)
                )
        );
    }
    return new DyTake(item, this.delay);
}

开发者ID:yegor256，项目名称:rehttp，代码行数:34，代码来源:DyBase.java

示例19: worst

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
/**
 * Worst metrics.
 * @return List of them
 * @throws IOException If fails
 */
public Iterable<Iterable<Directive>> worst() throws IOException {
    return new Mapped<>(
        item -> new Directives()
            .add("metric")
            .attr("id", item.get("metric").getS())
            .add("pos").set(item.get("pos").getN()).up()
            .add("neg").set(item.get("neg").getN()).up()
            .add("psum").set(new DyNum(item, "psum").doubleValue()).up()
            .add("pavg").set(new DyNum(item, "pavg").doubleValue()).up()
            .add("nsum").set(new DyNum(item, "nsum").doubleValue()).up()
            .add("navg").set(new DyNum(item, "navg").doubleValue()).up()
            .add("avg").set(new DyNum(item, "avg").doubleValue()).up()
            .add("champions").set(item.get("champions").getN()).up()
            .add("artifact").set(item.get("artifact").getS()).up()
            .add("mean").set(new DyNum(item, "mean").doubleValue()).up()
            .add("sigma").set(new DyNum(item, "sigma").doubleValue()).up()
            .up(),
        this.table.frame()
            .where("version", new Version().value())
            .through(
                new QueryValve()
                    .withScanIndexForward(false)
                    .withIndexName("mistakes")
                    .withConsistentRead(false)
                    // @checkstyle MagicNumber (1 line)
                    .withLimit(20)
                    .withSelect(Select.ALL_ATTRIBUTES)
            )
    );
}

开发者ID:yegor256，项目名称:jpeek，代码行数:36，代码来源:Mistakes.java

示例20: pipe

import com.jcabi.dynamo.QueryValve; //导入依赖的package包/类
@Override
public Pipe pipe(final long number) {
    final Item item = this.table()
        .frame()
        .through(new QueryValve().withLimit(1).withConsistentRead(true))
        .where("urn", Conditions.equalTo(this.urn))
        .where("id", Conditions.equalTo(number))
        .iterator()
        .next();
    return new DyPipe(item);
}

开发者ID:yegor256，项目名称:wring，代码行数:12，代码来源:DyPipes.java

注：本文中的com.jcabi.dynamo.QueryValve类示例整理自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 Join类代码示例发布时间：2022-05-23

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

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

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

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

阅读：18794|2023-10-27

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

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

阅读：9858|2022-11-06

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

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

阅读：8279|2022-11-06

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

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

阅读：8637|2022-11-06

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

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

阅读：8561|2022-11-06

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

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

阅读：9563|2022-11-06

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

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

阅读：8555|2022-11-06

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

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

阅读：7954|2022-11-06

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

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

阅读：8558|2022-11-06

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

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

阅读：7477|2022-11-06

客服电话

电子邮件

Java QueryValve类代码示例

示例1: details

示例2: expired

示例3: scripts

示例4: logs

示例5: ocket

示例6: recent

示例7: mine

示例8: domain

示例9: iterate

示例10: iterate

示例11: get

示例12: delete

示例13: iterate

示例14: item

示例15: forward

示例16: failures

示例17: history

示例18: target

示例19: worst

示例20: pipe

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

sevenjay/cpp-markdown: Cpp-Markdown is a

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

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053