Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r163396452
--- Diff: src/java/org/apache/cassandra/hadoop/ConfigHelper.java ---
@@ -349,6 +350,16 @@ public static String
getOutputInitialAddress(Configuration conf)
return conf.get(OUTPUT_INITIAL_ADDRESS);
}
+ public static void setOutputInitialPort(Configuration conf, Integer
port)
+ {
+ conf.set(OUTPUT_INITIAL_PORT, port.toString());
+ }
+
+ public static Integer getOutputInitialPort(Configuration conf)
+ {
+ return Integer.valueOf(conf.get(OUTPUT_INITIAL_PORT, "7000"));
--- End diff --
sgtm. pretty nit: maybe make it a constant, instead of looking like a magic
number?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
