File tree Expand file tree Collapse file tree 1 file changed +9
-2
lines changed
flink-core/src/main/java/org/apache/flink/api/common/typeutils Expand file tree Collapse file tree 1 file changed +9
-2
lines changed Original file line number Diff line number Diff line change @@ -228,8 +228,15 @@ private PrecomputedParameters(
228
228
this .stateful = stateful ;
229
229
}
230
230
231
- static PrecomputedParameters precompute (
231
+ public static PrecomputedParameters precompute (
232
232
boolean immutableTargetType , TypeSerializer <Object >[] fieldSerializers ) {
233
+ return precompute (immutableTargetType , false , fieldSerializers );
234
+ }
235
+
236
+ public static PrecomputedParameters precompute (
237
+ boolean immutableTargetType ,
238
+ boolean forceFieldsImmutable ,
239
+ TypeSerializer <Object >[] fieldSerializers ) {
233
240
Preconditions .checkNotNull (fieldSerializers );
234
241
int totalLength = 0 ;
235
242
boolean fieldsImmutable = true ;
@@ -239,7 +246,7 @@ static PrecomputedParameters precompute(
239
246
if (fieldSerializer != fieldSerializer .duplicate ()) {
240
247
stateful = true ;
241
248
}
242
- if (!fieldSerializer .isImmutableType ()) {
249
+ if (!forceFieldsImmutable && ! fieldSerializer .isImmutableType ()) {
243
250
fieldsImmutable = false ;
244
251
}
245
252
if (fieldSerializer .getLength () < 0 ) {
You can’t perform that action at this time.
0 commit comments