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:

Stream, FirstN

Method Summary

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

Method Detail

apply

Stream apply(Stream input)

Applies the `Assembly` to a given Stream.