Revision 57443
Added by Claudio Atzori over 4 years ago
ConnectedComponentsReducer.java | ||
---|---|---|
66 | 66 |
|
67 | 67 |
private void emitDedupRel(final Context context, final byte[] cf, final byte[] from, final byte[] to, final byte[] value) { |
68 | 68 |
final Put put = new Put(from).add(cf, to, value); |
69 |
put.setDurability(Durability.SKIP_WAL);
|
|
69 |
put.setDurability(Durability.USE_DEFAULT);
|
|
70 | 70 |
try { |
71 | 71 |
context.write(new ImmutableBytesWritable(from), put); |
72 | 72 |
} catch (IOException | InterruptedException e) { |
Also available in: Unified diff
put operations WAS SYNC