Skip to content

Commit 5274c1f

Browse files
gnodetclaude
andcommitted
CAMEL-23264: Address review feedback - remove upgrade guide, add @SInCE tags, regenerate
- Remove Split EIP section from upgrade guide (davsclaus: new features don't belong in the upgrade guide, only migration info) - Add @SInCE 4.21 to SplitResult class and Failure record (oscerd) - Regenerate all downstream artifacts after rebase onto latest main Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 2d22bdc commit 5274c1f

9 files changed

Lines changed: 1799 additions & 1654 deletions

File tree

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/split.json

Lines changed: 25 additions & 24 deletions
Large diffs are not rendered by default.

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13280,7 +13280,12 @@ of one at a time.
1328013280
<xs:annotation>
1328113281
<xs:documentation xml:lang="en">
1328213282
<![CDATA[
13283-
Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting the split operation.
13283+
Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting the split operation. For example, 0.1
13284+
means abort if more than 10% of items fail. When the threshold is exceeded, a org.apache.camel.CamelExchangeException is
13285+
thrown. This option is mutually exclusive with stopOnException . When set, individual item failures are tracked but
13286+
processing continues until the threshold is exceeded. Note: When combined with parallelProcessing , the failure ratio
13287+
may vary between runs because parallel items complete in non-deterministic order. For deterministic abort behavior with
13288+
parallel processing, prefer maxFailedRecords (absolute count) over errorThreshold (ratio).
1328413289
]]>
1328513290
</xs:documentation>
1328613291
</xs:annotation>
@@ -13289,7 +13294,9 @@ Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting
1328913294
<xs:annotation>
1329013295
<xs:documentation xml:lang="en">
1329113296
<![CDATA[
13292-
Sets the maximum number of failed records before aborting the split operation.
13297+
Sets the maximum number of failed records before aborting the split operation. When the count is exceeded, a
13298+
org.apache.camel.CamelExchangeException is thrown. This option is mutually exclusive with stopOnException . Can be
13299+
combined with errorThreshold processing aborts when either threshold is exceeded.
1329313300
]]>
1329413301
</xs:documentation>
1329513302
</xs:annotation>
@@ -13298,7 +13305,8 @@ Sets the maximum number of failed records before aborting the split operation.
1329813305
<xs:annotation>
1329913306
<xs:documentation xml:lang="en">
1330013307
<![CDATA[
13301-
Sets a reference to a ResumeStrategy in the registry for resume-from-last-position support.
13308+
Sets a ResumeStrategy for resume-from-last-position support. The watermark key must also be configured via
13309+
watermarkKey(String) .
1330213310
]]>
1330313311
</xs:documentation>
1330413312
</xs:annotation>
@@ -13316,7 +13324,8 @@ Sets the key to use in the watermark store.
1331613324
<xs:annotation>
1331713325
<xs:documentation xml:lang="en">
1331813326
<![CDATA[
13319-
Sets a Simple expression to evaluate on the exchange after split completion to determine the new watermark value.
13327+
Sets a Simple expression to evaluate on each completed sub-exchange to determine the new watermark value. When set,
13328+
enables value-based watermarking instead of index-based. The expression is evaluated using the Simple language.
1332013329
]]>
1332113330
</xs:documentation>
1332213331
</xs:annotation>

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-xml-io.xsd

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12423,7 +12423,12 @@ of one at a time.
1242312423
<xs:annotation>
1242412424
<xs:documentation xml:lang="en">
1242512425
<![CDATA[
12426-
Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting the split operation.
12426+
Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting the split operation. For example, 0.1
12427+
means abort if more than 10% of items fail. When the threshold is exceeded, a org.apache.camel.CamelExchangeException is
12428+
thrown. This option is mutually exclusive with stopOnException . When set, individual item failures are tracked but
12429+
processing continues until the threshold is exceeded. Note: When combined with parallelProcessing , the failure ratio
12430+
may vary between runs because parallel items complete in non-deterministic order. For deterministic abort behavior with
12431+
parallel processing, prefer maxFailedRecords (absolute count) over errorThreshold (ratio).
1242712432
]]>
1242812433
</xs:documentation>
1242912434
</xs:annotation>
@@ -12432,7 +12437,9 @@ Sets the error threshold as a fraction (0.0-1.0) of failed items before aborting
1243212437
<xs:annotation>
1243312438
<xs:documentation xml:lang="en">
1243412439
<![CDATA[
12435-
Sets the maximum number of failed records before aborting the split operation.
12440+
Sets the maximum number of failed records before aborting the split operation. When the count is exceeded, a
12441+
org.apache.camel.CamelExchangeException is thrown. This option is mutually exclusive with stopOnException . Can be
12442+
combined with errorThreshold processing aborts when either threshold is exceeded.
1243612443
]]>
1243712444
</xs:documentation>
1243812445
</xs:annotation>
@@ -12441,7 +12448,8 @@ Sets the maximum number of failed records before aborting the split operation.
1244112448
<xs:annotation>
1244212449
<xs:documentation xml:lang="en">
1244312450
<![CDATA[
12444-
Sets a reference to a ResumeStrategy in the registry for resume-from-last-position support.
12451+
Sets a ResumeStrategy for resume-from-last-position support. The watermark key must also be configured via
12452+
watermarkKey(String) .
1244512453
]]>
1244612454
</xs:documentation>
1244712455
</xs:annotation>
@@ -12459,7 +12467,8 @@ Sets the key to use in the watermark store.
1245912467
<xs:annotation>
1246012468
<xs:documentation xml:lang="en">
1246112469
<![CDATA[
12462-
Sets a Simple expression to evaluate on the exchange after split completion to determine the new watermark value.
12470+
Sets a Simple expression to evaluate on each completed sub-exchange to determine the new watermark value. When set,
12471+
enables value-based watermarking instead of index-based. The expression is evaluated using the Simple language.
1246312472
]]>
1246412473
</xs:documentation>
1246512474
</xs:annotation>

core/camel-api/src/generated/java/org/apache/camel/ExchangeConstantProvider.java

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,14 @@
11
/* Generated by camel build tools - do NOT edit this file! */
22
package org.apache.camel;
33

4-
import javax.annotation.processing.Generated;
4+
import java.util.Collection;
55
import java.util.HashMap;
66
import java.util.Map;
77

8+
import javax.annotation.processing.Generated;
9+
10+
import org.jspecify.annotations.Nullable;
11+
812
/**
913
* Generated by camel build tools - do NOT edit this file!
1014
*/
@@ -13,7 +17,7 @@ public class ExchangeConstantProvider {
1317

1418
private static final Map<String, String> MAP;
1519
static {
16-
Map<String, String> map = new HashMap<>(151);
20+
Map<String, String> map = new HashMap<>(153);
1721
map.put("AGGREGATED_COLLECTION_GUARD", "CamelAggregatedCollectionGuard");
1822
map.put("AGGREGATED_COMPLETED_BY", "CamelAggregatedCompletedBy");
1923
map.put("AGGREGATED_CORRELATION_KEY", "CamelAggregatedCorrelationKey");
@@ -111,6 +115,8 @@ public class ExchangeConstantProvider {
111115
map.put("MAXIMUM_SIMPLE_CACHE_SIZE", "CamelMaximumSimpleCacheSize");
112116
map.put("MAXIMUM_TRANSFORMER_CACHE_SIZE", "CamelMaximumTransformerCacheSize");
113117
map.put("MAXIMUM_VALIDATOR_CACHE_SIZE", "CamelMaximumValidatorCacheSize");
118+
map.put("MESSAGE_BODY_SIZE", "CamelMessageBodySize");
119+
map.put("MESSAGE_HEADERS_SIZE", "CamelMessageHeadersSize");
114120
map.put("MESSAGE_HISTORY", "CamelMessageHistory");
115121
map.put("MESSAGE_HISTORY_HEADER_FORMAT", "CamelMessageHistoryHeaderFormat");
116122
map.put("MESSAGE_HISTORY_OUTPUT_FORMAT", "CamelMessageHistoryOutputFormat");
@@ -168,8 +174,12 @@ public class ExchangeConstantProvider {
168174
MAP = map;
169175
}
170176

171-
public static String lookup(String key) {
177+
public static @Nullable String lookup(String key) {
172178
return MAP.get(key);
173179
}
180+
181+
public static Collection<String> values() {
182+
return MAP.values();
183+
}
174184
}
175185

core/camel-api/src/main/java/org/apache/camel/SplitResult.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@
2424
* when error thresholds ({@code errorThreshold} or {@code maxFailedRecords}) are configured.
2525
* <p/>
2626
* This result is available as an exchange property ({@link Exchange#SPLIT_RESULT}) after the split operation completes.
27+
*
28+
* @since 4.21
2729
*/
2830
public final class SplitResult {
2931

@@ -32,6 +34,7 @@ public final class SplitResult {
3234
*
3335
* @param index the 0-based index of the failed item in the split sequence
3436
* @param exception the exception that caused the failure
37+
* @since 4.21
3538
*/
3639
public record Failure(int index, Exception exception) {
3740
}

0 commit comments

Comments
 (0)