Java QueryGranularity类代码示例

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

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

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

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

示例1: getIndex

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static QueryableIndex getIndex(String indexKey) throws IOException {
    if (indices.has(indexKey)) {
        return indices.get(indexKey);
    }
    //  Create druid segments from raw data
    Reader reader = new FileReader(new File("./src/test/resources/report.csv"));

    List<String> columns = Arrays.asList("colo", "pool", "report", "URL", "TS", "metric", "value", "count", "min", "max", "sum");
    List<String> metrics = Arrays.asList("value", "count", "min", "max", "sum");
    List<String> dimensions = new ArrayList<>(columns);
    dimensions.removeAll(metrics);
    Loader loader = Loader.csv(reader, columns, dimensions, "TS");

    DimensionsSpec dimensionsSpec = new DimensionsSpec(dimensions, null, null);
    AggregatorFactory[] metricsAgg = new AggregatorFactory[]{
            new LongSumAggregatorFactory("agg_count", "count"),
            new DoubleMaxAggregatorFactory("agg_max", "max"),
            new DoubleMinAggregatorFactory("agg_min", "min"),
            new DoubleSumAggregatorFactory("agg_sum", "sum")
    };
    IncrementalIndexSchema indexSchema = new IncrementalIndexSchema(0, QueryGranularity.ALL, dimensionsSpec, metricsAgg);
    indices.cache(indexKey, loader, indexSchema);
    return indices.get(indexKey);
}

开发者ID:InferlyticsOSS，项目名称:jDruid，代码行数:25，代码来源:TestHelper.java

示例2: getGroupByQuery

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static Query getGroupByQuery() {
    List<DimFilter> filters = new ArrayList<>();
    filters.add(DimFilters.dimEquals("report", "URLTransaction"));
    filters.add(DimFilters.dimEquals("pool", "r1cart"));
    filters.add(DimFilters.dimEquals("metric", "Duration"));
    return GroupByQuery.builder()
            .setDataSource("test")
            .setQuerySegmentSpec(QuerySegmentSpecs.create(new Interval(0, new DateTime().getMillis())))
            .setGranularity(QueryGranularity.NONE)
            .addDimension("URL")
            .addAggregator(new LongSumAggregatorFactory("agg_count", "agg_count"))
            .addAggregator(new DoubleMaxAggregatorFactory("agg_max", "agg_max"))
            .addAggregator(new DoubleMinAggregatorFactory("agg_min", "agg_min"))
            .addAggregator(new DoubleSumAggregatorFactory("agg_sum", "agg_sum"))
            .setDimFilter(DimFilters.and(filters))
            .build();
}

开发者ID:InferlyticsOSS，项目名称:jDruid，代码行数:18，代码来源:TestHelper.java

示例3: getTopNQuery

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static Query getTopNQuery() {
    List<DimFilter> filters = new ArrayList<>();
    filters.add(DimFilters.dimEquals("report", "URLTransaction"));
    filters.add(DimFilters.dimEquals("pool", "r1cart"));
    filters.add(DimFilters.dimEquals("metric", "Duration"));
    return new TopNQueryBuilder()
            .threshold(5)
            .metric("agg_count")
            .dataSource("test")
            .intervals(QuerySegmentSpecs.create(new Interval(0, new DateTime().getMillis())))
            .granularity(QueryGranularity.NONE)
            .dimension("colo")
            .aggregators(
                    Arrays.asList(
                            new LongSumAggregatorFactory("agg_count", "agg_count"),
                            new DoubleMaxAggregatorFactory("agg_max", "agg_max"),
                            new DoubleMinAggregatorFactory("agg_min", "agg_min"),
                            new DoubleSumAggregatorFactory("agg_sum", "agg_sum")))
            .filters(DimFilters.and(filters)).build();
}

开发者ID:InferlyticsOSS，项目名称:jDruid，代码行数:21，代码来源:TestHelper.java

