com.lucidworks.apollo.pipeline

Class QuickstartBlobsRegistrar

java.lang.Object

com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar

com.lucidworks.apollo.pipeline.QuickstartBlobsRegistrar

public class QuickstartBlobsRegistrar
extends AbstractBlobsRegistrar

load the quickstart blobs

Nested Class Summary

Nested classes/interfaces inherited from class com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar

AbstractBlobsRegistrar.BiConsumer<T,U>, AbstractBlobsRegistrar.Supplier<T>

Constructor Summary

Constructors

Constructor and Description
QuickstartBlobsRegistrar()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.String>	getBlobData()
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

Methods inherited from class com.lucidworks.apollo.pipeline.AbstractBlobsRegistrar

init

Methods inherited from class java.lang.Object

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

Constructor Detail

QuickstartBlobsRegistrar

public QuickstartBlobsRegistrar()

Method Detail

init

@WhenReady
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

Description copied from class: AbstractBlobsRegistrar

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

Overrides:

init in class AbstractBlobsRegistrar

Throws:

java.lang.Exception

com.lucidworks.apollo.common.error.RESTError

getBlobLink

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

Specified by:

getBlobLink in class AbstractBlobsRegistrar

getLockZnode

public java.lang.String getLockZnode()

Overrides:

getLockZnode in class AbstractBlobsRegistrar

getBlobData

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

Specified by:

getBlobData in class AbstractBlobsRegistrar