Package org.apache.wayang.basic.operators

Class KafkaTopicSource.CardinalityEstimator

java.lang.Object

org.apache.wayang.basic.operators.KafkaTopicSource.CardinalityEstimator

All Implemented Interfaces:

java.io.Serializable, CardinalityEstimator

Enclosing class:

KafkaTopicSource

protected class KafkaTopicSource.CardinalityEstimator
extends java.lang.Object
implements CardinalityEstimator

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static double	CORRECTNESS_PROBABILITY
static double	EXPECTED_ESTIMATE_DEVIATION
CardinalityEstimate	FALLBACK_ESTIMATE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CardinalityEstimator()

Method Summary

Modifier and Type	Method	Description
CardinalityEstimate	estimate(OptimizationContext optimizationContext, CardinalityEstimate... inputEstimates)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FALLBACK_ESTIMATE

public final CardinalityEstimate FALLBACK_ESTIMATE

CORRECTNESS_PROBABILITY

public static final double CORRECTNESS_PROBABILITY

See Also:

Constant Field Values

EXPECTED_ESTIMATE_DEVIATION

public static final double EXPECTED_ESTIMATE_DEVIATION

See Also:

Constant Field Values

Constructor Detail

CardinalityEstimator

protected CardinalityEstimator()

Method Detail

estimate

public CardinalityEstimate estimate(OptimizationContext optimizationContext,
                                    CardinalityEstimate... inputEstimates)

Specified by:

estimate in interface CardinalityEstimator