示例4: getTimeseriesQuery

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static Query getTimeseriesQuery() {
    List<DimFilter> filters = new ArrayList<>();
    filters.add(DimFilters.dimEquals("report", "URLTransaction"));
    filters.add(DimFilters.dimEquals("pool", "r1cart"));
    filters.add(DimFilters.dimEquals("metric", "Duration"));
    return Druids.newTimeseriesQueryBuilder()
            .dataSource("test")
            .intervals(QuerySegmentSpecs.create(new Interval(0, new DateTime().getMillis())))
            .granularity(QueryGranularity.ALL)
            .aggregators(Arrays.asList(
                    new LongSumAggregatorFactory("agg_count", "agg_count"),
                    new DoubleMaxAggregatorFactory("agg_max", "agg_max"),
                    new DoubleMinAggregatorFactory("agg_min", "agg_min"),
                    new DoubleSumAggregatorFactory("agg_sum", "agg_sum")))
            .filters(DimFilters.and(filters)).build();
}

开发者ID:InferlyticsOSS，项目名称:jDruid，代码行数:17，代码来源:TestHelper.java

示例5: createDruidSegments

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static QueryableIndex createDruidSegments() throws IOException {
//  Create druid segments from raw data
	Reader reader = new BufferedReader(new FileReader(new File("./src/test/resources/report.csv")));

    List<String> columns = Arrays.asList("colo", "pool", "report", "URL", "TS", "metric", "value", "count", "min", "max", "sum");
    List<String> exclusions = Arrays.asList("_Timestamp", "_Machine", "_ThreadId", "_Query");
    List<String> metrics = Arrays.asList("value", "count", "min", "max", "sum");
    List<DimensionSchema> dimensions = new ArrayList<DimensionSchema>();
    for(String dim : columns){
    	dimensions.add(new StringDimensionSchema(dim));
    }
    dimensions.removeAll(exclusions);
    dimensions.removeAll(metrics);
    Loader loader = new CSVLoader(reader, columns, columns, "TS");

    DimensionsSpec dimensionsSpec = new DimensionsSpec(dimensions, null, null);
    AggregatorFactory[] metricsAgg = new AggregatorFactory[] {
        new LongSumAggregatorFactory("agg_count", "count"),
        new LongMaxAggregatorFactory("agg_max", "max"),
        new LongMinAggregatorFactory("agg_min", "min"),
        new DoubleSumAggregatorFactory("agg_sum", "sum"),
    };
    IncrementalIndexSchema indexSchema = new IncrementalIndexSchema(0, QueryGranularity.fromString("ALL"), dimensionsSpec, metricsAgg);
    QueryableIndex index = IndexHelper.getQueryableIndex(loader, indexSchema);
    return index;
}

开发者ID:eBay，项目名称:embedded-druid，代码行数:27，代码来源:EmbeddedDruidTest.java

示例6: topNQuery

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
@Test
public void topNQuery() throws IOException {
	QueryableIndex index = createDruidSegments();
	List<DimFilter> filters = new ArrayList<DimFilter>();
	filters.add(DimFilters.dimEquals("report", "URLTransaction"));
	filters.add(DimFilters.dimEquals("pool", "r1cart"));
	filters.add(DimFilters.dimEquals("metric", "Duration"));
    TopNQuery query =
        new TopNQueryBuilder()
            .threshold(5)
            .metric("agg_count")
            .dataSource("test")
            .intervals(QuerySegmentSpecs.create(new Interval(0, new DateTime().getMillis())))
            .granularity(QueryGranularity.fromString("NONE"))
            .dimension("colo")
            .aggregators(
                Arrays.<AggregatorFactory>asList(
                    new LongSumAggregatorFactory("agg_count", "agg_count"),
                    new LongMaxAggregatorFactory("agg_max", "agg_max"),
                    new LongMinAggregatorFactory("agg_min", "agg_min"),
                    new DoubleSumAggregatorFactory("agg_sum", "agg_sum"))
                    
            )
            .filters(DimFilters.and(filters)).build();
    @SuppressWarnings("unchecked")
    Sequence<Result> sequence = QueryHelper.run(query, index);
    ArrayList<Result> results = Sequences.toList(sequence, Lists.<Result>newArrayList());
    Assert.assertEquals(results.size(), 1);
}

开发者ID:eBay，项目名称:embedded-druid，代码行数:30，代码来源:EmbeddedDruidTest.java

