package CountCounts;
import com.continuuity.api.flow.flowlet.AbstractFlowlet;
<BUG>import com.continuuity.api.flow.flowlet.InputContext;</BUG>
import com.continuuity.api.flow.flowlet.OutputEmitter;
import com.continuuity.api.flow.flowlet.StreamEvent;
import java.nio.ByteBuffer;
<BUG>import java.nio.charset.CharacterCodingException;</BUG>
public class StreamSource extends AbstractFlowlet {

package CountCounts;
import com.continuuity.api.flow.flowlet.AbstractFlowlet;
import com.continuuity.api.flow.flowlet.OutputEmitter;
import com.continuuity.api.flow.flowlet.StreamEvent;
import java.nio.ByteBuffer;
public class StreamSource extends AbstractFlowlet {
