/**
 * Initializes, for testing, two NoEmitMetricsContext's, and adds one value 
 * to the first of them.
 */
@Override
public void setUp() throws IOException {
  nc1 = new NoEmitMetricsContext();
  nc1.init("test1", ContextFactory.getFactory());
  nc2 = new NoEmitMetricsContext();
  nc2.init("test2", ContextFactory.getFactory());
  contexts = new ArrayList<MetricsContext>();
  contexts.add(nc1);
  contexts.add(nc2);

  MetricsRecord r = nc1.createRecord("testRecord");
  
  r.setTag("testTag1", "testTagValue1");
  r.setTag("testTag2", "testTagValue2");
  r.setMetric("testMetric1", 1);
  r.setMetric("testMetric2", 33);
  r.update();

  Map<String, Collection<OutputRecord>> m = nc1.getAllRecords();
  assertEquals(1, m.size());
  assertEquals(1, m.values().size());
  Collection<OutputRecord> outputRecords = m.values().iterator().next();
  assertEquals(1, outputRecords.size());
  outputRecord = outputRecords.iterator().next();
}
 

/**
 * Initializes, for testing, two NoEmitMetricsContext's, and adds one value 
 * to the first of them.
 */
@Override
public void setUp() throws IOException {
  nc1 = new NoEmitMetricsContext();
  nc1.init("test1", ContextFactory.getFactory());
  nc2 = new NoEmitMetricsContext();
  nc2.init("test2", ContextFactory.getFactory());
  contexts = new ArrayList<MetricsContext>();
  contexts.add(nc1);
  contexts.add(nc2);

  MetricsRecord r = nc1.createRecord("testRecord");
  
  r.setTag("testTag1", "testTagValue1");
  r.setTag("testTag2", "testTagValue2");
  r.setMetric("testMetric1", 1);
  r.setMetric("testMetric2", 33);
  r.update();

  Map<String, Collection<OutputRecord>> m = nc1.getAllRecords();
  assertEquals(1, m.size());
  assertEquals(1, m.values().size());
  Collection<OutputRecord> outputRecords = m.values().iterator().next();
  assertEquals(1, outputRecords.size());
  outputRecord = outputRecords.iterator().next();
}
 

/**
 * Initializes, for testing, two NoEmitMetricsContext's, and adds one value 
 * to the first of them.
 */
public void setUp() throws IOException {
  nc1 = new NoEmitMetricsContext();
  nc1.init("test1", ContextFactory.getFactory());
  nc2 = new NoEmitMetricsContext();
  nc2.init("test2", ContextFactory.getFactory());
  contexts = new ArrayList<MetricsContext>();
  contexts.add(nc1);
  contexts.add(nc2);

  MetricsRecord r = nc1.createRecord("testRecord");
  
  r.setTag("testTag1", "testTagValue1");
  r.setTag("testTag2", "testTagValue2");
  r.setMetric("testMetric1", 1);
  r.setMetric("testMetric2", 33);
  r.update();

  Map<String, Collection<OutputRecord>> m = nc1.getAllRecords();
  assertEquals(1, m.size());
  assertEquals(1, m.values().size());
  Collection<OutputRecord> outputRecords = m.values().iterator().next();
  assertEquals(1, outputRecords.size());
  outputRecord = outputRecords.iterator().next();
}
 

private void setNoEmitMetricsContext() throws IOException {
  ContextFactory factory = ContextFactory.getFactory();
  factory.setAttribute(ClusterManagerMetrics.CONTEXT_NAME + ".class",
      NoEmitMetricsContext.class.getName());
}
 

private void setNoEmitMetricsContext() throws IOException {
  ContextFactory factory = ContextFactory.getFactory();
  factory.setAttribute(ClusterManagerMetrics.CONTEXT_NAME + ".class",
      NoEmitMetricsContext.class.getName());
}