|
22 | 22 | import java.util.Map; |
23 | 23 | import java.util.Set; |
24 | 24 | import java.util.stream.Collectors; |
25 | | -import java.util.stream.Stream; |
26 | 25 |
|
27 | 26 | import javax.annotation.Nonnull; |
28 | 27 | import javax.annotation.Nullable; |
|
41 | 40 | import com.cinchapi.concourse.thrift.JavaThriftBridge; |
42 | 41 | import com.cinchapi.concourse.thrift.TCriteria; |
43 | 42 | import com.cinchapi.concourse.thrift.TOrder; |
44 | | -import com.cinchapi.concourse.validate.Keys; |
45 | | -import com.cinchapi.concourse.validate.Keys.Key; |
46 | | -import com.cinchapi.concourse.validate.Keys.KeyType; |
47 | 43 | import com.google.common.base.CaseFormat; |
48 | 44 | import com.google.common.base.MoreObjects; |
49 | 45 | import com.google.common.base.MoreObjects.ToStringHelper; |
|
52 | 48 | import com.google.common.collect.ImmutableSet; |
53 | 49 | import com.google.common.collect.Multimap; |
54 | 50 | import com.google.common.collect.Sets; |
55 | | -import com.google.common.collect.Streams; |
56 | 51 |
|
57 | 52 | /** |
58 | 53 | * A {@link Command} describes a {@link ConcourseServer} operation and the |
@@ -464,20 +459,6 @@ else if(conditionKeys == null) { |
464 | 459 | conditionKeys = ImmutableSet.of(); |
465 | 460 | } |
466 | 461 |
|
467 | | - // If any of the #conditionKeys are navigation keys, break them up |
468 | | - // and add each stop as a condition key |
469 | | - if(!conditionKeys.isEmpty()) { |
470 | | - conditionKeys = conditionKeys.stream().flatMap($key -> { |
471 | | - Key key = Keys.parse($key); |
472 | | - Stream<String> stream = Stream.of($key); |
473 | | - if(key.type() == KeyType.NAVIGATION_KEY) { |
474 | | - String[] stops = key.data(); |
475 | | - stream = Streams.concat(stream, Arrays.stream(stops)); |
476 | | - } |
477 | | - return stream; |
478 | | - }).collect(Collectors.toSet()); |
479 | | - } |
480 | | - |
481 | 462 | // operationTimestamp |
482 | 463 | if(args.containsKey("time")) { |
483 | 464 | operationTimestamp = args.fetch("time"); |
|
0 commit comments