public static class ManagedResourceStorage.ZooKeeperStorageIO extends Object implements ManagedResourceStorage.StorageIO
Modifier and Type | Field and Description |
---|---|
protected boolean |
retryOnConnLoss |
protected SolrZkClient |
zkClient |
protected String |
znodeBase |
Constructor and Description |
---|
ManagedResourceStorage.ZooKeeperStorageIO(SolrZkClient zkClient,
String znodeBase) |
Modifier and Type | Method and Description |
---|---|
void |
configure(SolrResourceLoader loader,
NamedList<String> initArgs) |
boolean |
delete(String storedResourceId) |
boolean |
exists(String storedResourceId) |
String |
getInfo() |
protected String |
getZnodeForResource(String storedResourceId)
Returns the Znode for the given storedResourceId by combining it
with the znode base.
|
InputStream |
openInputStream(String storedResourceId) |
OutputStream |
openOutputStream(String storedResourceId) |
protected SolrZkClient zkClient
protected String znodeBase
protected boolean retryOnConnLoss
public ManagedResourceStorage.ZooKeeperStorageIO(SolrZkClient zkClient, String znodeBase)
public void configure(SolrResourceLoader loader, NamedList<String> initArgs) throws SolrException
configure
in interface ManagedResourceStorage.StorageIO
SolrException
public boolean exists(String storedResourceId) throws IOException
exists
in interface ManagedResourceStorage.StorageIO
IOException
public InputStream openInputStream(String storedResourceId) throws IOException
openInputStream
in interface ManagedResourceStorage.StorageIO
IOException
public OutputStream openOutputStream(String storedResourceId) throws IOException
openOutputStream
in interface ManagedResourceStorage.StorageIO
IOException
protected String getZnodeForResource(String storedResourceId)
public boolean delete(String storedResourceId) throws IOException
delete
in interface ManagedResourceStorage.StorageIO
IOException
public String getInfo()
getInfo
in interface ManagedResourceStorage.StorageIO
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.