在.NET中,当我们使用TransactionScope时,我们可以跨多个连接共享相同的事务。
using(TransactionScope tran = new TransactionScope()) {
//this method open a new connection
CallAMethodThatDoesSomeWork();
//this method open another new connection
CallAMethodThatDoesSomeMoreWork();
tran.Complete();
}
考虑到事务需要特定的连接才能在数据库中
我有一个地图。
for line in sys.stdin:
#if line is from file1
#process it based on some_arbitrary_logic
#emit k,v
#if line is from file2
#process it based on another_arbitrary_logic
#emit k, v
我需要使用-input file1和另一个-input file2通过hadoop调用这个映射器。
我怎样才能做到这一点?我如何知道hadoop流提供给我的STDIN中哪一行属于哪