Package org.apache.storm.trident.operation

Interface Assembly

All Known Implementing Classes:
FirstN
public interface Assembly
The `Assembly` interface provides a means to encapsulate logic applied to a Stream.

Usage:

```java Stream mystream = ...; Stream assemblyStream = mystream.applyAssembly(myAssembly); ```

See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    Stream
    apply(Stream input)
    Applies the `Assembly` to a given Stream.

  • Method Details