- Integer partition = record.partition();
- String user = record.key();
- Message message = record.value();
-
- switch(message.getType())
- {
- case ADD:
- addNumber(partition, user, (MessageAddNumber) message);
- break;
-
- case CALC:
- calculateSum(partition, user, (MessageCalculateSum) message);
- break;
- }
-