ProximaIO

java.lang.Object
- cz.o2.proxima.beam.io.ProximaIO

@Experimental
public class ProximaIO
extends java.lang.Object

IO connector for Proxima platform.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class ProximaIO.Write
Transformation that writes stream elements into proxima using DirectDataOperator.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static ProximaIO.Write`	`write(RepositoryFactory repositoryFactory)`	Write `stream elements` into proxima using `DirectDataOperator`.

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

- Method Detail
  - write
```
public static ProximaIO.Write write(RepositoryFactory repositoryFactory)
```
    Write stream elements into proxima using DirectDataOperator.
    
    Parameters:
    
    repositoryFactory - Serializable factory for Proxima repository.
    
    Returns:
    
    Write transform.