|
Rename Method private generateLateTimestamp() : long renamed to private generateArbitraryInSessionTimestamp() : long in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Rename Method private createTestStream() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> renamed to private createGenerator() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Rename Method public getStreamConfiguration() : StreamConfiguration renamed to public getGeneratorConfiguration() : GeneratorConfiguration in class org.apache.flink.test.windowing.sessionwindows.SessionGeneratorConfiguration |
From |
To |
|
Rename Method public canProduceEventAtWatermark(globalWatermark long) : boolean renamed to public canGenerateEventAtWatermark(globalWatermark long) : boolean in class org.apache.flink.test.windowing.sessionwindows.EventGenerator |
From |
To |
|
Rename Method public canProduceEventAtWatermark(globalWatermark long) : boolean renamed to public canGenerateEventAtWatermark(globalWatermark long) : boolean in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl.InLatenessGenerator |
From |
To |
|
Rename Method public newSessionStreamForKey(key K, globalWatermark long) : EventGenerator<K,E> renamed to public newSessionGeneratorForKey(key K, globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Rename Method public canProduceEventAtWatermark(globalWatermark long) : boolean renamed to public canGenerateEventAtWatermark(globalWatermark long) : boolean in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl.TimelyGenerator |
From |
To |
|
Rename Method public canProduceEventAtWatermark(globalWatermark long) : boolean renamed to public canGenerateEventAtWatermark(globalWatermark long) : boolean in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl.AfterLatenessGenerator |
From |
To |
|
Rename Method public canProduceEventAtWatermark(globalWatermark long) : boolean renamed to public canGenerateEventAtWatermark(globalWatermark long) : boolean in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Rename Method private generateTimelyTimestamp() : long renamed to private generateTimelyInSessionTimestamp() : long in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Parameter Type eventFactory : StreamEventFactory<K,E> to eventFactory : GeneratorEventFactory<K,E> in method public SessionConfiguration(key K, sessionId int, gap long, minEventTimestamp long, numberOfTimelyEvents int, eventFactory GeneratorEventFactory<K,E>) in class org.apache.flink.test.windowing.sessionwindows.SessionConfiguration |
From |
To |
|
Change Parameter Type eventFactory : StreamEventFactory<K,E> to eventFactory : GeneratorEventFactory<K,E> in method public EventGeneratorFactory(generatorConfiguration GeneratorConfiguration, eventFactory GeneratorEventFactory<K,E>, sessionTimeout long, timelyEventsPerSession int, randomGenerator LongRandomGenerator) in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Change Parameter Type eventFactory : StreamEventFactory<K,E> to eventFactory : GeneratorEventFactory<K,E> in method public of(key K, sessionId int, timeout long, startTimestamp long, numberOfEvents int, eventFactory GeneratorEventFactory<K,E>) : SessionConfiguration<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionConfiguration |
From |
To |
|
Change Parameter Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public EventGeneratorFactory(generatorConfiguration GeneratorConfiguration, eventFactory GeneratorEventFactory<K,E>, sessionTimeout long, timelyEventsPerSession int, randomGenerator LongRandomGenerator) in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Change Parameter Type configuration : SessionStreamConfiguration<K,E> to configuration : SessionGeneratorConfiguration<K,E> in method public SessionEventGeneratorImpl(configuration SessionGeneratorConfiguration<K,E>, randomGenerator LongRandomGenerator) in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Parameter Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public SessionGeneratorConfiguration(sessionConfiguration SessionConfiguration<K,E>, generatorConfiguration GeneratorConfiguration) in class org.apache.flink.test.windowing.sessionwindows.SessionGeneratorConfiguration |
From |
To |
|
Rename Variable sessionStreamConfiguration : SessionStreamConfiguration<K,E> to sessionGeneratorConfiguration : SessionGeneratorConfiguration<K,E> in method public getNextGenerator(globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Rename Variable stream : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> to generator : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in method public run(ctx SourceContext<SessionEvent<Integer,TestEventPayload>>) : void in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Rename Variable sessionEventStream : EventGenerator<K,E> to eventGenerator : EventGenerator<K,E> in method public getWatermark() : long in class org.apache.flink.test.windowing.sessionwindows.ParallelSessionsEventGenerator |
From |
To |
|
Rename Variable streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public getNextGenerator(globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Rename Variable sessionStreamConfiguration : SessionStreamConfiguration<K,E> to sessionGeneratorConfiguration : SessionGeneratorConfiguration<K,E> in method public newSessionGeneratorForKey(key K, globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Rename Variable streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method private createGenerator() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Rename Variable streamEventFactory : StreamEventFactory<Integer,SessionEvent<Integer,TestEventPayload>> to generatorEventFactory : GeneratorEventFactory<Integer,SessionEvent<Integer,TestEventPayload>> in method private createGenerator() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Change Return Type StreamEventFactory<K,E> to GeneratorEventFactory<K,E> in method private getEventFactory() : GeneratorEventFactory<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Return Type StreamEventFactory<K,E> to GeneratorEventFactory<K,E> in method public getEventFactory() : GeneratorEventFactory<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionConfiguration |
From |
To |
|
Change Return Type StreamConfiguration to GeneratorConfiguration in method public of(allowedLateness long, lateEventsPerSessionWithinLateness int, lateEventsPerSessionOutsideLateness int, maxAdditionalSessionGap long) : GeneratorConfiguration in class org.apache.flink.test.windowing.sessionwindows.GeneratorConfiguration |
From |
To |
|
Change Return Type StreamConfiguration to GeneratorConfiguration in method public getGeneratorConfiguration() : GeneratorConfiguration in class org.apache.flink.test.windowing.sessionwindows.SessionGeneratorConfiguration |
From |
To |
|
Change Variable Type sessionStreamConfiguration : SessionStreamConfiguration<K,E> to sessionGeneratorConfiguration : SessionGeneratorConfiguration<K,E> in method public getNextGenerator(globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Variable Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public getNextGenerator(globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Variable Type sessionStreamConfiguration : SessionStreamConfiguration<K,E> to sessionGeneratorConfiguration : SessionGeneratorConfiguration<K,E> in method public newSessionGeneratorForKey(key K, globalWatermark long) : EventGenerator<K,E> in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Change Variable Type streamEventFactory : StreamEventFactory<Integer,SessionEvent<Integer,TestEventPayload>> to generatorEventFactory : GeneratorEventFactory<Integer,SessionEvent<Integer,TestEventPayload>> in method private createGenerator() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Change Variable Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method private createGenerator() : ParallelSessionsEventGenerator<Integer,SessionEvent<Integer,TestEventPayload>> in class org.apache.flink.test.windowing.sessionwindows.SessionWindowITCase.SessionEventGeneratorDataSource |
From |
To |
|
Change Attribute Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Change Attribute Type configuration : SessionStreamConfiguration<K,E> to configuration : SessionGeneratorConfiguration<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionEventGeneratorImpl |
From |
To |
|
Change Attribute Type eventFactory : StreamEventFactory<K,E> to eventFactory : GeneratorEventFactory<K,E> in class org.apache.flink.test.windowing.sessionwindows.SessionConfiguration |
From |
To |
|
Change Attribute Type eventFactory : StreamEventFactory<K,E> to eventFactory : GeneratorEventFactory<K,E> in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Change Attribute Type streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in class org.apache.flink.test.windowing.sessionwindows.SessionGeneratorConfiguration |
From |
To |
|
Rename Parameter streamFactory : EventGeneratorFactory<K,E> to generatorFactory : EventGeneratorFactory<K,E> in method public ParallelSessionsEventGenerator(keys Set<K>, generatorFactory EventGeneratorFactory<K,E>, parallelSessions int, sessionCountLimit long, randomGenerator LongRandomGenerator) in class org.apache.flink.test.windowing.sessionwindows.ParallelSessionsEventGenerator |
From |
To |
|
Rename Parameter streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public EventGeneratorFactory(generatorConfiguration GeneratorConfiguration, eventFactory GeneratorEventFactory<K,E>, sessionTimeout long, timelyEventsPerSession int, randomGenerator LongRandomGenerator) in class org.apache.flink.test.windowing.sessionwindows.EventGeneratorFactory |
From |
To |
|
Rename Parameter streamConfiguration : StreamConfiguration to generatorConfiguration : GeneratorConfiguration in method public SessionGeneratorConfiguration(sessionConfiguration SessionConfiguration<K,E>, generatorConfiguration GeneratorConfiguration) in class org.apache.flink.test.windowing.sessionwindows.SessionGeneratorConfiguration |
From |
To |