contrib/src/test/java/com/datatorrent/contrib/testhelper/CollectorModule.java

package com.datatorrent.contrib.testhelper;

import com.datatorrent.api.BaseOperator;


public class CollectorModule<T> extends BaseOperator
{
  public final transient CollectorInputPort<T> inputPort = new CollectorInputPort<T>("collector", this);
}