New LocalOrShuffle (patch, 08038b6)
60,1,2,2,116300380,1938339,1,116300380,116300400,1938339,0.0,0.0 120,1,2,2,171035900,2850598,1,171035900,171035880,2850598,0.0,0.0 180,1,2,2,168730440,2812174,1,168730440,168730460,2812174,0.0,0.0 240,1,2,2,168933800,2815563,1,168933800,168933800,2815563,0.0,0.0 300,1,2,2,169707160,2828452,1,169707160,169707160,2828452,0.0,0.0
60,1,2,2,122351320,2039188,1,122351320,122351300,2039188,0.0,0.0 120,1,2,2,171169140,2852819,1,171169140,171169160,2852819,0.0,0.0
| # ~/.tmuxinator/storm-launch.yml | |
| name: storm-launch | |
| root: . | |
| # Optional tmux socket | |
| # socket_name: foo | |
| # Runs before everything. Use it to start daemons etc. | |
| pre: |
| #!/usr/bin/python | |
| import time | |
| import datetime | |
| import pytz | |
| import numpy | |
| import random | |
| import gzip | |
| import zipfile | |
| import sys | |
| import argparse |
| package com.hortonworks.storm.test; | |
| import org.apache.storm.StormSubmitter; | |
| import org.apache.storm.generated.AlreadyAliveException; | |
| import org.apache.storm.generated.AuthorizationException; | |
| import org.apache.storm.generated.InvalidTopologyException; | |
| import org.apache.storm.generated.StormTopology; | |
| import org.apache.storm.metric.api.MeanReducer; | |
| import org.apache.storm.metric.api.ReducedMetric; | |
| import org.apache.storm.spout.SpoutOutputCollector; |
{
"metrics":[
{
"timestamp":0,
"metricname":"SUM(regionserver.RegionServer.receivedBytes._avg,regionserver.RegionServer.sentBytes._avg)",
"appid":"hbase",
"instanceid":"",
{
"metrics":[
{
"timestamp":0,
"metricname":"SUM(count.10.execute-count,count.11.execute-count,count.12.execute-count,count.13.execute-count,count.14.execute-count,count.3.execute-count,count.4.execute-count,count.5.execute-count,count.6.execute-count,count.7.execute-count,count.8.execute-count,count.9.execute-count)",
"appid":"metric-topology",
"instanceid":"",
| package org.apache.storm.starter; | |
| import org.apache.storm.Config; | |
| import org.apache.storm.LocalCluster; | |
| import org.apache.storm.StormSubmitter; | |
| import org.apache.storm.spout.SpoutOutputCollector; | |
| import org.apache.storm.task.OutputCollector; | |
| import org.apache.storm.task.TopologyContext; | |
| import org.apache.storm.testing.TestWordSpout; | |
| import org.apache.storm.topology.OutputFieldsDeclarer; |
| package redis.clients.jedis.tests; | |
| import org.apache.commons.lang3.ClassUtils; | |
| import org.junit.Test; | |
| import org.mockito.MockingDetails; | |
| import org.mockito.invocation.Invocation; | |
| import redis.clients.jedis.Client; | |
| import redis.clients.jedis.Pipeline; | |
| import uk.co.jemos.podam.api.PodamFactory; | |
| import uk.co.jemos.podam.api.PodamFactoryImpl; |
| { | |
| "window":":all-time", | |
| "window-hint":"All time", | |
| "components":{ | |
| "__acker":{ | |
| "emitted":{ | |
| "__metrics":40 | |
| }, | |
| "transferred":{ | |
| "__metrics":0 |
| /** | |
| * Licensed to the Apache Software Foundation (ASF) under one | |
| * or more contributor license agreements. See the NOTICE file | |
| * distributed with this work for additional information | |
| * regarding copyright ownership. The ASF licenses this file | |
| * to you under the Apache License, Version 2.0 (the | |
| * "License"); you may not use this file except in compliance | |
| * with the License. You may obtain a copy of the License at | |
| * | |
| * http://www.apache.org/licenses/LICENSE-2.0 |