How to write a customer sink partitioner when using flinksql kafka-connector

[wangl...@geekplus.com]

CREATE TABLE kafka_sink_table(
 warehouse_id INT,
 pack_task_order_id BIGINT,
 out_order_code STRING,
 pick_order_id BIGINT,
 end_time BIGINT
WITH (
 'connector'='kafka',
 'topic'='ods_wms_pack_task_order',
 'properties.bootstrap.servers'='172.19.78.32:9092',
 'format'='json'
);


INSERT INTO  kafka_sink_table SELECT  ....... 

As describe here： 
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/kafka.html
  
I want to do partition according to warehouse_id.

How should i write my customer partitioner? Is there any example?

Thanks,
Lei



wangl...@geekplus.com