public class Processor extends Object
Modifier and Type | Field and Description |
---|---|
static int |
COUNT_COMMIT_MODE |
static int |
DEFAULT_COMMIT_MODE |
static int |
NEVER_COMMIT_MODE |
static int |
RELATIONAL_COMMIT_MODE |
static int |
TUPLE_COMMIT_MODE |
Modifier and Type | Method and Description |
---|---|
protected static AssociationIF |
addAssociation(TopicIF reifier,
Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static Object |
addEntity(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
addIdentities(AssociationIF assoc,
Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static TopicIF |
addIdentities(TopicIF topic,
Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
addOccurrence(TopicIF topic,
Relation relation,
Entity entity,
Field field,
int fieldIndex,
String[] tuple,
Context ctx) |
protected static void |
addPlayer(TopicIF topic,
Relation relation,
Entity entity,
Field field,
int fieldIndex,
String[] tuple,
Context ctx) |
static void |
addRelations(RelationMapping rmapping,
Collection<String> relnames,
TopicMapIF topicmap,
LocatorIF baseloc)
INTERNAL: Runs a DB2TM process by adding tuples to the topic map.
|
protected static void |
addScope(ScopedIF scoped,
String[] scope,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
addTopicName(TopicIF topic,
Relation relation,
Entity entity,
Field field,
int fieldIndex,
String[] tuple,
Context ctx) |
static void |
addTuple(Relation relation,
String[] tuple,
Context ctx) |
protected static void |
addTypes(TopicIF topic,
String[] types,
Entity entity,
String[] tuple,
Context ctx) |
protected static boolean |
checkCondition(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static boolean |
compareScope(String[] scope1,
Collection<TopicIF> scope2,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
deleteTopic(TopicIF topic) |
protected static AssociationIF |
findAssociationByIdentities(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static TopicIF |
findTopicByIdentities(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static List<OccurrenceIF> |
getOccurrences(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
protected static List<AssociationRoleIF> |
getPlayers(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
protected static List<TopicNameIF> |
getTopicNames(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
protected static void |
removeAssociation(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
removeEntity(Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
removeOccurrence(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
protected static void |
removePlayer(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
static void |
removeRelations(RelationMapping rmapping,
Collection<String> relnames,
TopicMapIF topicmap,
LocatorIF baseloc)
INTERNAL: Runs a DB2TM process by removing tuples from the topic map.
|
protected static void |
removeTopic(TopicIF topic,
Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
removeTopicName(TopicIF topic,
Relation relation,
Entity entity,
Field field,
String[] tuple,
Context ctx) |
static void |
removeTuple(Relation relation,
String[] tuple,
Context ctx) |
protected static void |
removeTypes(TopicIF topic,
String[] types,
Context ctx) |
static void |
synchronizeRelations(RelationMapping rmapping,
Collection<String> relnames,
TopicMapIF topicmap,
LocatorIF baseloc)
INTERNAL: Runs a DB2TM process by synchronizing the relations.
|
static void |
synchronizeRelations(RelationMapping rmapping,
Collection<String> relnames,
TopicMapIF topicmap,
LocatorIF baseloc,
boolean forceRescan) |
protected static TopicIF |
updateIdentities(TopicIF topic,
Relation relation,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
updateScope(ScopedIF scoped,
String[] scope,
Entity entity,
String[] tuple,
Context ctx) |
protected static void |
updateTypes(TopicIF topic,
String[] types,
Entity entity,
String[] tuple,
Context ctx) |
public static int NEVER_COMMIT_MODE
public static int RELATIONAL_COMMIT_MODE
public static int TUPLE_COMMIT_MODE
public static int COUNT_COMMIT_MODE
public static int DEFAULT_COMMIT_MODE
public static void addRelations(RelationMapping rmapping, Collection<String> relnames, TopicMapIF topicmap, LocatorIF baseloc)
public static void removeRelations(RelationMapping rmapping, Collection<String> relnames, TopicMapIF topicmap, LocatorIF baseloc)
protected static Object addEntity(Relation relation, Entity entity, String[] tuple, Context ctx)
protected static boolean checkCondition(Relation relation, Entity entity, String[] tuple, Context ctx)
protected static AssociationIF addAssociation(TopicIF reifier, Relation relation, Entity entity, String[] tuple, Context ctx)
protected static void removeEntity(Relation relation, Entity entity, String[] tuple, Context ctx)
protected static void removeTopic(TopicIF topic, Relation relation, Entity entity, String[] tuple, Context ctx)
protected static void deleteTopic(TopicIF topic)
protected static TopicIF findTopicByIdentities(Relation relation, Entity entity, String[] tuple, Context ctx)
protected static AssociationIF findAssociationByIdentities(Relation relation, Entity entity, String[] tuple, Context ctx)
protected static TopicIF addIdentities(TopicIF topic, Relation relation, Entity entity, String[] tuple, Context ctx)
protected static TopicIF updateIdentities(TopicIF topic, Relation relation, Entity entity, String[] tuple, Context ctx)
protected static void addIdentities(AssociationIF assoc, Relation relation, Entity entity, String[] tuple, Context ctx)
protected static void addTypes(TopicIF topic, String[] types, Entity entity, String[] tuple, Context ctx)
protected static void updateTypes(TopicIF topic, String[] types, Entity entity, String[] tuple, Context ctx)
protected static void addScope(ScopedIF scoped, String[] scope, Entity entity, String[] tuple, Context ctx)
protected static void updateScope(ScopedIF scoped, String[] scope, Entity entity, String[] tuple, Context ctx)
protected static boolean compareScope(String[] scope1, Collection<TopicIF> scope2, Entity entity, String[] tuple, Context ctx)
protected static void addTopicName(TopicIF topic, Relation relation, Entity entity, Field field, int fieldIndex, String[] tuple, Context ctx)
protected static List<TopicNameIF> getTopicNames(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void removeTopicName(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void addOccurrence(TopicIF topic, Relation relation, Entity entity, Field field, int fieldIndex, String[] tuple, Context ctx)
protected static List<OccurrenceIF> getOccurrences(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void removeOccurrence(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void addPlayer(TopicIF topic, Relation relation, Entity entity, Field field, int fieldIndex, String[] tuple, Context ctx)
protected static List<AssociationRoleIF> getPlayers(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void removePlayer(TopicIF topic, Relation relation, Entity entity, Field field, String[] tuple, Context ctx)
protected static void removeAssociation(Relation relation, Entity entity, String[] tuple, Context ctx)
public static void synchronizeRelations(RelationMapping rmapping, Collection<String> relnames, TopicMapIF topicmap, LocatorIF baseloc)
public static void synchronizeRelations(RelationMapping rmapping, Collection<String> relnames, TopicMapIF topicmap, LocatorIF baseloc, boolean forceRescan)