Hi all, I am looking to customize a sink behaviour based on tuple key.
My goal is to have each sink partition to write to a specific output. My job will be something like : input -> keyBy() -> outputSink This output should be something like './base/path/keyValue/....'. But I was not able to find where key value is stored, could you help me to go the right way :) -- Alexis Gendronneau alexis.gendronn...@corp.ovh.com a.gendronn...@gmail.com
