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 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
protected java.lang.String	indexName
protected short	indexNumber
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)
MongoDirectory(com.mongodb.MongoClient mongo, java.lang.String ddName, java.lang.String indexName, boolean sharded, int blockSize)

Method Summary

Modifier and Type	Method and Description
void	close()
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	fromDocument(org.bson.Document document)
com.mongodb.client.MongoCollection<org.bson.Document>	getBlocksCollection()
int	getBlockSize()
MongoFile	getFileHandle(java.lang.String fileName)
MongoFile	getFileHandle(java.lang.String filename, boolean createIfNotFound)
java.lang.String[]	getFileNames()
com.mongodb.client.MongoCollection<org.bson.Document>	getFilesCollection()
java.lang.String	getIndexName()
void	rename(java.lang.String source, java.lang.String dest)
static void	setMaxIndexBlocks(int blocks)
static org.bson.Document	toDocument(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

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

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

indexName

protected final java.lang.String indexName

indexNumber

protected final short indexNumber

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)
               throws com.mongodb.MongoException,
                      java.io.IOException

Throws:

com.mongodb.MongoException

java.io.IOException

MongoDirectory

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

Throws:

com.mongodb.MongoException

java.io.IOException

Method Detail

setMaxIndexBlocks

public static void setMaxIndexBlocks(int blocks)

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 -

getIndexName

public java.lang.String getIndexName()

getFilesCollection

public com.mongodb.client.MongoCollection<org.bson.Document> getFilesCollection()

getBlocksCollection

public com.mongodb.client.MongoCollection<org.bson.Document> 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

fromDocument

public MongoFile fromDocument(org.bson.Document document)
                       throws java.io.IOException

Throws:

java.io.IOException

toDocument

public static org.bson.Document toDocument(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

close

public void close()

Specified by:

close in interface NosqlDirectory

rename

public void rename(java.lang.String source,
                   java.lang.String dest)
            throws java.io.IOException

Specified by:

rename in interface NosqlDirectory

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object