Project

General

Profile

« Previous | Next » 

Revision 53036

cleanup

View differences:

modules/dnet-mapreduce-jobs/branches/beta/src/main/java/eu/dnetlib/data/mapreduce/hbase/dedup/DedupBuildRootsReducer.java
115 115
				context, revKey, decoder.getCFQ(), decoder.relTargetId(), decoder.toByteArray(), "mark deleted [entity -> dup]");
116 116
	}
117 117

  
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
			throws IOException, InterruptedException {
120
	    if (StringUtils.startsWith(family, "resultResult_publicationDataset_isSupplement")) {
121
            System.err.println(String.format("Error find relation %s on key %s and qualifier %s, message:'%s'", family, new String(rowkey), qualifier, msg));
122
            throw new RuntimeException("SUCA!");
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) {
123 119

  
124
        }
125

  
126

  
127

  
128

  
129 120
		final Put put = new Put(rowkey).add(Bytes.toBytes(family), Bytes.toBytes(qualifier), value);
130 121
		put.setDurability(Durability.SKIP_WAL);
131 122

  
......
185 176
			break;
186 177

  
187 178
		default:
188
			break;
179
			throw new IllegalStateException(String.format("case not implemented for %s", patchKind.toString()));
189 180
		}
190 181

  
191 182
		return OafDecoder.decode(builder.build());

Also available in: Unified diff