Interface MapFunction

    • Method Detail

      • execute

        Values execute​(TridentTuple input)
        Invoked by the framework for each trident tuple in a stream.
        Parameters:
        input - the input trident tuple
        Returns:
        the transformed values