如果Connection可序列化是不是用map也可以

Answer 1

Michael_PK 2019-11-15 20:02:18

上下文描述下，不太清楚想表达的意思是什么

• 提问者 慕神9346227 #1

  像这样：
  String connection = DBUtils.getConnection();
          data.map(new MapFunction<String, String>() {
              public String map(String input) throws Exception {
                  
                  System.out.println("connection = [" + connection + "]");
                  
                  return input;
              }
          }).print();
  DBUtils.returnConnection(connection);
  就是数据库的Connection如果可以序列化就可以定义在map的外面，这样是不是就和mapPartition差不多了，这样会存在什么问题吗

• Michael_PK 回复 提问者 慕神9346227 #2

  不是这个意思。首先connection是没法序列化的。其实应该是一个partition一个connection，不然每条记录一个开销太大。最好的方式就是首先准备好一个连接池，然后一个partition从pool中获取一个connection，用完还回去