|
Change Parameter Type evictionPolicy : EvictionPolicy<I,?> to evictionPolicy : EvictionPolicy<Record<I>,?> in method private getTriggerPolicy(windowConfig WindowConfig, manager WindowManager<Record<I>>, evictionPolicy EvictionPolicy<Record<I>,?>, context Context) : TriggerPolicy<Record<I>,?> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Parameter Type tuples : List<I> to tuples : List<Record<I>> in method private processWindow(context Context, tuples List<Record<I>>, newTuples List<Record<I>>, expiredTuples List<Record<I>>, referenceTime Long) : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Parameter Type newTuples : List<I> to newTuples : List<Record<I>> in method private processWindow(context Context, tuples List<Record<I>>, newTuples List<Record<I>>, expiredTuples List<Record<I>>, referenceTime Long) : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Parameter Type manager : WindowManager<I> to manager : WindowManager<Record<I>> in method private getTriggerPolicy(windowConfig WindowConfig, manager WindowManager<Record<I>>, evictionPolicy EvictionPolicy<Record<I>,?>, context Context) : TriggerPolicy<Record<I>,?> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Parameter Type expiredTuples : List<I> to expiredTuples : List<Record<I>> in method private processWindow(context Context, tuples List<Record<I>>, newTuples List<Record<I>>, expiredTuples List<Record<I>>, referenceTime Long) : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Parameter Type inputWindow : Window<Long> to inputWindow : Window<Record<Long>> in method public process(inputWindow Window<Record<Long>>, context WindowContext) : Long in class org.apache.pulsar.functions.windowing.WindowFunctionExecutorTest.TestWindowFunctionExecutor |
From |
To |
|
Change Return Type EvictionPolicy<I,?> to EvictionPolicy<Record<I>,?> in method private getEvictionPolicy(windowConfig WindowConfig) : EvictionPolicy<Record<I>,?> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Return Type Function<Collection<I>,O> to void in method private initializeUserFunction(windowConfig WindowConfig) : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Return Type TriggerPolicy<I,?> to TriggerPolicy<Record<I>,?> in method private getTriggerPolicy(windowConfig WindowConfig, manager WindowManager<Record<I>>, evictionPolicy EvictionPolicy<Record<I>,?>, context Context) : TriggerPolicy<Record<I>,?> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Return Type WindowManager<I> to WindowManager<Record<I>> in method private getWindowManager(windowConfig WindowConfig, context Context) : WindowManager<Record<I>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Return Type WindowLifecycleListener<Event<I>> to WindowLifecycleListener<Event<Record<I>>> in method protected newWindowLifecycleListener(context Context) : WindowLifecycleListener<Event<Record<I>>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Variable Type third : Window<Long> to third : Window<Record<Long>> in method public testExecuteWithTs() : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutorTest |
From |
To |
|
Change Variable Type first : Window<Long> to first : Window<Record<Long>> in method public testExecuteWithTs() : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutorTest |
From |
To |
|
Change Variable Type evictionPolicy : EvictionPolicy<I,?> to evictionPolicy : EvictionPolicy<Record<I>,?> in method private getWindowManager(windowConfig WindowConfig, context Context) : WindowManager<Record<I>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Variable Type lifecycleListener : WindowLifecycleListener<Event<I>> to lifecycleListener : WindowLifecycleListener<Event<Record<I>>> in method private getWindowManager(windowConfig WindowConfig, context Context) : WindowManager<Record<I>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Variable Type record : Record<?> to record : Record<I> in method public process(input I, context Context) : O in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Variable Type event : Event<I> to event : Event<Record<I>> in method public onExpiry(events List<Event<Record<I>>>) : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor.newWindowLifecycleListener |
From |
To |
|
Change Variable Type manager : WindowManager<I> to manager : WindowManager<Record<I>> in method private getWindowManager(windowConfig WindowConfig, context Context) : WindowManager<Record<I>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |
|
Change Variable Type second : Window<Long> to second : Window<Record<Long>> in method public testExecuteWithTs() : void in class org.apache.pulsar.functions.windowing.WindowFunctionExecutorTest |
From |
To |
|
Change Variable Type triggerPolicy : TriggerPolicy<I,?> to triggerPolicy : TriggerPolicy<Record<I>,?> in method private getWindowManager(windowConfig WindowConfig, context Context) : WindowManager<Record<I>> in class org.apache.pulsar.functions.windowing.WindowFunctionExecutor |
From |
To |