import co.cask.cdap.api.flow.flowlet.StreamEvent;
import com.google.common.base.Charsets;
import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;
import co.cask.cdap.api.flow.flowlet.StreamEvent;
import com.google.common.base.Charsets;
import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;