test_class.file: bigdata-intro/cep-intro/siddhi-kafka-rest/src/test/java/net/redborder/cep/siddhi/SiddhiPlanTest.java
test_class.identifier: SiddhiPlanTest
test_class.superclass: extends TestCase
test_case.body: @Test(expected = TransformException.class)
      public void createsFromMapInvalid() throws ExecutionPlanException {
          // Build a map with the execution plan data
          Map<String, Object> executionPlanMap = new HashMap<>();
          Map<String, String> outputTopics = new HashMap<>();
          outputTopics.put("testOutput", "outputTopic");
          // executionPlanMap.put("id", "testID");
          executionPlanMap.put("input", Arrays.asList("test", "test2"));
          executionPlanMap.put("output", outputTopics);
          executionPlanMap.put("executionPlan", "from test select a insert into testOutput");
  
          // Create the execution plan
          SiddhiPlan.fromMap(executionPlanMap);
      }
test_case.class_method_signature: SiddhiPlanTest.createsFromMapInvalid()
test_case.full_signature: @Test(expected = TransformException.class) public void createsFromMapInvalid()
test_case.identifier: createsFromMapInvalid
test_case.invocations: put put asList put put fromMap
test_case.modifiers: @Test(expected = TransformException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void createsFromMapInvalid()
focal_class.declarator: log = LoggerFactory.getLogger(SiddhiPlan.class)
focal_class.modifier: private final static
focal_class.original_string: private final static Logger log = LoggerFactory.getLogger(SiddhiPlan.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: streamDefinitions = new HashMap<>()
focal_class.modifier: private final static
focal_class.original_string: private final static Map<String, StreamDefinition> streamDefinitions = new HashMap<>();
focal_class.type: Map<String, StreamDefinition>
focal_class.var_name: streamDefinitions
focal_class.declarator: inputTopics
focal_class.modifier: private final
focal_class.original_string: private final List<String> inputTopics;
focal_class.type: List<String>
focal_class.var_name: inputTopics
focal_class.declarator: outputTopics
focal_class.modifier: private final
focal_class.original_string: private final Map<String, String> outputTopics;
focal_class.type: Map<String, String>
focal_class.var_name: outputTopics
focal_class.declarator: filters
focal_class.modifier: private final
focal_class.original_string: private final Map<String, String> filters;
focal_class.type: Map<String, String>
focal_class.var_name: filters
focal_class.declarator: executionPlan
focal_class.modifier: private final
focal_class.original_string: private final String executionPlan, id;
focal_class.type: String
focal_class.var_name: executionPlan
focal_class.declarator: fullExecutionPlan
focal_class.modifier: private final
focal_class.original_string: private final String fullExecutionPlan;
focal_class.type: String
focal_class.var_name: fullExecutionPlan
focal_class.declarator: version
focal_class.modifier: private final
focal_class.original_string: private final int version;
focal_class.type: int
focal_class.var_name: version
focal_class.declarator: executionPlanRuntime
focal_class.modifier: private
focal_class.original_string: private ExecutionPlanRuntime executionPlanRuntime;
focal_class.type: ExecutionPlanRuntime
focal_class.var_name: executionPlanRuntime
focal_class.file: bigdata-intro/cep-intro/siddhi-kafka-rest/src/main/java/net/redborder/cep/siddhi/SiddhiPlan.java
focal_class.identifier: SiddhiPlan
focal_class.class_method_signature: SiddhiPlan.fromMap(Map<String, Object> map)
focal_class.full_signature: @SuppressWarnings("unchecked") public static SiddhiPlan fromMap(Map<String, Object> map)
focal_class.identifier: fromMap
focal_class.modifiers: @SuppressWarnings("unchecked") public static
focal_class.parameters: (Map<String, Object> map)
focal_class.return: SiddhiPlan
focal_class.signature: SiddhiPlan fromMap(Map<String, Object> map)
focal_class.class_method_signature: SiddhiPlan.getField(Map<String, Object> map, String key, T defaultValue, Class<T> type, boolean required)
focal_class.full_signature: private static T getField(Map<String, Object> map, String key, T defaultValue, Class<T> type, boolean required)
focal_class.identifier: getField
focal_class.modifiers: private static
focal_class.parameters: (Map<String, Object> map, String key, T defaultValue, Class<T> type, boolean required)
focal_class.return: T
focal_class.signature: T getField(Map<String, Object> map, String key, T defaultValue, Class<T> type, boolean required)
focal_class.class_method_signature: SiddhiPlan.getField(Map<String, Object> map, String key, Class<T> type)
focal_class.full_signature: private static T getField(Map<String, Object> map, String key, Class<T> type)
focal_class.identifier: getField
focal_class.modifiers: private static
focal_class.parameters: (Map<String, Object> map, String key, Class<T> type)
focal_class.return: T
focal_class.signature: T getField(Map<String, Object> map, String key, Class<T> type)
focal_class.class_method_signature: SiddhiPlan.getField(Map<String, Object> map, String key, T defaultValue, Class<T> type)
focal_class.full_signature: private static T getField(Map<String, Object> map, String key, T defaultValue, Class<T> type)
focal_class.identifier: getField
focal_class.modifiers: private static
focal_class.parameters: (Map<String, Object> map, String key, T defaultValue, Class<T> type)
focal_class.return: T
focal_class.signature: T getField(Map<String, Object> map, String key, T defaultValue, Class<T> type)
focal_class.class_method_signature: SiddhiPlan.SiddhiPlan(String id, int version, List<String> inputTopics,
                        Map<String, String> outputTopics, Map<String, String> filters,
                        String executionPlan)
focal_class.full_signature: public  SiddhiPlan(String id, int version, List<String> inputTopics,
                        Map<String, String> outputTopics, Map<String, String> filters,
                        String executionPlan)
focal_class.identifier: SiddhiPlan
focal_class.modifiers: public
focal_class.parameters: (String id, int version, List<String> inputTopics,
                        Map<String, String> outputTopics, Map<String, String> filters,
                        String executionPlan)
focal_class.signature:  SiddhiPlan(String id, int version, List<String> inputTopics,
                        Map<String, String> outputTopics, Map<String, String> filters,
                        String executionPlan)
focal_class.class_method_signature: SiddhiPlan.toMap()
focal_class.full_signature: public Map<String, Object> toMap()
focal_class.identifier: toMap
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> toMap()
focal_class.class_method_signature: SiddhiPlan.getId()
focal_class.full_signature: public String getId()
focal_class.identifier: getId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getId()
focal_class.class_method_signature: SiddhiPlan.getVersion()
focal_class.full_signature: public long getVersion()
focal_class.identifier: getVersion
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long getVersion()
focal_class.class_method_signature: SiddhiPlan.getInput()
focal_class.full_signature: public List<String> getInput()
focal_class.identifier: getInput
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: List<String>
focal_class.signature: List<String> getInput()
focal_class.class_method_signature: SiddhiPlan.getOutput()
focal_class.full_signature: public Map<String, String> getOutput()
focal_class.identifier: getOutput
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> getOutput()
focal_class.class_method_signature: SiddhiPlan.getExecutionPlan()
focal_class.full_signature: public String getExecutionPlan()
focal_class.identifier: getExecutionPlan
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getExecutionPlan()
focal_class.class_method_signature: SiddhiPlan.build()
focal_class.full_signature: public String build()
focal_class.identifier: build
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String build()
focal_class.class_method_signature: SiddhiPlan.getFullExecutionPlan()
focal_class.full_signature: public String getFullExecutionPlan()
focal_class.identifier: getFullExecutionPlan
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getFullExecutionPlan()
focal_class.class_method_signature: SiddhiPlan.send(String topicName, Map<String, Object> data)
focal_class.full_signature: public void send(String topicName, Map<String, Object> data)
focal_class.identifier: send
focal_class.modifiers: public
focal_class.parameters: (String topicName, Map<String, Object> data)
focal_class.return: void
focal_class.signature: void send(String topicName, Map<String, Object> data)
focal_class.class_method_signature: SiddhiPlan.start(SiddhiManager siddhiManager, SiddhiCallback siddhiCallback)
focal_class.full_signature: public void start(SiddhiManager siddhiManager, SiddhiCallback siddhiCallback)
focal_class.identifier: start
focal_class.modifiers: public
focal_class.parameters: (SiddhiManager siddhiManager, SiddhiCallback siddhiCallback)
focal_class.return: void
focal_class.signature: void start(SiddhiManager siddhiManager, SiddhiCallback siddhiCallback)
focal_class.class_method_signature: SiddhiPlan.stop()
focal_class.full_signature: public void stop()
focal_class.identifier: stop
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_method.body: @SuppressWarnings("unchecked")
      public static SiddhiPlan fromMap(Map<String, Object> map) throws ExecutionPlanException {
          String id = getField(map, "id", String.class);
          List<String> inputTopics = getField(map, "input", List.class);
          Map<String, String> outputTopics = getField(map, "output", Map.class);
          Map<String, String> filters = getField(map, "filters", Collections.emptyMap(), Map.class);
          String plan = getField(map, "executionPlan", String.class);
          Integer version = getField(map, "version", 0, Integer.class);
  
          return new SiddhiPlan(id, version, inputTopics, outputTopics, filters, plan);
      }
focal_method.class_method_signature: SiddhiPlan.fromMap(Map<String, Object> map)
focal_method.full_signature: @SuppressWarnings("unchecked") public static SiddhiPlan fromMap(Map<String, Object> map)
focal_method.identifier: fromMap
focal_method.invocations: getField getField getField getField emptyMap getField getField
focal_method.modifiers: @SuppressWarnings("unchecked") public static
focal_method.parameters: (Map<String, Object> map)
focal_method.return: SiddhiPlan
focal_method.signature: SiddhiPlan fromMap(Map<String, Object> map)