public void testTransforms() throws Exception {
MockMetrics mockMetrics = new MockMetrics();
List<Transformation> transforms = Lists.<Transformation>newArrayList(
new IntToDouble(), new Filter(100d), new DoubleToString());
List<StageMetrics> stageMetrics = Lists.newArrayList(
<BUG>new StageMetrics(mockMetrics, StageMetrics.Type.SOURCE, "first"),
new StageMetrics(mockMetrics, StageMetrics.Type.TRANSFORM, "second"),
new StageMetrics(mockMetrics, StageMetrics.Type.SINK, "third")
);</BUG>
TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms, stageMetrics);

public void testTransforms() throws Exception {
MockMetrics mockMetrics = new MockMetrics();
List<Transformation> transforms = Lists.<Transformation>newArrayList(
new IntToDouble(), new Filter(100d), new DoubleToString());
List<StageMetrics> stageMetrics = Lists.newArrayList(
new StageMetrics(mockMetrics, PluginID.from(Constants.Source.PLUGINTYPE, "first", 1)),
new StageMetrics(mockMetrics, PluginID.from(Constants.Transform.PLUGINTYPE, "second", 2)),
new StageMetrics(mockMetrics, PluginID.from(Constants.Sink.PLUGINTYPE, "third", 3))
);
TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms, stageMetrics);
