com.lucidworks.apollo.pipeline

Class AbstractBlobsRegistrar

java.lang.Object

com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar

Direct Known Subclasses:

AutocompleteBlobsLoader, QuickstartBlobsRegistrar

public abstract class AbstractBlobsRegistrar
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractBlobsRegistrar.BiConsumer<T,U> I want a BiConcumer that WILL yield a RESTError for my lambdas
static interface	AbstractBlobsRegistrar.Supplier<T> i want a Supplier like interface that WILL yield a RESTError for my lambdas

Constructor Summary

Constructors

Constructor and Description
AbstractBlobsRegistrar()

Method Summary

Modifier and Type	Method and Description
abstract java.util.Map<java.lang.String,java.lang.String>	getBlobData()
abstract com.lucidworks.apollo.links.Link	getBlobLink(com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar.BlobToUpload blob)
java.lang.String	getLockZnode()
void	init(CuratorComponent curatorComponent, com.lucidworks.apollo.client.resources.BlobClientResource blobClientResource, com.lucidworks.apollo.links.LinkManager linkManager) initialize the blob store with blobs while using zookeeper curator as a lock mechanism
void	init(com.lucidworks.apollo.client.FusionClient fusionClient, com.lucidworks.apollo.links.LinkManager linkManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractBlobsRegistrar

public AbstractBlobsRegistrar()

Method Detail

getLockZnode

public java.lang.String getLockZnode()

init

public void init(CuratorComponent curatorComponent,
                 com.lucidworks.apollo.client.resources.BlobClientResource blobClientResource,
                 com.lucidworks.apollo.links.LinkManager linkManager)
          throws java.lang.Exception,
                 com.lucidworks.apollo.common.error.RESTError

initialize the blob store with blobs while using zookeeper curator as a lock mechanism

Parameters:

curatorComponent -

blobClientResource -

linkManager -

Throws:

java.lang.Exception

com.lucidworks.apollo.common.error.RESTError

init

public void init(com.lucidworks.apollo.client.FusionClient fusionClient,
                 com.lucidworks.apollo.links.LinkManager linkManager)
          throws com.lucidworks.apollo.common.error.RESTError

Throws:

com.lucidworks.apollo.common.error.RESTError

getBlobLink

public abstract com.lucidworks.apollo.links.Link getBlobLink(com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar.BlobToUpload blob)

getBlobData

public abstract java.util.Map<java.lang.String,java.lang.String> getBlobData()