@PublicEvolving public class RowtimeValidator extends Object implements DescriptorValidator
Rowtime
.Constructor and Description |
---|
RowtimeValidator(boolean supportsSourceTimestamps,
boolean supportsSourceWatermarks) |
RowtimeValidator(boolean supportsSourceTimestamps,
boolean supportsSourceWatermarks,
String prefix) |
Modifier and Type | Method and Description |
---|---|
static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> |
getRowtimeComponents(DescriptorProperties properties,
String prefix) |
void |
validate(DescriptorProperties properties)
Performs basic validation such as completeness tests.
|
public RowtimeValidator(boolean supportsSourceTimestamps, boolean supportsSourceWatermarks)
public RowtimeValidator(boolean supportsSourceTimestamps, boolean supportsSourceWatermarks, String prefix)
public void validate(DescriptorProperties properties)
DescriptorValidator
validate
in interface DescriptorValidator
public static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> getRowtimeComponents(DescriptorProperties properties, String prefix)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.