# Package org.apache.storm.streams.operations

package org.apache.storm.streams.operations

- Related Packages
  Package
  Description
  org.apache.storm.streams
  org.apache.storm.streams.operations.aggregators
  org.apache.storm.streams.operations.mappers
  org.apache.storm.streams.processors
  org.apache.storm.streams.tuple
  org.apache.storm.streams.windowing
- Class
  Description
  BiFunction<T,U,R>
  a function that accepts two arguments and produces a result.
  CombinerAggregator<T,A,R>
  Interface for aggregating values.
  Consumer<T>
  Represents an operation that accepts a single input argument and returns no result.
  FlatMapFunction<T,R>
  A function that accepts one argument and returns an `Iterable` of elements as its result.
  Function<T,R>
  Represents a function that accepts one argument and produces a result.
  IdentityFunction<T>
  A `Function` that returns the input argument itself as the result.
  Operation
  The parent interface for any kind of streaming operation.
  PairFlatMapFunction<T,K,V>
  A function that accepts one argument and returns an `Iterable` of `Pair` as its result.
  PairFunction<T,K,V>
  A function that accepts an argument and produces a key-value Pair.
  PairValueJoiner<V1,V2>
  A `ValueJoiner` that joins two values to produce a `Pair` of the two values as the result.
  Predicate<T>
  Represents a predicate (boolean-valued function) of a value.
  PrintConsumer<T>
  A consumer that prints the input to stdout.
  Reducer<T>
  The `Reducer` performs an operation on two values of the same type producing a result of the same type.
  StateUpdater<T,S>
  Interface for updating state.
  ValueJoiner<V1,V2,R>
  An interface for joining two values to produce a result.