Modifier and Type | Method and Description |
---|---|
DataflowDesc |
StatementAgentInstanceFactoryCreateDataflowResult.getDataflow() |
Modifier and Type | Method and Description |
---|---|
void |
StatementAgentInstanceFactoryCreateDataflow.setDataflow(DataflowDesc dataflow) |
Constructor and Description |
---|
StatementAgentInstanceFactoryCreateDataflowResult(Viewable finalView,
AgentInstanceStopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
DataflowDesc dataflow) |
Modifier and Type | Method and Description |
---|---|
DataflowDesc |
DataflowDeployment.getDataflow(String dataflowName) |
Modifier and Type | Method and Description |
---|---|
Map<String,DataflowDesc> |
DataflowDeployment.getDataflows() |
Modifier and Type | Method and Description |
---|---|
void |
DataflowDeployment.add(String dataflowName,
DataflowDesc metadata) |
void |
EPDataFlowServiceImpl.addDataflow(String deploymentId,
DataflowDesc dataflow) |
void |
EPDataFlowServiceImpl.removeDataflow(String deploymentId,
DataflowDesc dataflow) |
Constructor and Description |
---|
EPDataFlowInstanceImpl(Object dataFlowInstanceUserObject,
String dataFlowInstanceId,
OperatorStatisticsProvider statistics,
Map<Integer,Object> operators,
List<GraphSourceRunnable> sourceRunnables,
DataflowDesc dataflowDesc,
AgentInstanceContext agentInstanceContext,
EPDataFlowInstanceStatistics statisticsProvider,
Map<String,Object> parametersURIs) |
Modifier and Type | Method and Description |
---|---|
static EPDataFlowInstance |
DataflowInstantiator.instantiate(int agentInstanceId,
DataflowDesc dataflow,
EPDataFlowInstantiationOptions options) |
static OperatorStatisticsProvider |
DataflowInstantiatorHelper.realize(DataflowDesc dataflow,
Map<Integer,Object> operators,
List<LogicalChannelBinding> bindings,
DataFlowSignalManager dataFlowSignalManager,
EPDataFlowInstantiationOptions options,
AgentInstanceContext agentInstanceContext) |
Copyright © 2005–2018. All rights reserved.