CreateViewTransform (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,I>>,org.apache.beam.sdk.util.WindowedValue<O>>
- - org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform<I,O>

Type Parameters:

I - input type

O - materialized output type

All Implemented Interfaces:

java.io.Serializable, Transform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,I>>,org.apache.beam.sdk.util.WindowedValue<O>>
```
public final class CreateViewTransform<I,O>
extends LatencymarkEmitTransform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,I>>,org.apache.beam.sdk.util.WindowedValue<O>>
```
This transforms emits materialized data for each window.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class CreateViewTransform.MultiView<T>
Represents PrimitiveViewT supplied to the ViewFn.
- Nested classes/interfaces inherited from interface org.apache.nemo.common.ir.vertex.transform.Transform
  Transform.Context

Constructor Summary

Constructors
Constructor	Description
`CreateViewTransform(org.apache.beam.sdk.transforms.ViewFn<org.apache.beam.sdk.transforms.Materializations.MultimapView<java.lang.Void,?>,O> viewFn)`	Constructor of CreateViewTransform.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Close the transform.
`void`	`onData(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,I>> element)`	On data received.
`void`	`onWatermark(Watermark inputWatermark)`	On watermark received.
`java.lang.String`	`toString()`

Methods inherited from class org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform
getOutputCollector, onLatencymark, prepare

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - CreateViewTransform
```
public CreateViewTransform(org.apache.beam.sdk.transforms.ViewFn<org.apache.beam.sdk.transforms.Materializations.MultimapView<java.lang.Void,?>,O> viewFn)
```
    Constructor of CreateViewTransform.
    
    Parameters:
    
    viewFn - the viewFn that materializes data.
- Method Detail
  - onData
```
public void onData(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,I>> element)
```
    Description copied from interface: Transform
    
    On data received.
    
    Parameters:
    
    element - data received.
  - onWatermark
```
public void onWatermark(Watermark inputWatermark)
```
    Description copied from interface: Transform
    
    On watermark received. This method should be called for the minimum watermark among input streams (input watermark). Transform may emit collected data after receiving watermarks.
    
    Parameters:
    
    inputWatermark - watermark
  - close
```
public void close()
```
    Description copied from interface: Transform
    
    Close the transform.
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object