| Methods Summary |
|---|
| private com.google.gdata.data.BaseEntry | buildEntryFromLuceneDocument(org.apache.lucene.document.Document doc, org.apache.lucene.gdata.server.registry.ProvidedService config)
Reader reader = new StringReader(doc.getField(StorageEntryWrapper.FIELD_CONTENT).stringValue());
BaseEntry entry = GDataEntityBuilder.buildEntry(reader, config);
entry.setVersionId(doc.getField(StorageEntryWrapper.FIELD_VERSION).stringValue());
return entry;
|
| private com.google.gdata.data.BaseFeed | buildFeedFromLuceneDocument(org.apache.lucene.document.Document doc, org.apache.lucene.gdata.server.registry.ProvidedService config)
Reader reader = new StringReader(doc.getField(StorageFeedWrapper.FIELD_CONTENT).stringValue());
return GDataEntityBuilder.buildFeed(reader, config);
|
| protected boolean | checkEntryVersion(java.lang.String id, java.lang.String feedId, int version)
if (LOG.isDebugEnabled())
LOG.debug("Checking entry version for entryid " + id + " feedid: "
+ feedId + " version: " + version);
StorageEntryWrapper wrapper = this.buffer.getEntry(id, feedId);
if (wrapper != null)
return wrapper.getVersion() == version;
Hits h = storageQuery(id);
if (h.length() < 1)
return false;
Document doc = h.doc(0);
String fieldValue = null;
try {
fieldValue = doc.getField(StorageEntryWrapper.FIELD_VERSION)
.stringValue();
int storedVersion = Integer.parseInt(fieldValue);
if(LOG.isDebugEnabled())
LOG.debug("StoredEntry has version "+storedVersion +" return compare result");
return storedVersion == version;
} catch (Exception e) {
LOG.error("Entry has no parable Version id or field is not set -- "
+ fieldValue);
}
return false;
|
| public void | close()Closes all resources used in the {@link StorageQuery}. The instance can
not be reused after invoking this method.
this.searcher.close();
this.buffer.close();
|
| public java.util.List | entryQuery(java.util.List entryIds, java.lang.String feedId, org.apache.lucene.gdata.server.registry.ProvidedService config)Fetches the requested entries from the storage. The given list contains
entry id's to be looked up in the storage. First the {@link StorageBuffer}
will be queried for the entry id's. If not all of the entries remain in
the buffer the underlying lucene index will be searched. The entries are
not guaranteed to be in the same order as they are in the given id list.
Entry ID's not found in the index or the buffer will be omitted.
The entries will be searched in a feed context specified by the given
feed ID
List<BaseEntry> resultList = new ArrayList<BaseEntry>(entryIds.size());
List<String> searchList = new ArrayList<String>(entryIds.size());
for (String entry : entryIds) {
StorageEntryWrapper bufferedEntry = this.buffer.getEntry(entry,
feedId);
if (bufferedEntry != null) {
resultList.add(bufferedEntry.getEntry());
} else
searchList.add(entry);
}
if (searchList.isEmpty())
return resultList;
Hits hits = storageQuery(searchList);
Iterator hitIterator = hits.iterator();
while (hitIterator.hasNext()) {
Hit hit = (Hit) hitIterator.next();
Document doc = hit.getDocument();
BaseEntry entry = buildEntryFromLuceneDocument(doc, config);
resultList.add(entry);
}
return resultList;
|
| public java.lang.String | getAccountNameForFeedId(java.lang.String feedId)Looks up the account reference for the given feed id
Hits h = storageFeedQuery(feedId);
if (h.length() == 0)
return null;
Document doc = h.doc(0);
return doc.get(StorageFeedWrapper.FIELD_ACCOUNTREFERENCE);
|
| protected long | getEntryLastModified(java.lang.String entryId, java.lang.String feedId)
StorageEntryWrapper wrapper = this.buffer.getEntry(entryId, feedId);
if (wrapper != null)
return wrapper.getTimestamp();
Hits h = storageQuery(entryId);
if (h.length() > 0)
try {
return Long.parseLong(h.doc(0).get(
StorageEntryWrapper.FIELD_TIMESTAMP));
} catch (Exception e) {
LOG.warn("Can not parse timestamp from entry -- "
+ h.doc(0).get(StorageEntryWrapper.FIELD_TIMESTAMP));
}
else
throw new StorageException("Entry not found");
return 0;
|
| protected long | getFeedLastModified(java.lang.String feedId)
Long bufferedTime = this.buffer.getFeedLastModified(feedId);
if (bufferedTime != null)
return bufferedTime;
Hits entryHits = storageFeedQuery(feedId, this.timeStampSort);
if (entryHits.length() > 0) {
try {
return Long.parseLong(entryHits.doc(0).getField(
StorageEntryWrapper.FIELD_TIMESTAMP).stringValue());
} catch (Exception e) {
LOG.warn("Can not parse timestamp from entry -- "
+ entryHits.doc(0).get(
StorageEntryWrapper.FIELD_TIMESTAMP));
}
}
return 0;
|
| public com.google.gdata.data.BaseFeed | getLatestFeedQuery(java.lang.String feedId, int resultCount, int startIndex, org.apache.lucene.gdata.server.registry.ProvidedService config)This method fetches the latest feed entries from the storage. Feed
usually requested via a search query or as a simple query to the REST
interface.
The REST interface requests all the entries from a Storage. The Storage
retrieves the entries corresponding to the parameters specified. This
method first requests the latest entries or updated entries from the
{@link StorageBuffer}. If the buffer already contains enough entries
for the the specified result count the entries will be returned. If not,
the underlying lucene index will be searcher for all documents of the
specified feed sorted by storing timestamp desc.
The entries will be searched in a feed context specified by the given
feed ID
DateTime updated = null;
Hits feedHits = storageFeedQuery(feedId);
if (feedHits.length() == 0)
return null;
BaseFeed retVal = buildFeedFromLuceneDocument(feedHits.doc(0), config);
List<BaseEntry> returnList = new ArrayList<BaseEntry>(resultCount);
List<StorageEntryWrapper> bufferedWrapperList = this.buffer
.getSortedEntries(feedId);
int alreadyAdded = 0;
int offset = startIndex - 1;
if (bufferedWrapperList != null
&& bufferedWrapperList.size() >= startIndex) {
updated = bufferedWrapperList.get(0).getEntry().getUpdated();
for (; alreadyAdded < resultCount; alreadyAdded++) {
if ((bufferedWrapperList.size() - offset) > 0) {
StorageEntryWrapper wrappedEntry = bufferedWrapperList
.get(offset++);
returnList.add(wrappedEntry.getEntry());
} else
break;
}
// reset offset
offset = startIndex - 1;
if (alreadyAdded == resultCount) {
retVal.getEntries().addAll(returnList);
retVal.setUpdated(updated);
return retVal;
}
} else {
/*
* if the buffer size is less than the start index the buffer size must
* be considered. Sublists would not be a repeatable read part of
* the whole list
*/
if (bufferedWrapperList != null)
offset = startIndex - 1 - bufferedWrapperList.size();
}
Hits hits = storageFeedQuery(feedId, this.timeStampSort);
if (hits.length() > 0) {
for (; (offset < hits.length()) && (alreadyAdded < resultCount); offset++, alreadyAdded++) {
Document doc = hits.doc(offset);
BaseEntry entry = buildEntryFromLuceneDocument(doc, config);
returnList.add(entry);
}
if (updated == null) {
try {
long updatedTimeStamp = Long.parseLong(hits.doc(0).get(
StorageEntryWrapper.FIELD_TIMESTAMP));
updated = new DateTime(updatedTimeStamp);
} catch (Exception e) {
LOG.warn("could not create DateTime -- " + e.getMessage(),
e);
updated = buildEntryFromLuceneDocument(hits.doc(0), config)
.getUpdated();
}
}
}
retVal.setUpdated(updated);
retVal.getEntries().addAll(returnList);
return retVal;
|
| public java.lang.String | getService(java.lang.String feedID)Looks up the feed type for the given feed ID
Hits hits = storageFeedQuery(feedID);
if (hits.length() <= 0)
return null;
Document doc = hits.doc(0);
String feedType = doc.get(StorageFeedWrapper.FIELD_SERVICE_ID);
return feedType;
|
| public org.apache.lucene.gdata.data.GDataAccount | getUser(java.lang.String username)Queries the storage for an user instance
if (username == null)
return null;
TermQuery query = new TermQuery(new Term(
StorageAccountWrapper.FIELD_ACCOUNTNAME, username));
Hits h = this.searcher.search(query);
if (h.length() == 0)
return null;
return StorageAccountWrapper.buildEntity(h.doc(0));
|
| protected boolean | isEntryStored(java.lang.String entryId, java.lang.String feedId)
if (LOG.isDebugEnabled())
LOG.debug("Checking isEntryStored for entryid " + entryId
+ " feedid: " + feedId);
if (this.buffer.getEntry(entryId, feedId) != null)
return true;
Hits h = storageQuery(entryId);
if (h.length() > 0)
return true;
return false;
|
| public boolean | isFeedStored(java.lang.String feedId)Checks whether a feed for the given feedID is stored
Hits h = storageFeedQuery(feedId);
return (h.length() > 0);
|
| public com.google.gdata.data.BaseEntry | singleEntryQuery(java.lang.String entryId, java.lang.String feedId, org.apache.lucene.gdata.server.registry.ProvidedService config)This method retrieves a single entry from the storage. If the
{@link StorageBuffer} does not contain the requested entry the
underlying storage index will be searched.
The Entry will be searched in a feed context specified by the given feed
ID
StorageEntryWrapper wrapper = this.buffer.getEntry(entryId, feedId);
if (wrapper == null) {
Hits hits = storageQuery(entryId);
if (hits.length() <= 0)
return null;
Document doc = hits.doc(0);
return buildEntryFromLuceneDocument(doc, config);
}
/*
* ServerBaseEntry enables the dynamic element of the entry like the
* links to be dynamic. BufferedEntries will be reused until they are
* written.
*/
return wrapper.getEntry();
|
| private org.apache.lucene.search.Hits | storageFeedQuery(java.lang.String feedId)
TermQuery query = new TermQuery(new Term(
StorageFeedWrapper.FIELD_FEED_ID, feedId));
return this.searcher.search(query);
|
| private org.apache.lucene.search.Hits | storageFeedQuery(java.lang.String feedId, org.apache.lucene.search.Sort sort)
TermQuery query = new TermQuery(new Term(
StorageEntryWrapper.FIELD_FEED_REFERENCE, feedId));
return this.searcher.search(query, new ModifiedEntryFilter(this.buffer
.getExculdList(),StorageEntryWrapper.FIELD_ENTRY_ID), sort);
|
| private org.apache.lucene.search.Hits | storageQuery(java.util.List entryId)
BooleanQuery query = new BooleanQuery();
/*
* query the index using a BooleanQuery
*/
for (String id : entryId) {
TermQuery termQuery = new TermQuery(new Term(
StorageEntryWrapper.FIELD_ENTRY_ID, id));
// use an OR query
query.add(new BooleanClause(termQuery, Occur.SHOULD));
}
return this.searcher.search(query, new ModifiedEntryFilter(this.buffer
.getExculdList(),StorageEntryWrapper.FIELD_ENTRY_ID));
|
| private org.apache.lucene.search.Hits | storageQuery(java.lang.String entryId)
TermQuery termQuery = new TermQuery(new Term(
StorageEntryWrapper.FIELD_ENTRY_ID, entryId));
/*
* Filter entries inside the buffer, buffered entries might contain
* deleted entries. These entries must be found!!
*/
return this.searcher.search(termQuery, new ModifiedEntryFilter(
this.buffer.getExculdList(),StorageEntryWrapper.FIELD_ENTRY_ID));
|
