private void createSingleInputStreamExecutors(SingleInputStream inputStream, Partition partition,
                                                  MetaStreamEvent metaEvent,
                                                  List<VariableExpressionExecutor> executors,
                                                  Map<String, Table> tableMap,
                                                  SiddhiQueryContext siddhiQueryContext) {
        List<PartitionExecutor> executorList = new ArrayList<PartitionExecutor>();
        partitionExecutorLists.add(executorList);
        if (!inputStream.isInnerStream()) {
            for (PartitionType partitionType : partition.getPartitionTypeMap().values()) {
                if (partitionType instanceof ValuePartitionType) {
                    if (partitionType.getStreamId().equals(inputStream.getStreamId())) {
                        executorList.add(new ValuePartitionExecutor(ExpressionParser.parseExpression((
                                        (ValuePartitionType) partitionType).getExpression(),
                                metaEvent, SiddhiConstants.UNKNOWN_STATE, tableMap, executors,
                                false, 0,
                                ProcessingMode.BATCH, false, siddhiQueryContext)));
                    }
                } else {
                    for (RangePartitionType.RangePartitionProperty rangePartitionProperty : ((RangePartitionType)
                            partitionType).getRangePartitionProperties()) {
                        if (partitionType.getStreamId().equals(inputStream.getStreamId())) {
                            executorList.add(new RangePartitionExecutor((ConditionExpressionExecutor)
                                    ExpressionParser.parseExpression(rangePartitionProperty.getCondition(), metaEvent,
                                            SiddhiConstants.UNKNOWN_STATE, tableMap, executors,
                                            false, 0, ProcessingMode.BATCH,
                                            false, siddhiQueryContext),
                                    rangePartitionProperty.getPartitionKey()));
                        }
                    }
                }
            }
        }
    }
create PartitionExecutors to be used to get partitioning key
modules/siddhi-core/src/main/java/io/siddhi/core/partition/StreamPartitioner.java