In [ ]:

    

from multitransform_functions import TweetSource, HashTags
from streamsx.topology.topology import Topology
from streamsx.topology import context


    

In [ ]:

    

top = Topology("myTop")

tweet_source_operator = TweetSource()
hash_tag_operator = HashTags()

tweets = top.source(tweet_source_operator)

hashtags = tweets.multi_transform(hash_tag_operator)
hashtags.print()
context.submit("STANDALONE", top.graph)


    

In [ ]: