We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 06570b7 commit 84914b7Copy full SHA for 84914b7
1 file changed
src/main/java/su/interference/sql/SQLGroupContainer.java
@@ -117,9 +117,6 @@ public DataChunk add (DataChunk c) throws InternalException {
117
private DataChunk add2Window(DataChunk c) throws InternalException {
118
if (c != null) {
119
w_.add(c);
120
- if (dc == null) {
121
- dc = c;
122
- }
123
}
124
if (w_.size() < wcolumnInterval) {
125
return null;
@@ -130,6 +127,9 @@ private DataChunk add2Window(DataChunk c) throws InternalException {
130
127
if (w_.size() != wcolumnInterval) {
131
128
throw new InternalException();
132
129
+ if (dc == null) {
+ dc = w_.get(0);
+ }
133
for (DataChunk c_ : w_) {
134
final Object[] os = c_.getDcs().getValueSet();
135
if (os.length != this.cols.size()) {
0 commit comments