Validates the data setup in #setupStorage() is returned in the requests. @throws Exception if something went pear shaped.
()
| 792 | * @throws Exception if something went pear shaped. |
| 793 | */ |
| 794 | protected void validateSpansNometa() throws Exception { |
| 795 | assertEquals(6, spans.size()); |
| 796 | Span span = spans.get(getRowKey(METRIC_STRING, (int) start_ts, TAGK_STRING, |
| 797 | "A", TAGK_B_STRING, "D", "E", "F")); |
| 798 | SeekableView view = span.iterator(); |
| 799 | long ts = start_ts * 1000; |
| 800 | long v = 1; |
| 801 | while (view.hasNext()) { |
| 802 | DataPoint dp = view.next(); |
| 803 | assertEquals(ts, dp.timestamp()); |
| 804 | assertEquals(v++, dp.longValue()); |
| 805 | ts += 3600000; |
| 806 | } |
| 807 | |
| 808 | span = spans.get(getRowKey(METRIC_STRING, (int) start_ts, TAGK_STRING, |
| 809 | "B", TAGK_B_STRING, "D", "E", "F")); |
| 810 | view = span.iterator(); |
| 811 | ts = start_ts * 1000; |
| 812 | v = 11; |
| 813 | while (view.hasNext()) { |
| 814 | DataPoint dp = view.next(); |
| 815 | assertEquals(ts, dp.timestamp()); |
| 816 | assertEquals(v++, dp.longValue()); |
| 817 | ts += 3600000; |
| 818 | } |
| 819 | |
| 820 | span = spans.get(getRowKey(METRIC_STRING, (int) start_ts, TAGK_STRING, |
| 821 | "C", TAGK_B_STRING, "D", "E", "F")); |
| 822 | view = span.iterator(); |
| 823 | ts = start_ts * 1000; |
| 824 | v = 111; |
| 825 | while (view.hasNext()) { |
| 826 | DataPoint dp = view.next(); |
| 827 | assertEquals(ts, dp.timestamp()); |
| 828 | assertEquals(v++, dp.longValue()); |
| 829 | ts += 3600000; |
| 830 | } |
| 831 | |
| 832 | span = spans.get(getRowKey(METRIC_STRING, (int) start_ts, TAGK_STRING, |
| 833 | "A", TAGK_B_STRING, "D", "E", "G")); |
| 834 | view = span.iterator(); |
| 835 | ts = start_ts * 1000; |
| 836 | v = 1111; |
| 837 | while (view.hasNext()) { |
| 838 | DataPoint dp = view.next(); |
| 839 | assertEquals(ts, dp.timestamp()); |
| 840 | assertEquals(v++, dp.longValue()); |
| 841 | ts += 3600000; |
| 842 | } |
| 843 | |
| 844 | span = spans.get(getRowKey(METRIC_STRING, (int) start_ts, TAGK_STRING, |
| 845 | "B", TAGK_B_STRING, "D", "E", "G")); |
| 846 | view = span.iterator(); |
| 847 | ts = start_ts * 1000; |
| 848 | v = 11111; |
| 849 | while (view.hasNext()) { |
| 850 | DataPoint dp = view.next(); |
| 851 | assertEquals(ts, dp.timestamp()); |