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:

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

Parameters:

input -

Returns: