aboutsummaryrefslogtreecommitdiff
path: root/launcher
diff options
context:
space:
mode:
authorSean Owen <sowen@cloudera.com>2017-02-19 09:42:50 -0800
committerSean Owen <sowen@cloudera.com>2017-02-19 09:42:50 -0800
commit1487c9af20a333ead55955acf4c0aa323bea0d07 (patch)
tree5f47daa77e0f73da1e009cc3dcf0a5c0073246aa /launcher
parentde14d35f77071932963a994fac5aec0e5df838a1 (diff)
downloadspark-1487c9af20a333ead55955acf4c0aa323bea0d07.tar.gz
spark-1487c9af20a333ead55955acf4c0aa323bea0d07.tar.bz2
spark-1487c9af20a333ead55955acf4c0aa323bea0d07.zip
[SPARK-19534][TESTS] Convert Java tests to use lambdas, Java 8 features
## What changes were proposed in this pull request? Convert tests to use Java 8 lambdas, and modest related fixes to surrounding code. ## How was this patch tested? Jenkins tests Author: Sean Owen <sowen@cloudera.com> Closes #16964 from srowen/SPARK-19534.
Diffstat (limited to 'launcher')
-rw-r--r--launcher/src/test/java/org/apache/spark/launcher/SparkSubmitCommandBuilderSuite.java2
-rw-r--r--launcher/src/test/java/org/apache/spark/launcher/SparkSubmitOptionParserSuite.java8
2 files changed, 5 insertions, 5 deletions
diff --git a/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitCommandBuilderSuite.java b/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitCommandBuilderSuite.java
index d569b6688d..2e050f8413 100644
--- a/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitCommandBuilderSuite.java
+++ b/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitCommandBuilderSuite.java
@@ -217,7 +217,7 @@ public class SparkSubmitCommandBuilderSuite extends BaseSuite {
String deployMode = isDriver ? "client" : "cluster";
SparkSubmitCommandBuilder launcher =
- newCommandBuilder(Collections.<String>emptyList());
+ newCommandBuilder(Collections.emptyList());
launcher.childEnv.put(CommandBuilderUtils.ENV_SPARK_HOME,
System.getProperty("spark.test.home"));
launcher.master = "yarn";
diff --git a/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitOptionParserSuite.java b/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitOptionParserSuite.java
index 3bc35da7cc..9ff7aceb58 100644
--- a/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitOptionParserSuite.java
+++ b/launcher/src/test/java/org/apache/spark/launcher/SparkSubmitOptionParserSuite.java
@@ -44,7 +44,7 @@ public class SparkSubmitOptionParserSuite extends BaseSuite {
count++;
verify(parser).handle(eq(optNames[0]), eq(value));
verify(parser, times(count)).handle(anyString(), anyString());
- verify(parser, times(count)).handleExtraArgs(eq(Collections.<String>emptyList()));
+ verify(parser, times(count)).handleExtraArgs(eq(Collections.emptyList()));
}
}
@@ -54,9 +54,9 @@ public class SparkSubmitOptionParserSuite extends BaseSuite {
parser.parse(Arrays.asList(name));
count++;
switchCount++;
- verify(parser, times(switchCount)).handle(eq(switchNames[0]), same((String) null));
+ verify(parser, times(switchCount)).handle(eq(switchNames[0]), same(null));
verify(parser, times(count)).handle(anyString(), any(String.class));
- verify(parser, times(count)).handleExtraArgs(eq(Collections.<String>emptyList()));
+ verify(parser, times(count)).handleExtraArgs(eq(Collections.emptyList()));
}
}
}
@@ -80,7 +80,7 @@ public class SparkSubmitOptionParserSuite extends BaseSuite {
List<String> args = Arrays.asList(parser.MASTER + "=" + parser.MASTER);
parser.parse(args);
verify(parser).handle(eq(parser.MASTER), eq(parser.MASTER));
- verify(parser).handleExtraArgs(eq(Collections.<String>emptyList()));
+ verify(parser).handleExtraArgs(eq(Collections.emptyList()));
}
private static class DummyParser extends SparkSubmitOptionParser {