public interface FlowClient
| Modifier and Type | Method and Description |
|---|---|
VersionedFlow |
create(VersionedFlow flow)
Create the given flow in the given bucket.
|
VersionedFlow |
delete(String bucketId,
String flowId)
Deletes the flow with the given id in the given bucket.
|
VersionedFlowDifference |
diff(String bucketId,
String flowId,
Integer versionA,
Integer versionB) |
VersionedFlow |
get(String flowId)
Gets the flow with the given id.
|
VersionedFlow |
get(String bucketId,
String flowId)
Gets the flow with the given id in the given bucket.
|
List<VersionedFlow> |
getByBucket(String bucketId)
Gets the flows for a given bucket.
|
Fields |
getFields()
Gets the field info for flows.
|
VersionedFlow |
update(String bucketId,
VersionedFlow flow)
Updates the given flow with in the given bucket.
|
VersionedFlow create(VersionedFlow flow) throws NiFiRegistryException, IOException
flow - the flow to createNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredVersionedFlow get(String bucketId, String flowId) throws NiFiRegistryException, IOException
bucketId - a bucket idflowId - a flow idNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredVersionedFlow get(String flowId) throws NiFiRegistryException, IOException
flowId - a flow idNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredVersionedFlow update(String bucketId, VersionedFlow flow) throws NiFiRegistryException, IOException
bucketId - a bucket idflow - the flow with updatesNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredVersionedFlow delete(String bucketId, String flowId) throws NiFiRegistryException, IOException
bucketId - a bucket idflowId - the id of the flow to deleteNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredFields getFields() throws NiFiRegistryException, IOException
NiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredList<VersionedFlow> getByBucket(String bucketId) throws NiFiRegistryException, IOException
bucketId - a bucket idNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredVersionedFlowDifference diff(String bucketId, String flowId, Integer versionA, Integer versionB) throws NiFiRegistryException, IOException
bucketId - a bucket idflowId - the flow that is under inspectionversionA - the first version to use in the comparisonversionB - the second flow to use in the comparisonNiFiRegistryException - if an error is encountered other than IOExceptionIOException - if an I/O error is encounteredCopyright © 2018 Apache NiFi Project. All rights reserved.