public class MongoClientConnector extends Object
Constructor and Description |
---|
MongoClientConnector(com.mongodb.MongoClient client,
String db) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
ensureIndexes(AddIndexData addIndexData) |
com.mongodb.DBCollection |
getCollection(String collectionName) |
com.mongodb.DB |
getConnection() |
Collection<SpaceTypeDescriptor> |
getSortedTypes() |
void |
introduceType(IntroduceTypeData introduceTypeData) |
void |
introduceType(SpaceTypeDescriptor typeDescriptor) |
Collection<SpaceTypeDescriptor> |
loadMetadata() |
void |
performBatch(DataSyncOperation[] operations) |
void |
performBatch(List<BatchUnit> rows) |
public MongoClientConnector(com.mongodb.MongoClient client, String db)
public void close() throws IOException
IOException
public void introduceType(IntroduceTypeData introduceTypeData)
public void introduceType(SpaceTypeDescriptor typeDescriptor)
public com.mongodb.DB getConnection()
public com.mongodb.DBCollection getCollection(String collectionName)
public void performBatch(DataSyncOperation[] operations)
public Collection<SpaceTypeDescriptor> loadMetadata()
public Collection<SpaceTypeDescriptor> getSortedTypes()
public void ensureIndexes(AddIndexData addIndexData)
Copyright © GigaSpaces.