Skip to content

Commit

Permalink
MR notes
Browse files Browse the repository at this point in the history
  • Loading branch information
Christopher Gross cogross committed Jul 17, 2024
1 parent 64bccbc commit f848049
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
10 changes: 5 additions & 5 deletions warehouse/core/src/main/java/datawave/edge/util/EdgeKey.java
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ public class EdgeKey {

private static final Logger log = Logger.getLogger(EdgeKey.class);

private static final String CANT_ENCODE_UNKNOWN_ERROR_MSG = "Can't encode unknown edge key format.";
private static final String UNKNOWN_EDGE_KEY_FORMAT_MSG = "Can't encode unknown edge key format.";

// use the builder, not this nightmare constructor
private EdgeKey(EDGE_FORMAT format, STATS_TYPE statsType, String sourceData, String sinkData, String family, String sourceRelationship,
Expand Down Expand Up @@ -927,7 +927,7 @@ public Key encode() {
return encode(EDGE_VERSION.DATE_PROTOBUF);
} else {
// EDGE_FORMAT.UNKNOWN
throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
}
}

Expand All @@ -940,7 +940,7 @@ public Key encodeLegacyProtobufKey() {
return encode(EDGE_VERSION.PROTOBUF);
} else {
// EDGE_FORMAT.UNKNOWN
throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
}
}

Expand All @@ -951,7 +951,7 @@ public Key encodeLegacyAttribute2Key() {
return encode(EDGE_VERSION.BASE_ATTRIBUTE2);
} else {
// EDGE_FORMAT.UNKNOWN
throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
}
}

Expand All @@ -962,7 +962,7 @@ public Key encodeLegacyKey() {
return encode(EDGE_VERSION.BASE);
} else {
// EDGE_FORMAT.UNKNOWN
throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1292,7 +1292,7 @@ public AccumuloIteratorOption(String iteratorOption) {
this.iteratorName = tokenizer.nextToken();
try {
this.key = URLDecoder.decode(tokenizer.nextToken(), UTF8);
this.value = URLDecoder.decode(tokenizer.nextToken(), "UTF8");
this.value = URLDecoder.decode(tokenizer.nextToken(), UTF8);
} catch (UnsupportedEncodingException e) {
throw new RuntimeException(e);
}
Expand Down

0 comments on commit f848049

Please sign in to comment.