{
"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":"",
HeartSaVioR
/ topology-metrics.json
Created
April 16, 2016 10:25
Apache Storm - Topology metrics detail preview
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "window":":all-time", | |
| "window-hint":"All time", | |
| "components":{ | |
| "__acker":{ | |
| "emitted":{ | |
| "__metrics":40 | |
| }, | |
| "transferred":{ | |
| "__metrics":0 |
HeartSaVioR
/ SanityTest.java
Created
April 19, 2016 02:45
SanityTest for PipelineBase with Mock and Reflection (POC)
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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; |
HeartSaVioR
/ DelayedExclamationTopology.java
Created
April 29, 2016 07:09
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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; |
HeartSaVioR
/ ambari-collect-api-applying-series-aggregator.md
Created
June 3, 2016 11:03
HeartSaVioR
/ ambari-collect-api-applying-series-aggregator-v2.md
Created
June 8, 2016 05:10
Ambari Collect API: Applying SeriesAggregator
{
"metrics":[
{
"timestamp":0,
"metricname":"SUM(regionserver.RegionServer.receivedBytes._avg,regionserver.RegionServer.sentBytes._avg)",
"appid":"hbase",
"instanceid":"",
HeartSaVioR
/ CustomMetricTopology.java
Created
July 5, 2016 07:25
Full source code of CustomMetricTopology
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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; |
HeartSaVioR
/ apache-fake-log-gen.py
Created
October 8, 2016 23:04
kiritbasu/Fake-Apache-Log-Generator modified for storm-sql-example
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/python | |
| import time | |
| import datetime | |
| import pytz | |
| import numpy | |
| import random | |
| import gzip | |
| import zipfile | |
| import sys | |
| import argparse |
HeartSaVioR
/ storm-launch.yaml
Last active
December 29, 2016 09:56
tmuxinator storm-launch current directory
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # ~/.tmuxinator/storm-launch.yml | |
| name: storm-launch | |
| root: . | |
| # Optional tmux socket | |
| # socket_name: foo | |
| # Runs before everything. Use it to start daemons etc. | |
| pre: |
HeartSaVioR
/ STORM-2678-benchmark-result.md
Last active
August 22, 2017 08:33
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
HeartSaVioR
/ test_runner_tvl_2.0.0.sh
Created
February 14, 2018 10:23
TVL 2.0.0 test runner (for 4 workers)
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/bin/bash | |
| current_test=1 | |
| test_count=3 | |
| storm_directory="`pwd`" | |
| part1=`dirname "${storm_directory}"` | |
| part2=`basename "${storm_directory}"` |