@Internal public class WatermarkParams extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
WatermarkParams.WatermarkParamsBuilder
Builder of WatermarkHintParams.
|
Constructor and Description |
---|
WatermarkParams() |
WatermarkParams(WatermarkEmitStrategy emitStrategy,
String alignGroupName,
java.time.Duration alignMaxDrift,
java.time.Duration alignUpdateInterval,
long sourceIdleTimeout) |
Modifier and Type | Method and Description |
---|---|
boolean |
alignWatermarkEnabled() |
static WatermarkParams.WatermarkParamsBuilder |
builder() |
boolean |
equals(Object o) |
String |
getAlignGroupName() |
java.time.Duration |
getAlignMaxDrift() |
java.time.Duration |
getAlignUpdateInterval() |
WatermarkEmitStrategy |
getEmitStrategy() |
long |
getSourceIdleTimeout() |
int |
hashCode() |
void |
setAlignGroupName(String alignGroupName) |
void |
setAlignMaxDrift(java.time.Duration alignMaxDrift) |
void |
setAlignUpdateInterval(java.time.Duration alignUpdateInterval) |
void |
setEmitStrategy(WatermarkEmitStrategy emitStrategy) |
void |
setSourceIdleTimeout(long sourceIdleTimeout) |
String |
toString() |
public WatermarkParams()
public WatermarkParams(WatermarkEmitStrategy emitStrategy, String alignGroupName, java.time.Duration alignMaxDrift, java.time.Duration alignUpdateInterval, long sourceIdleTimeout)
public WatermarkEmitStrategy getEmitStrategy()
public void setEmitStrategy(WatermarkEmitStrategy emitStrategy)
public String getAlignGroupName()
public void setAlignGroupName(String alignGroupName)
public java.time.Duration getAlignMaxDrift()
public void setAlignMaxDrift(java.time.Duration alignMaxDrift)
public java.time.Duration getAlignUpdateInterval()
public void setAlignUpdateInterval(java.time.Duration alignUpdateInterval)
public long getSourceIdleTimeout()
public void setSourceIdleTimeout(long sourceIdleTimeout)
public boolean alignWatermarkEnabled()
public static WatermarkParams.WatermarkParamsBuilder builder()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.