示例7: getQueryGranularity

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
private QueryGranularity getQueryGranularity() {
    if ("NONE".equals(queryGranularity))
        return QueryGranularities.NONE;
    else if ("ALL".equals(queryGranularity))
        return QueryGranularities.ALL;
    else
        return QueryGranularity.fromString(queryGranularity);
}

开发者ID:hortonworks，项目名称:streamline，代码行数:9，代码来源:DruidBeamFactoryImpl.java

示例8: PigSegmentLoadSpec

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
@JsonCreator
public PigSegmentLoadSpec(
    @JsonProperty("dimensions") List<String> dimensions,
    @JsonProperty("metrics") List<Metric> metrics,
    @JsonProperty("granularity") QueryGranularity granularity,
    @JsonProperty("filter") DimFilter filter)
{
  this.dimensions = Preconditions.checkNotNull(dimensions, "null dimensions");
  this.metrics = Preconditions.checkNotNull(metrics, "null metrics");
  this.granularity = granularity == null ? QueryGranularities.NONE : granularity;
  this.filter = filter;
}

开发者ID:himanshug，项目名称:druid-hadoop-utils，代码行数:13，代码来源:PigSegmentLoadSpec.java

示例9: getGranularity

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
public static QueryGranularity getGranularity(String type) {
    if ("ALL".equals(type)) {
        return QueryGranularity.ALL;
    } else if ("NONE".equals(type)) {
        return QueryGranularity.NONE;
    } else {
        return QueryGranularity.fromString(type);
    }
}

开发者ID:Stratio，项目名称:ingestion，代码行数:10，代码来源:QueryGranularityHelper.java

示例10: groupByQuery

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
@Test
public void groupByQuery() throws IOException {
	QueryableIndex index = createDruidSegments();
	List<DimFilter> filters = new ArrayList<DimFilter>();
	filters.add(DimFilters.dimEquals("report", "URLTransaction"));
	filters.add(DimFilters.dimEquals("pool", "r1cart"));
	filters.add(DimFilters.dimEquals("metric", "Duration"));
	GroupByQuery query = GroupByQuery.builder()
      .setDataSource("test")
      .setQuerySegmentSpec(QuerySegmentSpecs.create(new Interval(0, new DateTime().getMillis())))
      .setGranularity(QueryGranularity.fromString("NONE"))
      .addDimension("URL")
      .addAggregator(new LongSumAggregatorFactory("agg_count", "agg_count"))
      .addAggregator(new LongMaxAggregatorFactory("agg_max", "agg_max"))
      .addAggregator(new LongMinAggregatorFactory("agg_min", "agg_min"))
      .addAggregator(new DoubleSumAggregatorFactory("agg_sum", "agg_sum"))
      
      .setDimFilter(DimFilters.and(filters))
      .build();

    @SuppressWarnings("unchecked")
    Sequence<Row> sequence = QueryHelper.run(query, index);
    ArrayList<Row> results = Sequences.toList(sequence, Lists.<Row>newArrayList());
    Assert.assertEquals(results.size(), 2);
    
    if(results.get(0).getDimension("URL").get(0).equals("abc")) {
    	Assert.assertEquals(results.get(0).getLongMetric("agg_sum"), 247);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_min"), 0);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_max"), 124);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_count"), 12);	
    	Assert.assertEquals(results.get(1).getLongMetric("agg_sum"), 123);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_min"), 0);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_max"), 123);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_count"), 3);	    		    	

    } else {
    	Assert.assertEquals(results.get(0).getLongMetric("agg_sum"), 123);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_min"), 0);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_max"), 123);
    	Assert.assertEquals(results.get(0).getLongMetric("agg_count"), 3);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_sum"), 247);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_min"), 0);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_max"), 124);
    	Assert.assertEquals(results.get(1).getLongMetric("agg_count"), 12);	
    }
}

开发者ID:eBay，项目名称:embedded-druid，代码行数:47，代码来源:EmbeddedDruidTest.java

示例11: configure

