Java源码示例:org.apache.flink.graph.drivers.Driver
示例1
/**
* List available algorithms. This is displayed to the user when no valid
* algorithm is given in the program parameterization.
*
* @return usage string listing available algorithms
*/
private static String getAlgorithmsListing() {
StrBuilder strBuilder = new StrBuilder();
strBuilder
.appendNewLine()
.appendln("Select an algorithm to view usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm <algorithm>")
.appendNewLine()
.appendln("Available algorithms:");
for (Driver algorithm : driverFactory) {
strBuilder.append(" ")
.appendFixedWidthPadRight(algorithm.getName(), 30, ' ')
.append(algorithm.getShortDescription()).appendNewLine();
}
return strBuilder.toString();
}
示例2
/**
* List available algorithms. This is displayed to the user when no valid
* algorithm is given in the program parameterization.
*
* @return usage string listing available algorithms
*/
private static String getAlgorithmsListing() {
StrBuilder strBuilder = new StrBuilder();
strBuilder
.appendNewLine()
.appendln("Select an algorithm to view usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm <algorithm>")
.appendNewLine()
.appendln("Available algorithms:");
for (Driver algorithm : driverFactory) {
strBuilder.append(" ")
.appendFixedWidthPadRight(algorithm.getName(), 30, ' ')
.append(algorithm.getShortDescription()).appendNewLine();
}
return strBuilder.toString();
}
示例3
/**
* List available algorithms. This is displayed to the user when no valid
* algorithm is given in the program parameterization.
*
* @return usage string listing available algorithms
*/
private static String getAlgorithmsListing() {
StrBuilder strBuilder = new StrBuilder();
strBuilder
.appendNewLine()
.appendln("Select an algorithm to view usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm <algorithm>")
.appendNewLine()
.appendln("Available algorithms:");
for (Driver algorithm : driverFactory) {
strBuilder.append(" ")
.appendFixedWidthPadRight(algorithm.getName(), 30, ' ')
.append(algorithm.getShortDescription()).appendNewLine();
}
return strBuilder.toString();
}
示例4
/**
* Display the usage for the given algorithm. This includes options for all
* compatible inputs, the selected algorithm, and outputs implemented by
* the selected algorithm.
*
* @param algorithmName unique identifier of the selected algorithm
* @return usage string for the given algorithm
*/
private static String getAlgorithmUsage(String algorithmName) {
StrBuilder strBuilder = new StrBuilder();
Driver algorithm = driverFactory.get(algorithmName);
strBuilder
.appendNewLine()
.appendNewLine()
.appendln(algorithm.getLongDescription())
.appendNewLine()
.append("usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm ")
.append(algorithmName)
.append(" [algorithm options] --input <input> [input options] --output <output> [output options]")
.appendNewLine()
.appendNewLine()
.appendln("Available inputs:");
for (Input input : inputFactory) {
strBuilder
.append(" --input ")
.append(input.getName())
.append(" ")
.appendln(input.getUsage());
}
String algorithmParameterization = algorithm.getUsage();
if (algorithmParameterization.length() > 0) {
strBuilder
.appendNewLine()
.appendln("Algorithm configuration:")
.append(" ")
.appendln(algorithm.getUsage());
}
strBuilder
.appendNewLine()
.appendln("Available outputs:");
for (Output output : outputFactory) {
strBuilder
.append(" --output ")
.append(output.getName())
.append(" ")
.appendln(output.getUsage());
}
return strBuilder
.appendNewLine()
.toString();
}
示例5
/**
* Display the usage for the given algorithm. This includes options for all
* compatible inputs, the selected algorithm, and outputs implemented by
* the selected algorithm.
*
* @param algorithmName unique identifier of the selected algorithm
* @return usage string for the given algorithm
*/
private static String getAlgorithmUsage(String algorithmName) {
StrBuilder strBuilder = new StrBuilder();
Driver algorithm = driverFactory.get(algorithmName);
strBuilder
.appendNewLine()
.appendNewLine()
.appendln(algorithm.getLongDescription())
.appendNewLine()
.append("usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm ")
.append(algorithmName)
.append(" [algorithm options] --input <input> [input options] --output <output> [output options]")
.appendNewLine()
.appendNewLine()
.appendln("Available inputs:");
for (Input input : inputFactory) {
strBuilder
.append(" --input ")
.append(input.getName())
.append(" ")
.appendln(input.getUsage());
}
String algorithmParameterization = algorithm.getUsage();
if (algorithmParameterization.length() > 0) {
strBuilder
.appendNewLine()
.appendln("Algorithm configuration:")
.append(" ")
.appendln(algorithm.getUsage());
}
strBuilder
.appendNewLine()
.appendln("Available outputs:");
for (Output output : outputFactory) {
strBuilder
.append(" --output ")
.append(output.getName())
.append(" ")
.appendln(output.getUsage());
}
return strBuilder
.appendNewLine()
.toString();
}
示例6
/**
* Display the usage for the given algorithm. This includes options for all
* compatible inputs, the selected algorithm, and outputs implemented by
* the selected algorithm.
*
* @param algorithmName unique identifier of the selected algorithm
* @return usage string for the given algorithm
*/
private static String getAlgorithmUsage(String algorithmName) {
StrBuilder strBuilder = new StrBuilder();
Driver algorithm = driverFactory.get(algorithmName);
strBuilder
.appendNewLine()
.appendNewLine()
.appendln(algorithm.getLongDescription())
.appendNewLine()
.append("usage: flink run examples/flink-gelly-examples_<version>.jar --algorithm ")
.append(algorithmName)
.append(" [algorithm options] --input <input> [input options] --output <output> [output options]")
.appendNewLine()
.appendNewLine()
.appendln("Available inputs:");
for (Input input : inputFactory) {
strBuilder
.append(" --input ")
.append(input.getName())
.append(" ")
.appendln(input.getUsage());
}
String algorithmParameterization = algorithm.getUsage();
if (algorithmParameterization.length() > 0) {
strBuilder
.appendNewLine()
.appendln("Algorithm configuration:")
.append(" ")
.appendln(algorithm.getUsage());
}
strBuilder
.appendNewLine()
.appendln("Available outputs:");
for (Output output : outputFactory) {
strBuilder
.append(" --output ")
.append(output.getName())
.append(" ")
.appendln(output.getUsage());
}
return strBuilder
.appendNewLine()
.toString();
}