org.apache.nifi.registry.client.impl

Class JerseyBucketClient

java.lang.Object

org.apache.nifi.registry.client.impl.AbstractJerseyClient

org.apache.nifi.registry.client.impl.JerseyBucketClient

All Implemented Interfaces:

BucketClient

public class JerseyBucketClient
extends AbstractJerseyClient
implements BucketClient

Jersey implementation of BucketClient.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.nifi.registry.client.impl.AbstractJerseyClient

AbstractJerseyClient.NiFiRegistryAction<T>

Field Summary

Fields

Modifier and Type	Field and Description
private javax.ws.rs.client.WebTarget	bucketsTarget

Constructor Summary

Constructors

Constructor and Description
JerseyBucketClient(javax.ws.rs.client.WebTarget baseTarget)
JerseyBucketClient(javax.ws.rs.client.WebTarget baseTarget, Map<String,String> headers)

Method Summary

Modifier and Type	Method and Description
Bucket	create(Bucket bucket) Creates the given bucket.
Bucket	delete(String bucketId) Deletes the bucket with the given id.
Bucket	get(String bucketId) Gets the bucket with the given id.
List<Bucket>	getAll() Gets all buckets.
Fields	getFields() Gets the fields that can be used to sort/search buckets.
Bucket	update(Bucket bucket) Updates the given bucket.

Methods inherited from class org.apache.nifi.registry.client.impl.AbstractJerseyClient

executeAction, getHeaders, getIOExceptionCause, getRequestBuilder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

bucketsTarget

private final javax.ws.rs.client.WebTarget bucketsTarget

Constructor Detail

JerseyBucketClient

public JerseyBucketClient(javax.ws.rs.client.WebTarget baseTarget)

JerseyBucketClient

public JerseyBucketClient(javax.ws.rs.client.WebTarget baseTarget,
                          Map<String,String> headers)

Method Detail

create

public Bucket create(Bucket bucket)
              throws NiFiRegistryException,
                     IOException

Description copied from interface: BucketClient

Creates the given bucket.

Specified by:

create in interface BucketClient

Parameters:

bucket - the bucket to create

Returns:

the created bucket with containing identifier that was generated

Throws:

NiFiRegistryException

IOException

get

public Bucket get(String bucketId)
           throws NiFiRegistryException,
                  IOException

Description copied from interface: BucketClient

Gets the bucket with the given id.

Specified by:

get in interface BucketClient

Parameters:

bucketId - the id of the bucket to retrieve

Returns:

the bucket with the given id

Throws:

NiFiRegistryException

IOException

update

public Bucket update(Bucket bucket)
              throws NiFiRegistryException,
                     IOException

Description copied from interface: BucketClient

Updates the given bucket. Only the name and description can be updated.

Specified by:

update in interface BucketClient

Parameters:

bucket - the bucket with updates, must contain the id

Returns:

the updated bucket

Throws:

NiFiRegistryException

IOException

delete

public Bucket delete(String bucketId)
              throws NiFiRegistryException,
                     IOException

Description copied from interface: BucketClient

Deletes the bucket with the given id.

Specified by:

delete in interface BucketClient

Parameters:

bucketId - the id of the bucket to delete

Returns:

the deleted bucket

Throws:

NiFiRegistryException

IOException

getFields

public Fields getFields()
                 throws NiFiRegistryException,
                        IOException

Description copied from interface: BucketClient

Gets the fields that can be used to sort/search buckets.

Specified by:

getFields in interface BucketClient

Returns:

the bucket fields

Throws:

NiFiRegistryException

IOException

getAll

public List<Bucket> getAll()
                    throws NiFiRegistryException,
                           IOException

Description copied from interface: BucketClient

Gets all buckets.

Specified by:

getAll in interface BucketClient

Returns:

the list of all buckets

Throws:

NiFiRegistryException

IOException