Committed by
Pavlin Radoslavov
Cosmetic fixes to SMap
Change-Id: I2b45227c19ee2d6595d52dda35a139ed3a898ce8
Showing
1 changed file
with
133 additions
and
20 deletions
... | @@ -47,7 +47,6 @@ import com.hazelcast.mapreduce.aggregation.Supplier; | ... | @@ -47,7 +47,6 @@ import com.hazelcast.mapreduce.aggregation.Supplier; |
47 | import com.hazelcast.monitor.LocalMapStats; | 47 | import com.hazelcast.monitor.LocalMapStats; |
48 | import com.hazelcast.query.Predicate; | 48 | import com.hazelcast.query.Predicate; |
49 | 49 | ||
50 | -// TODO: implement Predicate, etc. if we need them. | ||
51 | /** | 50 | /** |
52 | * Wrapper around IMap<byte[], byte[]> which serializes/deserializes | 51 | * Wrapper around IMap<byte[], byte[]> which serializes/deserializes |
53 | * key and value using StoreSerializer. | 52 | * key and value using StoreSerializer. |
... | @@ -298,21 +297,39 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -298,21 +297,39 @@ public class SMap<K, V> implements IMap<K, V> { |
298 | return m.addLocalEntryListener(new BaseEntryListener(listener)); | 297 | return m.addLocalEntryListener(new BaseEntryListener(listener)); |
299 | } | 298 | } |
300 | 299 | ||
301 | - @Deprecated // marking method not implemented | 300 | + /** |
301 | + * {@inheritDoc} | ||
302 | + * | ||
303 | + * @deprecated not implemented yet | ||
304 | + * @throws UnsupportedOperationException not implemented yet | ||
305 | + */ | ||
306 | + @Deprecated | ||
302 | @Override | 307 | @Override |
303 | public String addLocalEntryListener(EntryListener<K, V> listener, | 308 | public String addLocalEntryListener(EntryListener<K, V> listener, |
304 | Predicate<K, V> predicate, boolean includeValue) { | 309 | Predicate<K, V> predicate, boolean includeValue) { |
305 | throw new UnsupportedOperationException(); | 310 | throw new UnsupportedOperationException(); |
306 | } | 311 | } |
307 | 312 | ||
308 | - @Deprecated // marking method not implemented | 313 | + /** |
314 | + * {@inheritDoc} | ||
315 | + * | ||
316 | + * @deprecated not implemented yet | ||
317 | + * @throws UnsupportedOperationException not implemented yet | ||
318 | + */ | ||
319 | + @Deprecated | ||
309 | @Override | 320 | @Override |
310 | public String addLocalEntryListener(EntryListener<K, V> listener, | 321 | public String addLocalEntryListener(EntryListener<K, V> listener, |
311 | Predicate<K, V> predicate, K key, boolean includeValue) { | 322 | Predicate<K, V> predicate, K key, boolean includeValue) { |
312 | throw new UnsupportedOperationException(); | 323 | throw new UnsupportedOperationException(); |
313 | } | 324 | } |
314 | 325 | ||
315 | - @Deprecated // marking method not implemented | 326 | + /** |
327 | + * {@inheritDoc} | ||
328 | + * | ||
329 | + * @deprecated not implemented yet | ||
330 | + * @throws UnsupportedOperationException not implemented yet | ||
331 | + */ | ||
332 | + @Deprecated | ||
316 | @Override | 333 | @Override |
317 | public String addInterceptor(MapInterceptor interceptor) { | 334 | public String addInterceptor(MapInterceptor interceptor) { |
318 | throw new UnsupportedOperationException(); | 335 | throw new UnsupportedOperationException(); |
... | @@ -341,21 +358,39 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -341,21 +358,39 @@ public class SMap<K, V> implements IMap<K, V> { |
341 | serializeKey(key), includeValue); | 358 | serializeKey(key), includeValue); |
342 | } | 359 | } |
343 | 360 | ||
344 | - @Deprecated // marking method not implemented | 361 | + /** |
362 | + * {@inheritDoc} | ||
363 | + * | ||
364 | + * @deprecated not implemented yet | ||
365 | + * @throws UnsupportedOperationException not implemented yet | ||
366 | + */ | ||
367 | + @Deprecated | ||
345 | @Override | 368 | @Override |
346 | public String addEntryListener(EntryListener<K, V> listener, | 369 | public String addEntryListener(EntryListener<K, V> listener, |
347 | Predicate<K, V> predicate, boolean includeValue) { | 370 | Predicate<K, V> predicate, boolean includeValue) { |
348 | throw new UnsupportedOperationException(); | 371 | throw new UnsupportedOperationException(); |
349 | } | 372 | } |
350 | 373 | ||
351 | - @Deprecated // marking method not implemented | 374 | + /** |
375 | + * {@inheritDoc} | ||
376 | + * | ||
377 | + * @deprecated not implemented yet | ||
378 | + * @throws UnsupportedOperationException not implemented yet | ||
379 | + */ | ||
380 | + @Deprecated | ||
352 | @Override | 381 | @Override |
353 | public String addEntryListener(EntryListener<K, V> listener, | 382 | public String addEntryListener(EntryListener<K, V> listener, |
354 | Predicate<K, V> predicate, K key, boolean includeValue) { | 383 | Predicate<K, V> predicate, K key, boolean includeValue) { |
355 | throw new UnsupportedOperationException(); | 384 | throw new UnsupportedOperationException(); |
356 | } | 385 | } |
357 | 386 | ||
358 | - @Deprecated // marking method not implemented | 387 | + /** |
388 | + * {@inheritDoc} | ||
389 | + * | ||
390 | + * @deprecated not implemented yet | ||
391 | + * @throws UnsupportedOperationException not implemented yet | ||
392 | + */ | ||
393 | + @Deprecated | ||
359 | @Override | 394 | @Override |
360 | public EntryView<K, V> getEntryView(K key) { | 395 | public EntryView<K, V> getEntryView(K key) { |
361 | throw new UnsupportedOperationException(); | 396 | throw new UnsupportedOperationException(); |
... | @@ -386,21 +421,39 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -386,21 +421,39 @@ public class SMap<K, V> implements IMap<K, V> { |
386 | return deserializeEntrySet(m.entrySet()); | 421 | return deserializeEntrySet(m.entrySet()); |
387 | } | 422 | } |
388 | 423 | ||
389 | - @Deprecated // marking method not implemented | 424 | + /** |
425 | + * {@inheritDoc} | ||
426 | + * | ||
427 | + * @deprecated not implemented yet | ||
428 | + * @throws UnsupportedOperationException not implemented yet | ||
429 | + */ | ||
430 | + @Deprecated | ||
390 | @SuppressWarnings("rawtypes") | 431 | @SuppressWarnings("rawtypes") |
391 | @Override | 432 | @Override |
392 | public Set<K> keySet(Predicate predicate) { | 433 | public Set<K> keySet(Predicate predicate) { |
393 | throw new UnsupportedOperationException(); | 434 | throw new UnsupportedOperationException(); |
394 | } | 435 | } |
395 | 436 | ||
396 | - @Deprecated // marking method not implemented | 437 | + /** |
438 | + * {@inheritDoc} | ||
439 | + * | ||
440 | + * @deprecated not implemented yet | ||
441 | + * @throws UnsupportedOperationException not implemented yet | ||
442 | + */ | ||
443 | + @Deprecated | ||
397 | @SuppressWarnings("rawtypes") | 444 | @SuppressWarnings("rawtypes") |
398 | @Override | 445 | @Override |
399 | public Set<java.util.Map.Entry<K, V>> entrySet(Predicate predicate) { | 446 | public Set<java.util.Map.Entry<K, V>> entrySet(Predicate predicate) { |
400 | throw new UnsupportedOperationException(); | 447 | throw new UnsupportedOperationException(); |
401 | } | 448 | } |
402 | 449 | ||
403 | - @Deprecated // marking method not implemented | 450 | + /** |
451 | + * {@inheritDoc} | ||
452 | + * | ||
453 | + * @deprecated not implemented yet | ||
454 | + * @throws UnsupportedOperationException not implemented yet | ||
455 | + */ | ||
456 | + @Deprecated | ||
404 | @SuppressWarnings("rawtypes") | 457 | @SuppressWarnings("rawtypes") |
405 | @Override | 458 | @Override |
406 | public Collection<V> values(Predicate predicate) { | 459 | public Collection<V> values(Predicate predicate) { |
... | @@ -412,14 +465,26 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -412,14 +465,26 @@ public class SMap<K, V> implements IMap<K, V> { |
412 | return deserializeKeySet(m.localKeySet()); | 465 | return deserializeKeySet(m.localKeySet()); |
413 | } | 466 | } |
414 | 467 | ||
415 | - @Deprecated // marking method not implemented | 468 | + /** |
469 | + * {@inheritDoc} | ||
470 | + * | ||
471 | + * @deprecated not implemented yet | ||
472 | + * @throws UnsupportedOperationException not implemented yet | ||
473 | + */ | ||
474 | + @Deprecated | ||
416 | @SuppressWarnings("rawtypes") | 475 | @SuppressWarnings("rawtypes") |
417 | @Override | 476 | @Override |
418 | public Set<K> localKeySet(Predicate predicate) { | 477 | public Set<K> localKeySet(Predicate predicate) { |
419 | throw new UnsupportedOperationException(); | 478 | throw new UnsupportedOperationException(); |
420 | } | 479 | } |
421 | 480 | ||
422 | - @Deprecated // marking method not implemented | 481 | + /** |
482 | + * {@inheritDoc} | ||
483 | + * | ||
484 | + * @deprecated not implemented yet | ||
485 | + * @throws UnsupportedOperationException not implemented yet | ||
486 | + */ | ||
487 | + @Deprecated | ||
423 | @Override | 488 | @Override |
424 | public void addIndex(String attribute, boolean ordered) { | 489 | public void addIndex(String attribute, boolean ordered) { |
425 | throw new UnsupportedOperationException(); | 490 | throw new UnsupportedOperationException(); |
... | @@ -430,14 +495,26 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -430,14 +495,26 @@ public class SMap<K, V> implements IMap<K, V> { |
430 | return m.getLocalMapStats(); | 495 | return m.getLocalMapStats(); |
431 | } | 496 | } |
432 | 497 | ||
433 | - @Deprecated // marking method not implemented | 498 | + /** |
499 | + * {@inheritDoc} | ||
500 | + * | ||
501 | + * @deprecated not implemented yet | ||
502 | + * @throws UnsupportedOperationException not implemented yet | ||
503 | + */ | ||
504 | + @Deprecated | ||
434 | @SuppressWarnings("rawtypes") | 505 | @SuppressWarnings("rawtypes") |
435 | @Override | 506 | @Override |
436 | public Object executeOnKey(K key, EntryProcessor entryProcessor) { | 507 | public Object executeOnKey(K key, EntryProcessor entryProcessor) { |
437 | throw new UnsupportedOperationException(); | 508 | throw new UnsupportedOperationException(); |
438 | } | 509 | } |
439 | 510 | ||
440 | - @Deprecated // marking method not implemented | 511 | + /** |
512 | + * {@inheritDoc} | ||
513 | + * | ||
514 | + * @deprecated not implemented yet | ||
515 | + * @throws UnsupportedOperationException not implemented yet | ||
516 | + */ | ||
517 | + @Deprecated | ||
441 | @SuppressWarnings("rawtypes") | 518 | @SuppressWarnings("rawtypes") |
442 | @Override | 519 | @Override |
443 | public Map<K, Object> executeOnKeys(Set<K> keys, | 520 | public Map<K, Object> executeOnKeys(Set<K> keys, |
... | @@ -445,7 +522,13 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -445,7 +522,13 @@ public class SMap<K, V> implements IMap<K, V> { |
445 | throw new UnsupportedOperationException(); | 522 | throw new UnsupportedOperationException(); |
446 | } | 523 | } |
447 | 524 | ||
448 | - @Deprecated // marking method not implemented | 525 | + /** |
526 | + * {@inheritDoc} | ||
527 | + * | ||
528 | + * @deprecated not implemented yet | ||
529 | + * @throws UnsupportedOperationException not implemented yet | ||
530 | + */ | ||
531 | + @Deprecated | ||
449 | @SuppressWarnings("rawtypes") | 532 | @SuppressWarnings("rawtypes") |
450 | @Override | 533 | @Override |
451 | public void submitToKey(K key, EntryProcessor entryProcessor, | 534 | public void submitToKey(K key, EntryProcessor entryProcessor, |
... | @@ -453,21 +536,39 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -453,21 +536,39 @@ public class SMap<K, V> implements IMap<K, V> { |
453 | throw new UnsupportedOperationException(); | 536 | throw new UnsupportedOperationException(); |
454 | } | 537 | } |
455 | 538 | ||
456 | - @Deprecated // marking method not implemented | 539 | + /** |
540 | + * {@inheritDoc} | ||
541 | + * | ||
542 | + * @deprecated not implemented yet | ||
543 | + * @throws UnsupportedOperationException not implemented yet | ||
544 | + */ | ||
545 | + @Deprecated | ||
457 | @SuppressWarnings("rawtypes") | 546 | @SuppressWarnings("rawtypes") |
458 | @Override | 547 | @Override |
459 | public Future submitToKey(K key, EntryProcessor entryProcessor) { | 548 | public Future submitToKey(K key, EntryProcessor entryProcessor) { |
460 | throw new UnsupportedOperationException(); | 549 | throw new UnsupportedOperationException(); |
461 | } | 550 | } |
462 | 551 | ||
463 | - @Deprecated // marking method not implemented | 552 | + /** |
553 | + * {@inheritDoc} | ||
554 | + * | ||
555 | + * @deprecated not implemented yet | ||
556 | + * @throws UnsupportedOperationException not implemented yet | ||
557 | + */ | ||
558 | + @Deprecated | ||
464 | @SuppressWarnings("rawtypes") | 559 | @SuppressWarnings("rawtypes") |
465 | @Override | 560 | @Override |
466 | public Map<K, Object> executeOnEntries(EntryProcessor entryProcessor) { | 561 | public Map<K, Object> executeOnEntries(EntryProcessor entryProcessor) { |
467 | throw new UnsupportedOperationException(); | 562 | throw new UnsupportedOperationException(); |
468 | } | 563 | } |
469 | 564 | ||
470 | - @Deprecated // marking method not implemented | 565 | + /** |
566 | + * {@inheritDoc} | ||
567 | + * | ||
568 | + * @deprecated not implemented yet | ||
569 | + * @throws UnsupportedOperationException not implemented yet | ||
570 | + */ | ||
571 | + @Deprecated | ||
471 | @SuppressWarnings("rawtypes") | 572 | @SuppressWarnings("rawtypes") |
472 | @Override | 573 | @Override |
473 | public Map<K, Object> executeOnEntries(EntryProcessor entryProcessor, | 574 | public Map<K, Object> executeOnEntries(EntryProcessor entryProcessor, |
... | @@ -475,7 +576,13 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -475,7 +576,13 @@ public class SMap<K, V> implements IMap<K, V> { |
475 | throw new UnsupportedOperationException(); | 576 | throw new UnsupportedOperationException(); |
476 | } | 577 | } |
477 | 578 | ||
478 | - @Deprecated // marking method not implemented | 579 | + /** |
580 | + * {@inheritDoc} | ||
581 | + * | ||
582 | + * @deprecated not implemented yet | ||
583 | + * @throws UnsupportedOperationException not implemented yet | ||
584 | + */ | ||
585 | + @Deprecated | ||
479 | @Override | 586 | @Override |
480 | public <SuppliedValue, Result> Result aggregate( | 587 | public <SuppliedValue, Result> Result aggregate( |
481 | Supplier<K, V, SuppliedValue> supplier, | 588 | Supplier<K, V, SuppliedValue> supplier, |
... | @@ -484,7 +591,13 @@ public class SMap<K, V> implements IMap<K, V> { | ... | @@ -484,7 +591,13 @@ public class SMap<K, V> implements IMap<K, V> { |
484 | throw new UnsupportedOperationException(); | 591 | throw new UnsupportedOperationException(); |
485 | } | 592 | } |
486 | 593 | ||
487 | - @Deprecated // marking method not implemented | 594 | + /** |
595 | + * {@inheritDoc} | ||
596 | + * | ||
597 | + * @deprecated not implemented yet | ||
598 | + * @throws UnsupportedOperationException not implemented yet | ||
599 | + */ | ||
600 | + @Deprecated | ||
488 | @Override | 601 | @Override |
489 | public <SuppliedValue, Result> Result aggregate( | 602 | public <SuppliedValue, Result> Result aggregate( |
490 | Supplier<K, V, SuppliedValue> supplier, | 603 | Supplier<K, V, SuppliedValue> supplier, | ... | ... |
-
Please register or login to post a comment