import org.wso2.siddhi.query.api.definition.Attribute;
import org.wso2.siddhi.query.api.definition.StreamDefinition;
import org.wso2.siddhi.query.api.exception.ExecutionPlanValidationException;
import org.wso2.siddhi.query.api.execution.Subscription;
import org.wso2.siddhi.query.api.execution.io.Transport;
<BUG>import org.wso2.siddhi.query.api.execution.io.map.Mapping;
public class JsonInputMapperTestCase {</BUG>
static final Logger log = Logger.getLogger(JsonInputMapperTestCase.class);
@Test
public void subscriptionTest1() throws InterruptedException {

import org.wso2.siddhi.query.api.definition.Attribute;
import org.wso2.siddhi.query.api.definition.StreamDefinition;
import org.wso2.siddhi.query.api.exception.ExecutionPlanValidationException;
import org.wso2.siddhi.query.api.execution.Subscription;
import org.wso2.siddhi.query.api.execution.io.Transport;
import org.wso2.siddhi.query.api.execution.io.map.Mapping;
import org.wso2.siddhi.query.compiler.SiddhiCompiler;
public class JsonInputMapperTestCase {
static final Logger log = Logger.getLogger(JsonInputMapperTestCase.class);
@Test
public void subscriptionTest1() throws InterruptedException {
