Package org.openrdf.query.algebra.evaluation

Examples of org.openrdf.query.algebra.evaluation.TripleSource

126
127
128
129
130
131
132
133
134
135
136
      if (!isAutoCommit()) {
        snapshot++;
        readMode = ReadMode.TRANSACTION;
      }

      TripleSource tripleSource = new MemTripleSource(includeInferred, snapshot, readMode);
      EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, query);

      QueryOptimizerList optimizerList = new QueryOptimizerList();
      optimizerList.add(new BindingAssigner());
      optimizerList.add(new ConstantOptimizer(strategy));
View Full Code Here
260
261
262
263
264
265
266
267
268
269
  }

  public Cursor<? extends BindingSet> evaluate(QueryModel query, BindingSet bindings, boolean includeInferred)
    throws StoreException
  {
    TripleSource tripleSource = new FederationTripleSource(includeInferred);
    EvaluationStrategyImpl strategy = new FederationStrategy(federation.getExecutor(), tripleSource, query, includeInferred);
    query = optimize(query, bindings, strategy);
    return strategy.evaluate(query, EmptyBindingSet.getInstance());
  }
View Full Code Here
117
118
119
120
121
122
123
124
125
    Cursor<BindingSet> result = expr.evaluate(dataset, bindings, includeInferred);
    if (result != null) {
      return result;
    }
    QueryModel query = createQueryModel(expr);
    TripleSource source = new RepositoryTripleSource(expr.getOwner());
    EvaluationStrategyImpl eval = new FederationStrategy(executor, source, query, includeInferred);
    return eval.evaluate(query, bindings);
  }
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
    protected CloseableIteration<? extends BindingSet, QueryEvaluationException> evaluateInternal(final TupleExpr query,
                                                                                                  final Dataset dataset,
                                                                                                  final BindingSet bindings,
                                                                                                  final boolean includeInferred) throws SailException {
        try {
            TripleSource tripleSource = new SailConnectionTripleSource(this, context.valueFactory, includeInferred);
            EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);
            return strategy.evaluate(query, bindings);
        } catch (QueryEvaluationException e) {
            throw new SailException(e);
        }
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    public CloseableIteration<? extends BindingSet, QueryEvaluationException> evaluateInternal(TupleExpr tupleExpr,
                                                                                               final Dataset dataset,
                                                                                               final BindingSet bindings,
                                                                                               final boolean includeInferred) throws SailException {
        try {
            TripleSource tripleSource = new SailConnectionTripleSource(this, store.valueFactory, includeInferred);
            EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);
            return strategy.evaluate(tupleExpr, bindings);
        } catch (QueryEvaluationException e) {
            throw new SailException(e);
        }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
      if (transactionActive()) {
        snapshot++;
        readMode = ReadMode.TRANSACTION;
      }

      TripleSource tripleSource = new MemTripleSource(includeInferred, snapshot, readMode);
      EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);

      QueryOptimizerList optimizerList = new QueryOptimizerList();
      optimizerList.add(new BindingAssigner());
      optimizerList.add(new ConstantOptimizer(strategy));
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    Lock readLock = nativeStore.getReadLock();

    try {
      replaceValues(tupleExpr);

      TripleSource tripleSource = new NativeTripleSource(nativeStore, includeInferred, transactionActive());
      EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);

      QueryOptimizerList optimizerList = new QueryOptimizerList();
      optimizerList.add(new BindingAssigner());
      optimizerList.add(new ConstantOptimizer(strategy));
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
            final TupleExpr query,
            final Dataset dataset,
            final BindingSet bindings,
            final boolean includeInferred) throws SailException {
        try {
            TripleSource tripleSource = new SailConnectionTripleSource(this, valueFactory, includeInferred);
            EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);
            return strategy.evaluate(query, bindings);
        } catch (QueryEvaluationException e) {
            throw new SailException(e);
        }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
            final BindingSet bindings,
            final boolean includeInferred)
            throws SailException {
        // Decompose queries into getStatements operations so we can dereference URIs.
        try {
            TripleSource tripleSource = new SailConnectionTripleSource(this, valueFactory, includeInferred);
            EvaluationStrategyImpl strategy = new EvaluationStrategyImpl(tripleSource, dataset);

            return strategy.evaluate(tupleExpr, bindings);
        } catch (QueryEvaluationException e) {
            throw new SailException(e);
View Full Code Here
TOP

Related Classes of org.openrdf.query.algebra.evaluation.TripleSource

  • com.tinkerpop.blueprints.oupls.sail.GraphSailConnection
  • com.tinkerpop.blueprints.oupls.sail.pg.PropertyGraphSailConnection
  • net.fortytwo.linkeddata.sail.LinkedDataSailConnection
  • net.fortytwo.ripple.sail.RippleSailConnection
  • org.openrdf.sail.federation.evaluation.FederationStrategy
  • org.openrdf.sail.federation.FederationConnection
  • org.openrdf.sail.memory.MemoryStoreConnection
  • org.openrdf.sail.nativerdf.NativeStoreConnection
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.