public class Stream extends Object
Stream stream = Stream.builder(dataflowOperations).definition("time | log").create().deploy();
A fluent style that separates source, processor and sink parts can also be used via
Stream stream = Stream.builder(dataflowOperations).source("time").sink("log").create().deploy();
Modifier and Type | Class and Description |
---|---|
static class |
Stream.ProcessorBuilder |
static class |
Stream.SinkBuilder |
static class |
Stream.SourceBuilder |
static class |
Stream.StreamDefinitionBuilder |
static class |
Stream.StreamNameBuilder |
Modifier and Type | Method and Description |
---|---|
static StreamBuilder |
builder(DataFlowOperations client)
Fluent API method to create a
StreamBuilder . |
void |
destroy()
Destroy the stream from the server.
|
String |
getStatus() |
StreamDefinition |
undeploy()
Undeploy the current
Stream . |
public static StreamBuilder builder(DataFlowOperations client)
StreamBuilder
.client
- DataFlowOperations
client instancepublic StreamDefinition undeploy()
Stream
. This method invokes the remote serverStreamDefinition
so one can invoke other builder operations such as StreamDefinition.deploy()
public void destroy()
public String getStatus()
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.