@@ -303,8 +303,7 @@ protected Object readProperty(String path, RedisData source, RedisPersistentProp
303
303
Bucket bucket = source .getBucket ().extract (currentPath + "." );
304
304
305
305
RedisData newBucket = new RedisData (bucket );
306
- TypeInformation <?> typeToRead = typeMapper .readType (bucket .getPropertyPath (currentPath ),
307
- typeInformation );
306
+ TypeInformation <?> typeToRead = typeMapper .readType (bucket .getPropertyPath (currentPath ), typeInformation );
308
307
309
308
return readInternal (currentPath , typeToRead .getType (), newBucket );
310
309
}
@@ -584,8 +583,7 @@ RedisPersistentProperty getTargetPropertyOrNullForPath(String path, Class<?> typ
584
583
* @param sink
585
584
*/
586
585
private void writeInternal (@ Nullable String keyspace , String path , @ Nullable Object value ,
587
- TypeInformation <?> typeHint ,
588
- RedisData sink ) {
586
+ TypeInformation <?> typeHint , RedisData sink ) {
589
587
590
588
if (value == null ) {
591
589
return ;
@@ -736,8 +734,7 @@ private void writeAssociation(String path, RedisPersistentEntity<?> entity, @Nul
736
734
* @param sink
737
735
*/
738
736
private void writeCollection (@ Nullable String keyspace , String path , @ Nullable Iterable <?> values ,
739
- TypeInformation <?> typeHint ,
740
- RedisData sink ) {
737
+ TypeInformation <?> typeHint , RedisData sink ) {
741
738
742
739
if (values == null ) {
743
740
return ;
@@ -1131,6 +1128,7 @@ private enum NaturalOrderingKeyComparator implements Comparator<String> {
1131
1128
* (non-Javadoc)
1132
1129
* @see java.util.Comparator#compare(java.lang.Object, java.lang.Object)
1133
1130
*/
1131
+ @ Override
1134
1132
public int compare (String s1 , String s2 ) {
1135
1133
1136
1134
int s1offset = 0 ;
@@ -1214,13 +1212,14 @@ public int compareTo(Part that) {
1214
1212
* {@literal keyspace:id}.
1215
1213
*
1216
1214
* @author Mark Paluch
1215
+ * @author Stefan Berger
1217
1216
* @since 1.8.10
1218
1217
*/
1219
1218
public static class KeyspaceIdentifier {
1220
1219
1221
1220
public static final String PHANTOM = "phantom" ;
1222
- public static final String DELIMITTER = ":" ;
1223
- public static final String PHANTOM_SUFFIX = DELIMITTER + PHANTOM ;
1221
+ public static final String DELIMITER = ":" ;
1222
+ public static final String PHANTOM_SUFFIX = DELIMITER + PHANTOM ;
1224
1223
1225
1224
private final String keyspace ;
1226
1225
private final String id ;
@@ -1244,7 +1243,7 @@ public static KeyspaceIdentifier of(String key) {
1244
1243
Assert .isTrue (isValid (key ), String .format ("Invalid key %s" , key ));
1245
1244
1246
1245
boolean phantomKey = key .endsWith (PHANTOM_SUFFIX );
1247
- int keyspaceEndIndex = key .indexOf (DELIMITTER );
1246
+ int keyspaceEndIndex = key .indexOf (DELIMITER );
1248
1247
String keyspace = key .substring (0 , keyspaceEndIndex );
1249
1248
String id ;
1250
1249
@@ -1270,7 +1269,7 @@ public static boolean isValid(@Nullable String key) {
1270
1269
return false ;
1271
1270
}
1272
1271
1273
- int keyspaceEndIndex = key .indexOf (DELIMITTER );
1272
+ int keyspaceEndIndex = key .indexOf (DELIMITER );
1274
1273
1275
1274
return keyspaceEndIndex > 0 && key .length () > keyspaceEndIndex ;
1276
1275
}
@@ -1293,13 +1292,14 @@ public boolean isPhantomKey() {
1293
1292
* {@literal keyspace:id}.
1294
1293
*
1295
1294
* @author Mark Paluch
1295
+ * @author Stefan Berger
1296
1296
* @since 1.8.10
1297
1297
*/
1298
1298
public static class BinaryKeyspaceIdentifier {
1299
1299
1300
1300
public static final byte [] PHANTOM = KeyspaceIdentifier .PHANTOM .getBytes ();
1301
- public static final byte DELIMITTER = ':' ;
1302
- public static final byte [] PHANTOM_SUFFIX = ByteUtils .concat (new byte [] { DELIMITTER }, PHANTOM );
1301
+ public static final byte DELIMITER = ':' ;
1302
+ public static final byte [] PHANTOM_SUFFIX = ByteUtils .concat (new byte [] { DELIMITER }, PHANTOM );
1303
1303
1304
1304
private final byte [] keyspace ;
1305
1305
private final byte [] id ;
@@ -1324,7 +1324,7 @@ public static BinaryKeyspaceIdentifier of(byte[] key) {
1324
1324
1325
1325
boolean phantomKey = ByteUtils .startsWith (key , PHANTOM_SUFFIX , key .length - PHANTOM_SUFFIX .length );
1326
1326
1327
- int keyspaceEndIndex = ByteUtils .indexOf (key , DELIMITTER );
1327
+ int keyspaceEndIndex = ByteUtils .indexOf (key , DELIMITER );
1328
1328
byte [] keyspace = extractKeyspace (key , keyspaceEndIndex );
1329
1329
byte [] id = extractId (key , phantomKey , keyspaceEndIndex );
1330
1330
@@ -1344,7 +1344,7 @@ public static boolean isValid(byte[] key) {
1344
1344
return false ;
1345
1345
}
1346
1346
1347
- int keyspaceEndIndex = ByteUtils .indexOf (key , DELIMITTER );
1347
+ int keyspaceEndIndex = ByteUtils .indexOf (key , DELIMITER );
1348
1348
1349
1349
return keyspaceEndIndex > 0 && key .length > keyspaceEndIndex ;
1350
1350
}
0 commit comments