Interface FlatMapFunction

    • Method Detail

      • execute

        Iterable<Values> execute​(TridentTuple input)
        Invoked by the framework for each trident tuple in a stream.
        Parameters:
        input - the input trident tuple
        Returns:
        an iterable over the resultant values