Class KafkaTopicSource.CardinalityEstimator
java.lang.Object
org.apache.wayang.basic.operators.KafkaTopicSource.CardinalityEstimator
- All Implemented Interfaces:
Serializable
,CardinalityEstimator
- Enclosing class:
- KafkaTopicSource
protected class KafkaTopicSource.CardinalityEstimator
extends Object
implements CardinalityEstimator
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final double
static final double
final CardinalityEstimate
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionestimate
(OptimizationContext optimizationContext, CardinalityEstimate... inputEstimates)
-
Field Details
-
FALLBACK_ESTIMATE
-
CORRECTNESS_PROBABILITY
public static final double CORRECTNESS_PROBABILITY- See Also:
-
EXPECTED_ESTIMATE_DEVIATION
public static final double EXPECTED_ESTIMATE_DEVIATION- See Also:
-
-
Constructor Details
-
CardinalityEstimator
protected CardinalityEstimator()
-
-
Method Details
-
estimate
public CardinalityEstimate estimate(OptimizationContext optimizationContext, CardinalityEstimate... inputEstimates) - Specified by:
estimate
in interfaceCardinalityEstimator
-