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();
}