public abstract class AbstractStreamCommands extends Object implements org.springframework.shell.core.CommandMarker
Modifier and Type | Field and Description |
---|---|
protected DataFlowShell |
dataFlowShell |
protected static String |
PROPERTIES_FILE_OPTION |
protected static String |
PROPERTIES_OPTION |
protected UserInput |
userInput |
protected static String |
VALIDATE_STREAM |
Constructor and Description |
---|
AbstractStreamCommands() |
Modifier and Type | Method and Description |
---|---|
boolean |
availableWithCreateRole() |
boolean |
availableWithViewRole() |
String |
createStream(String name,
String dsl,
boolean deploy) |
String |
destroyAllStreams(boolean force) |
String |
destroyStream(String name) |
org.springframework.shell.table.Table |
listStreams() |
List<Object> |
streamInfo(String name) |
protected StreamOperations |
streamOperations() |
String |
undeployAllStreams(boolean force) |
String |
undeployStream(String name) |
List<Object> |
validateStream(String name) |
protected static final String PROPERTIES_OPTION
protected static final String PROPERTIES_FILE_OPTION
protected static final String VALIDATE_STREAM
protected DataFlowShell dataFlowShell
protected UserInput userInput
@CliAvailabilityIndicator(value={"stream list","stream info"}) public boolean availableWithViewRole()
@CliAvailabilityIndicator(value={"stream create","stream undeploy","stream all undeploy","stream destroy","stream all destroy"}) public boolean availableWithCreateRole()
@CliCommand(value="stream create", help="Create a new stream definition") public String createStream(@CliOption(mandatory=true,key={"","name"},help="the name to give to the stream") String name, @CliOption(mandatory=true,key="definition",help="a stream definition, using the DSL (e.g. \"http --port=9000 | hdfs\")",optionContext="disable-string-converter completion-stream") String dsl, @CliOption(key="deploy",help="whether to deploy the stream immediately",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean deploy)
@CliCommand(value="stream list", help="List created streams") public org.springframework.shell.table.Table listStreams()
@CliCommand(value="stream info", help="Show information about a specific stream") public List<Object> streamInfo(@CliOption(key={"","name"},help="the name of the stream to show",mandatory=true,optionContext="existing-stream disable-string-converter") String name)
@CliCommand(value="stream undeploy", help="Un-deploy a previously deployed stream") public String undeployStream(@CliOption(key={"","name"},help="the name of the stream to un-deploy",mandatory=true,optionContext="existing-stream disable-string-converter") String name)
@CliCommand(value="stream all undeploy", help="Un-deploy all previously deployed stream") public String undeployAllStreams(@CliOption(key="force",help="bypass confirmation prompt",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean force)
@CliCommand(value="stream destroy", help="Destroy an existing stream") public String destroyStream(@CliOption(key={"","name"},help="the name of the stream to destroy",mandatory=true,optionContext="existing-stream disable-string-converter") String name)
@CliCommand(value="stream all destroy", help="Destroy all existing streams") public String destroyAllStreams(@CliOption(key="force",help="bypass confirmation prompt",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean force)
@CliCommand(value="stream validate", help="Verify that apps contained in the stream are valid.") public List<Object> validateStream(@CliOption(key={"","name"},help="the name of the stream to validate",mandatory=true,optionContext="existing-stream disable-string-converter") String name) throws OperationNotSupportedException
OperationNotSupportedException
protected StreamOperations streamOperations()
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.