davidradl commented on code in PR #26632:
URL: https://github.com/apache/flink/pull/26632#discussion_r2127045679
##########
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"
+ + "FORCE: Enforce to use delta join. If
failed, an exception will be thrown.\n"
Review Comment:
nit:
Enforce to use delta join. If failed, an exception will be thrown
->
Use the delta join. If this fails, an exception will be thrown
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
