flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexis Gendronneau <a.gendronn...@gmail.com>
Subject Specific sink behaviour based on tuple key
Date Sat, 26 Aug 2017 08:01:30 GMT
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.gendronneau@corp.ovh.com
a.gendronneau@gmail.com

Mime
View raw message