@Test
public void testGetDataSourceId() throws Exception {

    Map<String, Object> map = new HashMap<>();
    map.put("a", "aval");
    map.put("b", "bval");
    StreamlineEvent event = StreamlineEventImpl.builder().fieldsAndValues(map).dataSourceId("1").build();
    assertEquals("1", event.getDataSourceId());
}