Revision 57443
Added by Claudio Atzori over 4 years ago
| DedupGrouperMapper.java | ||
|---|---|---|
| 5 | 5 |
import java.util.List; |
| 6 | 6 |
|
| 7 | 7 |
import org.apache.hadoop.hbase.KeyValue; |
| 8 |
import org.apache.hadoop.hbase.client.Durability; |
|
| 8 | 9 |
import org.apache.hadoop.hbase.client.Put; |
| 9 | 10 |
import org.apache.hadoop.hbase.client.Result; |
| 10 | 11 |
import org.apache.hadoop.hbase.io.ImmutableBytesWritable; |
| ... | ... | |
| 52 | 53 |
if (!Arrays.equals(nq, jq)) {
|
| 53 | 54 |
|
| 54 | 55 |
final Put put = new Put(nq).add(family, jq, cellValue); |
| 55 |
put.setWriteToWAL(JobParams.WRITE_TO_WAL);
|
|
| 56 |
put.setDurability(Durability.USE_DEFAULT);
|
|
| 56 | 57 |
rowKey.set(nq); |
| 57 | 58 |
context.write(rowKey, put); |
| 58 | 59 |
|
Also available in: Unified diff
put operations WAS SYNC