davidradl commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2127044539
##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java:
##########
@@ -373,6 +373,25 @@ public class OptimizerConfigOptions {
+ "requires reserving network buffers,
which impacts memory usage. For this reason, "
+ "the number of input tables is limited
to 20.");
+ @Documentation.TableOption(execMode = Documentation.ExecMode.STREAMING)
+ public static final ConfigOption<DeltaJoinStrategy>
TABLE_OPTIMIZER_DELTA_JOIN_STRATEGY =
+ key("table.optimizer.delta-join.strategy")
+ .enumType(DeltaJoinStrategy.class)
+ .defaultValue(DeltaJoinStrategy.NONE)
+ .withDescription(
+ "Whether to enable delta join strategy. Only AUTO,
FORCE or NONE can be set.\n"
+ + "AUTO: Optimizer will try to use delta
join first. If failed, it will fallback to regular join.\n"
Review Comment:
nit:
If failed -> if it fails
to regular join -> to a regular join
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
