ProximaIO.Write

java.lang.Object
- org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<StreamElement>,org.apache.beam.sdk.values.PDone>
- - cz.o2.proxima.beam.io.ProximaIO.Write

All Implemented Interfaces:

java.io.Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

ProximaIO
```
public static class ProximaIO.Write
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<StreamElement>,org.apache.beam.sdk.values.PDone>
```
Transformation that writes stream elements into proxima using DirectDataOperator.

See Also:

Serialized Form

- Field Summary
  - Fields inherited from class org.apache.beam.sdk.transforms.PTransform
    annotations, displayData, name, resourceHints
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  org.apache.beam.sdk.values.PDone expand(org.apache.beam.sdk.values.PCollection<StreamElement> input)
  - Methods inherited from class org.apache.beam.sdk.transforms.PTransform
    addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Method Detail
  - expand
```
public org.apache.beam.sdk.values.PDone expand(org.apache.beam.sdk.values.PCollection<StreamElement> input)
```
    Specified by:
    
    expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<StreamElement>,org.apache.beam.sdk.values.PDone>