Skip to content

Commit

Permalink
[FLINK-36499][table-common] Remove deprecated method `SupportsProject…
Browse files Browse the repository at this point in the history
…ionPushDown#applyProjection` (#25967)

Co-authored-by: RanJinh <[email protected]>
  • Loading branch information
xishuaidelin and RanJinh authored Jan 15, 2025
1 parent cbdf9ac commit 5e87e8a
Showing 1 changed file with 1 addition and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,16 +57,6 @@ public interface SupportsProjectionPushDown {
/** Returns whether this source supports nested projection. */
boolean supportsNestedProjection();

/**
* @deprecated Please implement {@link #applyProjection(int[][], DataType)}
*/
@Deprecated
default void applyProjection(int[][] projectedFields) {
throw new UnsupportedOperationException(
"No implementation provided for SupportsProjectionPushDown. "
+ "Please implement SupportsProjectionPushDown#applyProjection(int[][], DataType)");
}

/**
* Provides the field index paths that should be used for a projection. The indices are 0-based
* and support fields within (possibly nested) structures if this is enabled via {@link
Expand All @@ -88,7 +78,5 @@ default void applyProjection(int[][] projectedFields) {
* produced data
* @param producedDataType the final output type of the source, with the projection applied
*/
default void applyProjection(int[][] projectedFields, DataType producedDataType) {
applyProjection(projectedFields);
}
void applyProjection(int[][] projectedFields, DataType producedDataType);
}

0 comments on commit 5e87e8a

Please sign in to comment.