SourceAbilitySpecBase (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpecBase

All Implemented Interfaces:

SourceAbilitySpec

Direct Known Subclasses:

AggregatePushDownSpec, FilterPushDownSpec, LimitPushDownSpec, PartitionPushDownSpec, ProjectPushDownSpec, ReadingMetadataSpec, SourceWatermarkSpec, WatermarkPushDownSpec
```
public abstract class SourceAbilitySpecBase
extends Object
implements SourceAbilitySpec
```
Base class for SourceAbilitySpec.

Field Summary

Fields
Modifier and Type Field Description

static String FIELD_NAME_PRODUCED_TYPE

Constructor Summary

Constructors
Constructor Description

SourceAbilitySpecBase()

SourceAbilitySpecBase(RowType producedType)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`
`Optional<RowType>`	`getProducedType()`	Return the produced `RowType` this the ability is applied.
`int`	`hashCode()`

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

Methods inherited from interface org.apache.flink.table.planner.plan.abilities.source.SourceAbilitySpec
apply, getDigests, needAdjustFieldReferenceAfterProjection

- Field Detail
  - FIELD_NAME_PRODUCED_TYPE
```
public static final String FIELD_NAME_PRODUCED_TYPE
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - SourceAbilitySpecBase
```
public SourceAbilitySpecBase()
```
  - SourceAbilitySpecBase
```
public SourceAbilitySpecBase(@Nullable
                             RowType producedType)
```
- Method Detail
  - getProducedType
```
public Optional<RowType> getProducedType()
```
    Description copied from interface: SourceAbilitySpec
    
    Return the produced RowType this the ability is applied.
    NOTE: If the ability does not change the produced type, this method will return Optional.empty().
    
    Specified by:
    
    getProducedType in interface SourceAbilitySpec
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object