diff --git a/Test/start.py b/Test/start.py index e7eaa10d..9122e009 100644 --- a/Test/start.py +++ b/Test/start.py @@ -14,12 +14,12 @@ event, ssc = connector.Prime(sc, 5 , StorageLevel.MEMORY_AND_DISK_2) event = event.flatMap(lambda x: x.entities).map(lambda x: x.attrs['price'].value) -#response = event.map(lambda x : replier.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }')) -#response2 = event.map(lambda x: replier.SemistructuredReplyToBroker("20", '{"value" : %%TOREPLACE%% }')) +response = event.map(lambda x : replier.UnstructuredReplyToBroker('{ "value" :' + str(20) +' }')) +response2 = event.map(lambda x: replier.SemistructuredReplyToBroker("20", '{"value" : %%TOREPLACE%% }')) response3 = event.map(lambda x : replier.ReplyToBroker("20")) event.pprint() -#response.pprint() -#response2.pprint() +response.pprint() +response2.pprint() response3.pprint()