test case for Insert added

package/streamsx/eventstore/tests/test_eventstore.py

@@ -84,7 +84,6 @@ def test_insert(self):
         streamsx.spl.toolkit.add_toolkit(topo, self.es_toolkit)
         s = self._create_stream(topo)
         res = es.insert(s, config='eventstore', table='SampleTablePy', primary_key='id', ssl_connection=False, plugin_flag=False)      
-
         # build only
         self._build_only(name, topo)
 
@@ -96,9 +95,20 @@ def test_statement(self):
         s = topo.source(['DROP TABLE STR_SAMPLE']).as_string()
         res_sql = s.map(es.SQLStatement(credentials='eventstore'), schema=CommonSchema.String)
         res_sql.print()
+        # build only
+        self._build_only(name, topo)
 
+    def test_insert_composite(self):
+        print ('\n---------'+str(self))
+        name = 'test_insert_composite'
+        topo = Topology(name)
+        streamsx.spl.toolkit.add_toolkit(topo, self.es_toolkit)
+        s = self._create_stream(topo)
+        s.for_each(es.Insert(config='eventstore', table='SampleTablePy', primary_key='id', ssl_connection=False, plugin_flag=False))
+        # build only
         self._build_only(name, topo)
 
+
 class TestDownloadToolkit(unittest.TestCase):
     @classmethod
     def tearDownClass(cls):