如题,或者获取split ID in the mapfunction。
=========================================
InputSplit is = context.getInputSplit();
splitId = MD5Hash.digest(is.toString()).toString();
-------------------------------------------------------------------
lastSplit = reporter.getInputSplit();
splitId = MD5Hash.digest(lastSplit.toString()).toString();
时间: 2024-11-03 22:29:21