sohami commented on a change in pull request #1334: DRILL-6385: Support JPPD
feature
URL: https://github.com/apache/drill/pull/1334#discussion_r207743838
##########
File path:
exec/java-exec/src/main/java/org/apache/drill/exec/rpc/data/DataServerRequestHandler.java
##########
@@ -52,8 +54,21 @@ public DataServerRequestHandler(WorkEventBus workBus,
WorkManager.WorkerBee bee)
@Override
public void handle(DataServerConnection connection, int rpcType, ByteBuf
pBody, ByteBuf dBody,
ResponseSender sender) throws RpcException {
- assert rpcType == BitData.RpcType.REQ_RECORD_BATCH_VALUE;
+ switch (rpcType) {
+ case RpcType.REQ_RUNTIME_FILTER_VALUE : {
+ handleRuntimeFilterRequest(pBody, dBody, sender);
+ }
+
Review comment:
`break` statement is missing here and below
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
