MapReduce Input Split(输入分/切片)详解 public static long getMaxSplitSize(JobContext context) { return context.getConfiguration().getLong(SPLIT_MAXSIZE, Long.MAX_VALUE); } 如果没有设置这maxsize默认是Long.MAX_VALUE public static long getMinSplitSize(JobContext job) {
应用场景: 使用 sql的 Case When Then 批量更新某张表,底层数据库用到了Dapper 代码示例: public int UpdateClientReceivedResult(Dictionary<string, string> dict) { var dynamicSqlParam = new DynamicParameters(); ); sbSet.Append(" (CASE SmsFlowID "); ; foreach (var kv in di