ElementWiseTransformation

All Superinterfaces:

DataOperatorAgnostic, DataOperatorAware, java.io.Serializable, Transformation

All Known Implementing Classes:

IdentityTransformation, RenameTransformation
```
@Evolving
public interface ElementWiseTransformation
extends Transformation, DataOperatorAgnostic
```
A stateless element-wise transformation applied on incoming data converting single StreamElement to another StreamElement(s).

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface ElementWiseTransformation.Collector<T>
Collector for outputs.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`int`	`apply(StreamElement input, ElementWiseTransformation.Collector<StreamElement> collector)`	Apply the transformation function.
`void`	`setup(Repository repo, java.util.Map<java.lang.String,java.lang.Object> cfg)`	Setup this transform.

Methods inherited from interface cz.o2.proxima.core.transform.DataOperatorAgnostic
isContextual, isDelegateOf

Methods inherited from interface cz.o2.proxima.core.transform.DataOperatorAware
as

Methods inherited from interface cz.o2.proxima.core.transform.Transformation
asContextualTransform, asElementWiseTransform

- Method Detail
  - setup
```
void setup(Repository repo,
           java.util.Map<java.lang.String,java.lang.Object> cfg)
```
    Setup this transform.
    
    Parameters:
    
    repo - repository
    
    cfg - configuration
  - apply
```
int apply(StreamElement input,
          ElementWiseTransformation.Collector<StreamElement> collector)
```
    Apply the transformation function.
    
    Parameters:
    
    input - the input stream element to transform
    
    collector - collector for outputs
    
    Returns:
    
    how many invocations of collector to expect before the elements should be considered processed