|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlAggregatingState(originalState InternalAggregatingState<K,N,IN,TtlValue<ACC>,OUT>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<ACC>, aggregateFunction TtlAggregateFunction<IN,ACC,OUT>) in class org.apache.flink.runtime.state.ttl.TtlAggregatingState |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package AbstractTtlState(original S, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<SV>) in class org.apache.flink.runtime.state.ttl.AbstractTtlState |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlListState(originalState InternalListState<K,N,TtlValue<T>>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<List<T>>) in class org.apache.flink.runtime.state.ttl.TtlListState |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlMapState(original InternalMapState<K,N,UK,TtlValue<UV>>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<Map<UK,UV>>) in class org.apache.flink.runtime.state.ttl.TtlMapState |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlReducingState(originalState InternalReducingState<K,N,TtlValue<T>>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<T>) in class org.apache.flink.runtime.state.ttl.TtlReducingState |
From |
To |
|
Change Parameter Type ttlConfig : TtlConfig to ttlConfig : StateTtlConfiguration in method private TtlStateFactory(originalStateFactory KeyedStateFactory, ttlConfig StateTtlConfiguration, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlStateFactory |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlReduceFunction(originalReduceFunction ReduceFunction<T>, config StateTtlConfiguration, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlReduceFunction |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlFoldingState(originalState InternalFoldingState<K,N,T,TtlValue<ACC>>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<ACC>) in class org.apache.flink.runtime.state.ttl.TtlFoldingState |
From |
To |
|
Change Parameter Type ttlConfig : TtlConfig to ttlConfig : StateTtlConfiguration in method public createStateAndWrapWithTtlIfEnabled(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<S,SV>, originalStateFactory KeyedStateFactory, ttlConfig StateTtlConfiguration, timeProvider TtlTimeProvider) : IS in class org.apache.flink.runtime.state.ttl.TtlStateFactory |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package AbstractTtlDecorator(original T, config StateTtlConfiguration, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.AbstractTtlDecorator |
From |
To |
|
Change Parameter Type updateType : TtlConfig.TtlUpdateType to updateType : StateTtlConfiguration.TtlUpdateType in method private initTest(updateType StateTtlConfiguration.TtlUpdateType, visibility StateTtlConfiguration.TtlStateVisibility) : void in class org.apache.flink.runtime.state.ttl.TtlStateTestBase |
From |
To |
|
Change Parameter Type visibility : TtlConfig.TtlStateVisibility to visibility : StateTtlConfiguration.TtlStateVisibility in method private initTest(updateType StateTtlConfiguration.TtlUpdateType, visibility StateTtlConfiguration.TtlStateVisibility) : void in class org.apache.flink.runtime.state.ttl.TtlStateTestBase |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlFoldFunction(original FoldFunction<T,ACC>, config StateTtlConfiguration, timeProvider TtlTimeProvider, defaultAccumulator ACC) in class org.apache.flink.runtime.state.ttl.TtlFoldFunction |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlAggregateFunction(aggFunction AggregateFunction<IN,ACC,OUT>, config StateTtlConfiguration, timeProvider TtlTimeProvider) in class org.apache.flink.runtime.state.ttl.TtlAggregateFunction |
From |
To |
|
Change Parameter Type config : TtlConfig to config : StateTtlConfiguration in method package TtlValueState(originalState InternalValueState<K,N,TtlValue<T>>, config StateTtlConfiguration, timeProvider TtlTimeProvider, valueSerializer TypeSerializer<T>) in class org.apache.flink.runtime.state.ttl.TtlValueState |
From |
To |