aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java
index 9d4a62979..cef41013f 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/materialize/QueryWritableBatch.java
@@ -17,27 +17,27 @@
*/
package org.apache.drill.exec.physical.impl.materialize;
+import io.netty.buffer.ByteBuf;
+
import java.util.Arrays;
import java.util.List;
-import com.google.common.collect.Lists;
-import io.netty.buffer.ByteBuf;
-
import org.apache.drill.exec.proto.UserBitShared.QueryId;
import org.apache.drill.exec.proto.UserBitShared.QueryResult;
import org.apache.drill.exec.proto.UserBitShared.RecordBatchDef;
import org.apache.drill.exec.proto.UserBitShared.SerializedField;
import org.apache.drill.exec.record.BatchSchema;
import org.apache.drill.exec.record.MaterializedField;
-import org.apache.drill.exec.record.WritableBatch;
+
+import com.google.common.collect.Lists;
public class QueryWritableBatch {
static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(QueryWritableBatch.class);
-
+
private final QueryResult header;
private final ByteBuf[] buffers;
-
-
+
+
public QueryWritableBatch(QueryResult header, ByteBuf... buffers) {
super();
this.header = header;
@@ -55,7 +55,7 @@ public class QueryWritableBatch {
}
return n;
}
-
+
public QueryResult getHeader() {
return header;
}
@@ -79,5 +79,5 @@ public class QueryWritableBatch {
.build();
return new QueryWritableBatch(header);
}
-
+
}