org.lumongo.storage.lucene

Class MongoDirectory

java.lang.Object

org.lumongo.storage.lucene.MongoDirectory

All Implemented Interfaces:

NosqlDirectory

public class MongoDirectory
extends java.lang.Object
implements NosqlDirectory

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BLOCK_NUMBER
static java.lang.String	BLOCK_SIZE
static java.lang.String	BLOCKS_SUFFIX
static java.lang.String	BYTES
static java.lang.String	COMPRESSED
static java.lang.String	COUNTER_SUFFIX
static int	DEFAULT_BLOCK_MAX
static int	DEFAULT_BLOCK_SIZE
static java.lang.String	FILE_NAME
static java.lang.String	FILE_NUMBER
static java.lang.String	FILES_SUFFIX
static java.lang.String	LAST_MODIFIED
static java.lang.String	LENGTH

Constructor Summary

Constructors

Constructor and Description
MongoDirectory(com.mongodb.MongoClient mongo, java.lang.String dbname, java.lang.String indexName)
MongoDirectory(com.mongodb.MongoClient mongo, java.lang.String dbname, java.lang.String indexName, boolean sharded, boolean compressed)
MongoDirectory(com.mongodb.MongoClient mongo, java.lang.String dbname, java.lang.String indexName, boolean sharded, boolean compressed, int blockSize)

Method Summary

Methods

Modifier and Type	Method and Description
static void	cacheBlock(MongoBlock mb)
void	deleteFile(NosqlFile nosqlFile)
static void	dropIndex(com.mongodb.MongoClient mongo, java.lang.String dbname, java.lang.String indexName) Removes an index from a database
MongoFile	fromDbObject(com.mongodb.DBObject dbObject)
com.mongodb.DBCollection	getBlocksCollection()
int	getBlockSize()
com.mongodb.DBCollection	getCounterCollection()
MongoFile	getFileHandle(java.lang.String fileName)
MongoFile	getFileHandle(java.lang.String filename, boolean createIfNotFound)
java.lang.String[]	getFileNames()
com.mongodb.DBCollection	getFilesCollection()
java.lang.String	getIndexName()
static void	removeBlock(MongoBlock mb)
static void	setMaxIndexBlocks(int blocks)
static com.mongodb.DBObject	toDbObject(NosqlFile nosqlFile)
java.lang.String	toString()
void	updateFileMetadata(NosqlFile nosqlFile)

Methods inherited from class java.lang.Object

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

Field Detail

BLOCK_SIZE

public static final java.lang.String BLOCK_SIZE

See Also:

Constant Field Values

BLOCK_NUMBER

public static final java.lang.String BLOCK_NUMBER

See Also:

Constant Field Values

LAST_MODIFIED

public static final java.lang.String LAST_MODIFIED

See Also:

Constant Field Values

LENGTH

public static final java.lang.String LENGTH

See Also:

Constant Field Values

FILE_NAME

public static final java.lang.String FILE_NAME

See Also:

Constant Field Values

FILE_NUMBER

public static final java.lang.String FILE_NUMBER

See Also:

Constant Field Values

COMPRESSED

public static final java.lang.String COMPRESSED

See Also:

Constant Field Values

BYTES

public static java.lang.String BYTES

FILES_SUFFIX

public static final java.lang.String FILES_SUFFIX

See Also:

Constant Field Values

BLOCKS_SUFFIX

public static final java.lang.String BLOCKS_SUFFIX

See Also:

Constant Field Values

COUNTER_SUFFIX

public static final java.lang.String COUNTER_SUFFIX

See Also:

Constant Field Values

DEFAULT_BLOCK_SIZE

public static final int DEFAULT_BLOCK_SIZE

See Also:

Constant Field Values

DEFAULT_BLOCK_MAX

public static final int DEFAULT_BLOCK_MAX

See Also:

Constant Field Values

Constructor Detail

MongoDirectory

public MongoDirectory(com.mongodb.MongoClient mongo,
              java.lang.String dbname,
              java.lang.String indexName)
               throws com.mongodb.MongoException,
                      java.io.IOException

Throws:

com.mongodb.MongoException

java.io.IOException

MongoDirectory

public MongoDirectory(com.mongodb.MongoClient mongo,
              java.lang.String dbname,
              java.lang.String indexName,
              boolean sharded,
              boolean compressed)
               throws com.mongodb.MongoException,
                      java.io.IOException

Throws:

com.mongodb.MongoException

java.io.IOException

MongoDirectory

public MongoDirectory(com.mongodb.MongoClient mongo,
              java.lang.String dbname,
              java.lang.String indexName,
              boolean sharded,
              boolean compressed,
              int blockSize)
               throws com.mongodb.MongoException,
                      java.io.IOException

Throws:

com.mongodb.MongoException

java.io.IOException

Method Detail

dropIndex

public static void dropIndex(com.mongodb.MongoClient mongo,
             java.lang.String dbname,
             java.lang.String indexName)

Removes an index from a database

Parameters:

mongo -

dbname -

indexName -

setMaxIndexBlocks

public static void setMaxIndexBlocks(int blocks)

cacheBlock

public static void cacheBlock(MongoBlock mb)

removeBlock

public static void removeBlock(MongoBlock mb)

getIndexName

public java.lang.String getIndexName()

getCounterCollection

public com.mongodb.DBCollection getCounterCollection()

getFilesCollection

public com.mongodb.DBCollection getFilesCollection()

getBlocksCollection

public com.mongodb.DBCollection getBlocksCollection()

getFileNames

public java.lang.String[] getFileNames()
                                throws java.io.IOException

Specified by:

getFileNames in interface NosqlDirectory

Throws:

java.io.IOException

getFileHandle

public MongoFile getFileHandle(java.lang.String fileName)
                        throws java.io.IOException

Specified by:

getFileHandle in interface NosqlDirectory

Throws:

java.io.IOException

getFileHandle

public MongoFile getFileHandle(java.lang.String filename,
                      boolean createIfNotFound)
                        throws java.io.IOException

Specified by:

getFileHandle in interface NosqlDirectory

Throws:

java.io.IOException

fromDbObject

public MongoFile fromDbObject(com.mongodb.DBObject dbObject)
                       throws java.io.IOException

Throws:

java.io.IOException

toDbObject

public static com.mongodb.DBObject toDbObject(NosqlFile nosqlFile)
                                       throws java.io.IOException

Throws:

java.io.IOException

getBlockSize

public int getBlockSize()

Specified by:

getBlockSize in interface NosqlDirectory

updateFileMetadata

public void updateFileMetadata(NosqlFile nosqlFile)
                        throws java.io.IOException

Specified by:

updateFileMetadata in interface NosqlDirectory

Throws:

java.io.IOException

deleteFile

public void deleteFile(NosqlFile nosqlFile)
                throws java.io.IOException

Specified by:

deleteFile in interface NosqlDirectory

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object