BeamStreamProvider.Default

java.lang.Object
- cz.o2.proxima.beam.tools.groovy.BeamStreamProvider
- - cz.o2.proxima.beam.tools.groovy.BeamStreamProvider.Default

All Implemented Interfaces:

StreamProvider, java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

BeamStreamProvider
```
@AutoService(StreamProvider.class)
public static class BeamStreamProvider.Default
extends BeamStreamProvider
```

Nested Class Summary
- Nested classes/interfaces inherited from class cz.o2.proxima.beam.tools.groovy.BeamStreamProvider
  BeamStreamProvider.Default, BeamStreamProvider.RunnerRegistrar
- Nested classes/interfaces inherited from interface cz.o2.proxima.tools.groovy.StreamProvider
  StreamProvider.TerminatePredicate

Constructor Summary

Constructors
Constructor Description

Default()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected java.util.function.Supplier<org.apache.beam.sdk.options.PipelineOptions>`	`getPipelineOptionsFactory()`	Create factory to be used for pipeline creation.
`void`	`init(Repository repo, java.lang.String[] args)`	Initialize the provider with given repository.

Methods inherited from class cz.o2.proxima.beam.tools.groovy.BeamStreamProvider
close, getBatchSnapshot, getBatchUpdates, getCreatePipelineFromOpts, getStream, impulse, periodicImpulse, wrap

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

Methods inherited from interface cz.o2.proxima.tools.groovy.StreamProvider
impulse, periodicImpulse

- Constructor Detail
  - Default
```
public Default()
```
- Method Detail
  - init
```
public void init(Repository repo,
                 java.lang.String[] args)
```
    Description copied from interface: StreamProvider
    
    Initialize the provider with given repository.
    
    Specified by:
    
    init in interface StreamProvider
    
    Overrides:
    
    init in class BeamStreamProvider
    
    Parameters:
    
    repo - the repository
    
    args - command line arguments passed to Console
  - getPipelineOptionsFactory
```
protected java.util.function.Supplier<org.apache.beam.sdk.options.PipelineOptions> getPipelineOptionsFactory()
```
    Description copied from class: BeamStreamProvider
    
    Create factory to be used for pipeline creation.
    
    Overrides:
    
    getPipelineOptionsFactory in class BeamStreamProvider
    
    Returns:
    
    the factory