Skip to content

Commit ffe69f7

Browse files
godfreyhegodfreyhe
committed
fix checkstyle error
1 parent 9810d38 commit ffe69f7

File tree

6 files changed

+31
-32
lines changed

6 files changed

+31
-32
lines changed

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/expressions/ExpressionBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,10 @@
2525

2626
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.DIVIDE;
2727
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.EQUALS;
28-
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.LESS_THAN;
2928
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.GREATER_THAN;
3029
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.IF;
3130
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.IS_NULL;
31+
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.LESS_THAN;
3232
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.MINUS;
3333
import static org.apache.flink.table.expressions.BuiltInFunctionDefinitions.PLUS;
3434

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/functions/CountAggFunction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
import static org.apache.flink.table.expressions.ExpressionBuilder.plus;
3333

3434
/**
35-
* built-in count aggregate function
35+
* built-in count aggregate function.
3636
*/
3737
public class CountAggFunction extends DeclarativeAggregateFunction {
3838
private UnresolvedFieldReferenceExpression count = new UnresolvedFieldReferenceExpression("count");

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/functions/MaxAggFunction.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,9 @@
2626
import org.apache.flink.table.type.TypeConverters;
2727
import org.apache.flink.table.typeutils.DecimalTypeInfo;
2828

29+
import static org.apache.flink.table.expressions.ExpressionBuilder.greaterThan;
2930
import static org.apache.flink.table.expressions.ExpressionBuilder.ifThenElse;
3031
import static org.apache.flink.table.expressions.ExpressionBuilder.isNull;
31-
import static org.apache.flink.table.expressions.ExpressionBuilder.greaterThan;
3232
import static org.apache.flink.table.expressions.ExpressionBuilder.nullOf;
3333

3434
/**
@@ -90,7 +90,7 @@ public Expression getValueExpression() {
9090
}
9191

9292
/**
93-
* Built-in Int Max aggregate function
93+
* Built-in Int Max aggregate function.
9494
*/
9595
public static class IntMaxAggFunction extends MaxAggFunction {
9696

@@ -101,7 +101,7 @@ public TypeInformation getResultType() {
101101
}
102102

103103
/**
104-
* Built-in Byte Max aggregate function
104+
* Built-in Byte Max aggregate function.
105105
*/
106106
public static class ByteMaxAggFunction extends MaxAggFunction {
107107
@Override
@@ -111,7 +111,7 @@ public TypeInformation getResultType() {
111111
}
112112

113113
/**
114-
* Built-in Short Max aggregate function
114+
* Built-in Short Max aggregate function.
115115
*/
116116
public static class ShortMaxAggFunction extends MaxAggFunction {
117117
@Override
@@ -121,7 +121,7 @@ public TypeInformation getResultType() {
121121
}
122122

123123
/**
124-
* Built-in Long Max aggregate function
124+
* Built-in Long Max aggregate function.
125125
*/
126126
public static class LongMaxAggFunction extends MaxAggFunction {
127127
@Override
@@ -131,7 +131,7 @@ public TypeInformation getResultType() {
131131
}
132132

133133
/**
134-
* Built-in Float Max aggregate function
134+
* Built-in Float Max aggregate function.
135135
*/
136136
public static class FloatMaxAggFunction extends MaxAggFunction {
137137
@Override
@@ -141,7 +141,7 @@ public TypeInformation getResultType() {
141141
}
142142

143143
/**
144-
* Built-in Double Max aggregate function
144+
* Built-in Double Max aggregate function.
145145
*/
146146
public static class DoubleMaxAggFunction extends MaxAggFunction {
147147
@Override
@@ -151,7 +151,7 @@ public TypeInformation getResultType() {
151151
}
152152

153153
/**
154-
* Built-in Decimal Max aggregate function
154+
* Built-in Decimal Max aggregate function.
155155
*/
156156
public static class DecimalMaxAggFunction extends MaxAggFunction {
157157
private DecimalTypeInfo decimalType;

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/functions/MinAggFunction.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public Expression getValueExpression() {
9090
}
9191

9292
/**
93-
* Built-in Int Min aggregate function
93+
* Built-in Int Min aggregate function.
9494
*/
9595
public static class IntMinAggFunction extends MinAggFunction {
9696

@@ -101,7 +101,7 @@ public TypeInformation getResultType() {
101101
}
102102

103103
/**
104-
* Built-in Byte Min aggregate function
104+
* Built-in Byte Min aggregate function.
105105
*/
106106
public static class ByteMinAggFunction extends MinAggFunction {
107107
@Override
@@ -111,7 +111,7 @@ public TypeInformation getResultType() {
111111
}
112112

113113
/**
114-
* Built-in Short Min aggregate function
114+
* Built-in Short Min aggregate function.
115115
*/
116116
public static class ShortMinAggFunction extends MinAggFunction {
117117
@Override
@@ -121,7 +121,7 @@ public TypeInformation getResultType() {
121121
}
122122

123123
/**
124-
* Built-in Long Min aggregate function
124+
* Built-in Long Min aggregate function.
125125
*/
126126
public static class LongMinAggFunction extends MinAggFunction {
127127
@Override
@@ -131,7 +131,7 @@ public TypeInformation getResultType() {
131131
}
132132

133133
/**
134-
* Built-in Float Min aggregate function
134+
* Built-in Float Min aggregate function.
135135
*/
136136
public static class FloatMinAggFunction extends MinAggFunction {
137137
@Override
@@ -141,7 +141,7 @@ public TypeInformation getResultType() {
141141
}
142142

143143
/**
144-
* Built-in Double Min aggregate function
144+
* Built-in Double Min aggregate function.
145145
*/
146146
public static class DoubleMinAggFunction extends MinAggFunction {
147147
@Override
@@ -151,7 +151,7 @@ public TypeInformation getResultType() {
151151
}
152152

153153
/**
154-
* Built-in Decimal Min aggregate function
154+
* Built-in Decimal Min aggregate function.
155155
*/
156156
public static class DecimalMinAggFunction extends MinAggFunction {
157157
private DecimalTypeInfo decimalType;

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/functions/Sum0AggFunction.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public Expression getValueExpression() {
9090
}
9191

9292
/**
93-
* Built-in Int Sum0 aggregate function
93+
* Built-in Int Sum0 aggregate function.
9494
*/
9595
public static class IntSum0AggFunction extends Sum0AggFunction {
9696

@@ -101,7 +101,7 @@ public TypeInformation getResultType() {
101101
}
102102

103103
/**
104-
* Built-in Byte Sum0 aggregate function
104+
* Built-in Byte Sum0 aggregate function.
105105
*/
106106
public static class ByteSum0AggFunction extends Sum0AggFunction {
107107
@Override
@@ -111,7 +111,7 @@ public TypeInformation getResultType() {
111111
}
112112

113113
/**
114-
* Built-in Short Sum0 aggregate function
114+
* Built-in Short Sum0 aggregate function.
115115
*/
116116
public static class ShortSum0AggFunction extends Sum0AggFunction {
117117
@Override
@@ -121,7 +121,7 @@ public TypeInformation getResultType() {
121121
}
122122

123123
/**
124-
* Built-in Long Sum0 aggregate function
124+
* Built-in Long Sum0 aggregate function.
125125
*/
126126
public static class LongSum0AggFunction extends Sum0AggFunction {
127127
@Override
@@ -131,7 +131,7 @@ public TypeInformation getResultType() {
131131
}
132132

133133
/**
134-
* Built-in Float Sum0 aggregate function
134+
* Built-in Float Sum0 aggregate function.
135135
*/
136136
public static class FloatSum0AggFunction extends Sum0AggFunction {
137137
@Override
@@ -148,7 +148,7 @@ public Expression[] initialValuesExpressions() {
148148
}
149149

150150
/**
151-
* Built-in Double Sum0 aggregate function
151+
* Built-in Double Sum0 aggregate function.
152152
*/
153153
public static class DoubleSum0AggFunction extends Sum0AggFunction {
154154
@Override
@@ -165,7 +165,7 @@ public Expression[] initialValuesExpressions() {
165165
}
166166

167167
/**
168-
* Built-in Decimal Sum0 aggregate function
168+
* Built-in Decimal Sum0 aggregate function.
169169
*/
170170
public static class DecimalSum0AggFunction extends Sum0AggFunction {
171171
private DecimalTypeInfo decimalType;

‎flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/functions/SumAggFunction.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.apache.flink.table.expressions.UnresolvedFieldReferenceExpression;
2525
import org.apache.flink.table.type.DecimalType;
2626
import org.apache.flink.table.type.InternalType;
27-
import org.apache.flink.table.type.InternalTypes;
2827
import org.apache.flink.table.type.TypeConverters;
2928
import org.apache.flink.table.typeutils.DecimalTypeInfo;
3029

@@ -95,7 +94,7 @@ public Expression getValueExpression() {
9594
}
9695

9796
/**
98-
* Built-in Int Sum aggregate function
97+
* Built-in Int Sum aggregate function.
9998
*/
10099
public static class IntSumAggFunction extends SumAggFunction {
101100

@@ -106,7 +105,7 @@ public TypeInformation getResultType() {
106105
}
107106

108107
/**
109-
* Built-in Byte Sum aggregate function
108+
* Built-in Byte Sum aggregate function.
110109
*/
111110
public static class ByteSumAggFunction extends SumAggFunction {
112111
@Override
@@ -116,7 +115,7 @@ public TypeInformation getResultType() {
116115
}
117116

118117
/**
119-
* Built-in Short Sum aggregate function
118+
* Built-in Short Sum aggregate function.
120119
*/
121120
public static class ShortSumAggFunction extends SumAggFunction {
122121
@Override
@@ -126,7 +125,7 @@ public TypeInformation getResultType() {
126125
}
127126

128127
/**
129-
* Built-in Long Sum aggregate function
128+
* Built-in Long Sum aggregate function.
130129
*/
131130
public static class LongSumAggFunction extends SumAggFunction {
132131
@Override
@@ -136,7 +135,7 @@ public TypeInformation getResultType() {
136135
}
137136

138137
/**
139-
* Built-in Float Sum aggregate function
138+
* Built-in Float Sum aggregate function.
140139
*/
141140
public static class FloatSumAggFunction extends SumAggFunction {
142141
@Override
@@ -146,7 +145,7 @@ public TypeInformation getResultType() {
146145
}
147146

148147
/**
149-
* Built-in Double Sum aggregate function
148+
* Built-in Double Sum aggregate function.
150149
*/
151150
public static class DoubleSumAggFunction extends SumAggFunction {
152151
@Override
@@ -156,7 +155,7 @@ public TypeInformation getResultType() {
156155
}
157156

158157
/**
159-
* Built-in Decimal Sum aggregate function
158+
* Built-in Decimal Sum aggregate function.
160159
*/
161160
public static class DecimalSumAggFunction extends SumAggFunction {
162161
private DecimalTypeInfo decimalType;

0 commit comments

Comments
 (0)