Project

General

Profile

« Previous | Next » 

Revision 57443

put operations WAS SYNC

View differences:

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