import io.druid.granularity.QueryGranularity; //导入依赖的package包/类
@Override
public void configure(Context context) {
    indexService = context.getString(INDEX_SERVICE);
    discoveryPath = context.getString(DISCOVERY_PATH);
    dimensions = Arrays.asList(context.getString(DIMENSIONS).split(","));
    firehosePattern = context.getString(FIREHOSE_PATTERN, DEFAULT_FIREHOSE);
    dataSource = context.getString(DATA_SOURCE, DEFAUL_DATASOURCE);
    aggregators = AggregatorsHelper.build(context.getString(AGGREGATORS));
    queryGranularity = QueryGranularity.fromString(context.getString(QUERY_GRANULARITY, DEFAULT_QUERY_GRANULARITY));
    segmentGranularity = Granularity.valueOf(context.getString(SEGMENT_GRANULARITY, DEFAULT_SEGMENT_GRANULARITY));
    windowPeriod = context.getString(WINDOW_PERIOD, DEFAULT_PERIOD);
    partitions = context.getInteger(PARTITIONS, DEFAULT_PARTITIONS);
    replicants = context.getInteger(REPLICANTS, DEFAULT_REPLICANTS);
    timestampField = context.getString(TIMESTAMP_FIELD, DEFAULT_TIMESTAMP_FIELD);
    timestampFormat = context.getString(TIMESTAMP_FORMAT, null);
    zookeeperLocation = context.getString(ZOOKEEPER_LOCATION, DEFAULT_ZOOKEEPER_LOCATION);
    baseSleepTime = context.getInteger(ZOOKEEPPER_BASE_SLEEP_TIME, DEFAULT_ZOOKEEPER_BASE_SLEEP);
    maxRetries = context.getInteger(ZOOKEEPER_MAX_RETRIES, DEFAULT_ZOOKEEPER_MAX_RETRIES);
    maxSleep = context.getInteger(ZOOKEEPER_MAX_SLEEP, DEFAULT_ZOOKEEPER_MAX_SLEEP);
    batchSize = context.getInteger(BATCH_SIZE, DEFAULT_BATCH_SIZE);

    druidService = sinkStrategy.getDruidService();
    if (druidService != null) {
        sinkCounter = new SinkCounter(this.getName());
        if (timestampFormat.equals("auto"))
            dateTimeFormatter = DateTimeFormat.forPattern("yyyy-MM-dd'T'HH:mm:ss'Z'");
        else if (timestampFormat.equals("millis"))
            dateTimeFormatter = null;
        else
            dateTimeFormatter = DateTimeFormat.forPattern(timestampFormat);

        // Filter defined fields
        Set<String> filter = new HashSet<String>();
        filter.add(timestampField);
        filter.addAll(dimensions);
        for (AggregatorFactory aggregatorFactory : aggregators) {
            filter.addAll(aggregatorFactory.requiredFields());
        }

        eventParser = new FlumeEventParser(timestampField, dateTimeFormatter, filter);
    }
}

开发者ID:KonkerLabs，项目名称:flume-ng-druid-sink，代码行数:43，代码来源:TranquilitySink.java

注：本文中的io.druid.granularity.QueryGranularity类示例整理自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 ShadowEffect类代码示例发布时间：2022-05-22

Java TestKit类代码示例发布时间：2022-05-22

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

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

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

阅读：18277|2023-10-27

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

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

阅读：9678|2022-11-06

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

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

阅读：8179|2022-11-06

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

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

阅读：8549|2022-11-06

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

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

阅读：8457|2022-11-06

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

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

阅读：9393|2022-11-06

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

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

阅读：8431|2022-11-06

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

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

阅读：7865|2022-11-06

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

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

阅读：8416|2022-11-06

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

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

阅读：7394|2022-11-06

客服电话

电子邮件

Java QueryGranularity类代码示例

示例1: getIndex

示例2: getGroupByQuery

示例3: getTopNQuery

示例4: getTimeseriesQuery

示例5: createDruidSegments

示例6: topNQuery

示例7: getQueryGranularity

示例8: PigSegmentLoadSpec

示例9: getGranularity

示例10: groupByQuery

示例11: configure

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

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

微信小程序--微信小程序tabBar不显示：缺少

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