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(
228228 this .stateful = stateful ;
229229 }
230230
231- static PrecomputedParameters precompute (
231+ public static PrecomputedParameters precompute (
232232 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 ) {
233240 Preconditions .checkNotNull (fieldSerializers );
234241 int totalLength = 0 ;
235242 boolean fieldsImmutable = true ;
@@ -239,7 +246,7 @@ static PrecomputedParameters precompute(
239246 if (fieldSerializer != fieldSerializer .duplicate ()) {
240247 stateful = true ;
241248 }
242- if (!fieldSerializer .isImmutableType ()) {
249+ if (!forceFieldsImmutable && ! fieldSerializer .isImmutableType ()) {
243250 fieldsImmutable = false ;
244251 }
245252 if (fieldSerializer .getLength () < 0 ) {
You can’t perform that action at this time.
0 commit comments