Revision 57443
Added by Claudio Atzori over 4 years ago
DedupBuildRootsReducer.java | ||
---|---|---|
118 | 118 |
private void emit(final String msg, final Context context, final byte[] rowkey, final String family, final String qualifier, final byte[] value, final String label) { |
119 | 119 |
|
120 | 120 |
final Put put = new Put(rowkey).add(Bytes.toBytes(family), Bytes.toBytes(qualifier), value); |
121 |
put.setDurability(Durability.SKIP_WAL);
|
|
121 |
put.setDurability(Durability.USE_DEFAULT);
|
|
122 | 122 |
|
123 | 123 |
try { |
124 | 124 |
context.write(new ImmutableBytesWritable(rowkey), put); |
Also available in: Unified diff
put operations WAS SYNC