|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method package newOperator(type FlinkJoinType, leftIsSmaller boolean) : StreamOperator in class org.apache.flink.table.runtime.join.Int2SortMergeJoinOperatorTest |
From |
To |
|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method package newOperator(type FlinkJoinType, leftIsSmaller boolean) : StreamOperator in class org.apache.flink.table.runtime.join.String2SortMergeJoinOperatorTest |
From |
To |
|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method public SortMergeJoinOperator(reservedSortMemory long, externalBufferMemory long, type FlinkJoinType, leftIsSmaller boolean, condFuncCode GeneratedJoinCondition, projectionCode1 GeneratedProjection, projectionCode2 GeneratedProjection, computer1 GeneratedNormalizedKeyComputer, comparator1 GeneratedRecordComparator, computer2 GeneratedNormalizedKeyComputer, comparator2 GeneratedRecordComparator, genKeyComparator GeneratedRecordComparator, filterNulls boolean[]) in class org.apache.flink.table.runtime.join.SortMergeJoinOperator |
From |
To |
|
Change Parameter Type outerJoinType : SortMergeJoinType to outerJoinType : FlinkJoinType in method protected testOuterJoinWithHighNumberOfCommonKeys(outerJoinType FlinkJoinType, input1Size int, input1Duplicates int, input1ValueLength int, input1KeyDensity float, input2Size int, input2Duplicates int, input2ValueLength int, input2KeyDensity float) : void in class org.apache.flink.table.runtime.join.RandomSortMergeOuterJoinTest |
From |
To |
|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method public SortMergeJoinOperator(reservedSortMemory1 long, reservedSortMemory2 long, externalBufferMemory long, type FlinkJoinType, leftIsSmaller boolean, condFuncCode GeneratedJoinCondition, projectionCode1 GeneratedProjection, projectionCode2 GeneratedProjection, computer1 GeneratedNormalizedKeyComputer, comparator1 GeneratedRecordComparator, computer2 GeneratedNormalizedKeyComputer, comparator2 GeneratedRecordComparator, genKeyComparator GeneratedRecordComparator, filterNulls boolean[]) in class org.apache.flink.table.runtime.join.SortMergeJoinOperator |
From |
To |
|
Change Parameter Type outerJoinType : SortMergeJoinType to outerJoinType : FlinkJoinType in method protected getOperator(outerJoinType FlinkJoinType) : StreamOperator in class org.apache.flink.table.runtime.join.RandomSortMergeOuterJoinTest |
From |
To |
|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method private getOperator(type FlinkJoinType) : StreamOperator in class org.apache.flink.table.runtime.join.Int2SortMergeJoinOperatorTest |
From |
To |
|
Change Parameter Type type : SortMergeJoinType to type : FlinkJoinType in method private buildJoin(input1 MutableObjectIterator<BinaryRow>, input2 MutableObjectIterator<BinaryRow>, type FlinkJoinType, expertOutSize int, expertOutKeySize int, expertOutVal int) : void in class org.apache.flink.table.runtime.join.Int2SortMergeJoinOperatorTest |
From |
To |
|
Change Parameter Type outerJoinType : SortMergeJoinType to outerJoinType : FlinkJoinType in method private joinValues(leftMap Map<Integer,Collection<String>>, rightMap Map<Integer,Collection<String>>, outerJoinType FlinkJoinType) : Map<Integer,Collection<Match>> in class org.apache.flink.table.runtime.join.RandomSortMergeOuterJoinTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testOnlySortOnRowTime() : void in class org.apache.flink.table.runtime.sort.RowTimeSortOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testOutputRankNumberWithVariableRankRange() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testTumblingCountWindow() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testOutputRankNumberWithConstantRankRange() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testEventTimeTumblingWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testSortKeyChangesWhenOutputRankNumberAndNotGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testConstantRankRangeWithoutOffset() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public test() : void in class org.apache.flink.table.runtime.sort.ProcTimeSortOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testProcessingTimeSessionWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testSortKeyChangesWhenOutputRankNumber() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testEventTimeTumblingWindowsWithEarlyAndLateFirings() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testVariableRankRange() : void in class org.apache.flink.table.runtime.rank.RetractableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testSortKeyChangesWhenNotOutputRankNumber() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testEventTimeSlidingWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testEventTimeTumblingWindowsWithEarlyFiring() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testWithGenerateRetraction() : void in class org.apache.flink.table.runtime.deduplicate.DeduplicateKeepLastRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testProcessRetractMessageWithNotGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.RetractableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testVariableRankRange() : void in class org.apache.flink.table.runtime.rank.AppendOnlyTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public test() : void in class org.apache.flink.table.runtime.deduplicate.DeduplicateKeepFirstRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testPointSessions() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testWithoutGenerateRetraction() : void in class org.apache.flink.table.runtime.deduplicate.DeduplicateKeepLastRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testProcessingTimeTumblingWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testKeepFirstRowWithGenerateRetraction() : void in class org.apache.flink.table.runtime.deduplicate.MiniBatchDeduplicateKeepFirstRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testDisableGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.RetractableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testProcessingTimeSlidingWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testSortKeyChangesWhenNotOutputRankNumberAndNotGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public test() : void in class org.apache.flink.table.runtime.sort.StreamSortOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testWithoutGenerateRetraction() : void in class org.apache.flink.table.runtime.deduplicate.MiniBatchDeduplicateKeepLastRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testWithGenerateRetraction() : void in class org.apache.flink.table.runtime.deduplicate.MiniBatchDeduplicateKeepLastRowFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testSlidingCountWindow() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testDisableGenerateRetractionAndOutputRankNumber() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testOutputRankNumberWithVariableRankRange() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testConstantRankRangeWithoutOffset() : void in class org.apache.flink.table.runtime.rank.RetractableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testConstantRankRangeWithOffset() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testVariableRankRange() : void in class org.apache.flink.table.runtime.rank.UpdatableTopNFunctionTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testDisableGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.TopNFunctionTestBase |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testSortOnTwoFields() : void in class org.apache.flink.table.runtime.sort.RowTimeSortOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : ConcurrentLinkedQueue<Object> to expectedOutput : ConcurrentLinkedQueue<Object> in method public testEventTimeSessionWindows() : void in class org.apache.flink.table.runtime.window.WindowOperatorTest |
From |
To |
|
Rename Variable expectedOutputOutput : List<Object> to expectedOutput : List<Object> in method public testProcessRetractMessageWithGenerateRetraction() : void in class org.apache.flink.table.runtime.rank.RetractableTopNFunctionTest |
From |
To |