WatermarkConfiguration

java.lang.Object
- cz.o2.proxima.direct.core.time.WatermarkConfiguration

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

KafkaWatermarkConfiguration, PubSubWatermarkConfiguration
```
public abstract class WatermarkConfiguration
extends java.lang.Object
implements java.io.Serializable
```
Watermark configuration

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field Description

static java.lang.String CFG_ESTIMATOR_FACTORY

static java.lang.String CFG_IDLE_POLICY_FACTORY

static java.lang.String CFG_PREFIX

Constructor Summary

Constructors
Modifier Constructor Description

protected WatermarkConfiguration(java.util.Map<java.lang.String,java.lang.Object> cfg)

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`protected void`	`configure()`
`protected abstract WatermarkEstimatorFactory`	`getDefaultEstimatorFactory()`	Returns default estimator factory when none user's factory is provided.
`protected abstract WatermarkIdlePolicyFactory`	`getDefaultIdlePolicyFactory()`	Returns default idle policy factory when none user's factory is provided.
`static java.lang.String`	`prefixedKey(java.lang.String cfgName)`	Returns configuration key with added watermark config prefix.

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

- Field Detail
  - CFG_PREFIX
```
public static final java.lang.String CFG_PREFIX
```
    See Also:
    
    Constant Field Values
  - CFG_ESTIMATOR_FACTORY
```
public static final java.lang.String CFG_ESTIMATOR_FACTORY
```
    See Also:
    
    Constant Field Values
  - CFG_IDLE_POLICY_FACTORY
```
public static final java.lang.String CFG_IDLE_POLICY_FACTORY
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - WatermarkConfiguration
```
protected WatermarkConfiguration(java.util.Map<java.lang.String,java.lang.Object> cfg)
```
- Method Detail
  - prefixedKey
```
public static java.lang.String prefixedKey(java.lang.String cfgName)
```
    Returns configuration key with added watermark config prefix.
    
    Parameters:
    
    cfgName - config key name
    
    Returns:
    
    full key name
  - getDefaultIdlePolicyFactory
```
protected abstract WatermarkIdlePolicyFactory getDefaultIdlePolicyFactory()
```
    Returns default idle policy factory when none user's factory is provided.
    
    Returns:
    
    WatermarkIdlePolicyFactory default idle watermark policy
  - getDefaultEstimatorFactory
```
protected abstract WatermarkEstimatorFactory getDefaultEstimatorFactory()
```
    Returns default estimator factory when none user's factory is provided.
    
    Returns:
    
    WatermarkEstimatorFactory default watermark estimator factory.
  - configure
```
protected final void configure()
```