61yao commented on code in PR #9778:
URL: https://github.com/apache/pinot/pull/9778#discussion_r1022381083
##########
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MailboxReceiveOperator.java:
##########
@@ -50,23 +48,26 @@ public class MailboxReceiveOperator extends
BaseOperator<TransferableBlock> {
private final MailboxService<TransferableBlock> _mailboxService;
private final RelDistribution.Type _exchangeType;
- private final KeySelector<Object[], Object[]> _keySelector;
private final List<ServerInstance> _sendingStageInstances;
- private final DataSchema _dataSchema;
private final String _hostName;
private final int _port;
private final long _jobId;
private final int _stageId;
private final long _timeout;
-
private int _serverIdx;
private TransferableBlock _upstreamErrorBlock;
- public MailboxReceiveOperator(MailboxService<TransferableBlock>
mailboxService, DataSchema dataSchema,
- List<ServerInstance> sendingStageInstances, RelDistribution.Type
exchangeType,
- KeySelector<Object[], Object[]> keySelector, String hostName, int port,
long jobId, int stageId) {
- _dataSchema = dataSchema;
+ public MailboxReceiveOperator(MailboxService<TransferableBlock>
mailboxService,
+ List<ServerInstance> sendingStageInstances, RelDistribution.Type
exchangeType, String hostName, int port,
+ long jobId, int stageId) {
_mailboxService = mailboxService;
+ Preconditions.checkState(exchangeType !=
RelDistribution.Type.RANDOM_DISTRIBUTED,
+ "Random distribution is not supported");
+ Preconditions.checkState(exchangeType != RelDistribution.Type.ANY, "Any
distribution is not supported");
+ Preconditions.checkState(exchangeType !=
RelDistribution.Type.RANGE_DISTRIBUTED,
+ "Range distribution is not supported");
+ Preconditions.checkState(exchangeType !=
RelDistribution.Type.ROUND_ROBIN_DISTRIBUTED,
+ "Round robin distribution is not supported");
Review Comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
