You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by bh...@apache.org on 2019/08/18 04:53:22 UTC
[hadoop] branch trunk updated: HDDS-1979. Fix checkstyle errors
(#1312)
This is an automated email from the ASF dual-hosted git repository.
bharat pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new e618256 HDDS-1979. Fix checkstyle errors (#1312)
e618256 is described below
commit e61825682a1fe19ccf43fae5ff64beb078d8af62
Author: Vivek Ratnavel Subramanian <vi...@gmail.com>
AuthorDate: Sat Aug 17 21:53:12 2019 -0700
HDDS-1979. Fix checkstyle errors (#1312)
---
.../scm/cli/pipeline/ListPipelinesSubcommand.java | 23 +++++++++++++---------
1 file changed, 14 insertions(+), 9 deletions(-)
diff --git a/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/pipeline/ListPipelinesSubcommand.java b/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/pipeline/ListPipelinesSubcommand.java
index 1489ed0..51c4043 100644
--- a/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/pipeline/ListPipelinesSubcommand.java
+++ b/hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/pipeline/ListPipelinesSubcommand.java
@@ -38,14 +38,16 @@ public class ListPipelinesSubcommand implements Callable<Void> {
@CommandLine.ParentCommand
private SCMCLI parent;
- @CommandLine.Option( names = {"-ffc", "--filterByFactor"},
- description = "Filter listed pipelines by Factor(ONE/one)", defaultValue = "",
- required = false)
+ @CommandLine.Option(names = {"-ffc", "--filterByFactor"},
+ description = "Filter listed pipelines by Factor(ONE/one)",
+ defaultValue = "",
+ required = false)
private String factor;
- @CommandLine.Option( names = {"-fst", "--filterByState"},
- description = "Filter listed pipelines by State(OPEN/CLOSE)", defaultValue = "",
- required = false)
+ @CommandLine.Option(names = {"-fst", "--filterByState"},
+ description = "Filter listed pipelines by State(OPEN/CLOSE)",
+ defaultValue = "",
+ required = false)
private String state;
@@ -56,9 +58,12 @@ public class ListPipelinesSubcommand implements Callable<Void> {
scmClient.listPipelines().forEach(System.out::println);
} else {
scmClient.listPipelines().stream()
- .filter(p -> ((isNullOrEmpty(factor) || (p.getFactor().toString().compareToIgnoreCase(factor) == 0))
- && (isNullOrEmpty(state) || (p.getPipelineState().toString().compareToIgnoreCase(state) == 0))))
- .forEach(System.out::println);
+ .filter(p -> ((isNullOrEmpty(factor) ||
+ (p.getFactor().toString().compareToIgnoreCase(factor) == 0))
+ && (isNullOrEmpty(state) ||
+ (p.getPipelineState().toString().compareToIgnoreCase(state)
+ == 0))))
+ .forEach(System.out::println);
}
return null;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org