custom_partitions_lambda This code takes transactions from the firehose buffer, put custom partitions and sends back to firehose.