@Test public void columnFamily() { assertEquals(S_POC, _cut.tripleStoreColumnFamily(_pattern____)); assertEquals(S_POC, _cut.tripleStoreColumnFamily(_pattern_sp_)); assertEquals(PO_SC, _cut.tripleStoreColumnFamily(_pattern__po)); assertEquals(O_SPC, _cut.tripleStoreColumnFamily(_pattern_s_o)); assertEquals(PO_SC, _cut.tripleStoreColumnFamily(_pattern__p_)); assertEquals(S_POC, _cut.tripleStoreColumnFamily(_pattern_s__)); assertEquals(O_SPC, _cut.tripleStoreColumnFamily(_pattern___o)); assertEquals(O_SPC, _cut.tripleStoreColumnFamily(_pattern_spo)); }
String tripleStoreColumnFamily(final byte[][] q) { if (!isVariable(q[0])) { if (!isVariable(q[2])) { return O_SPC; } else { return S_POC; } } if (!isVariable(q[2])) { if (!isVariable(q[1])) { return PO_SC; } else { return O_SPC; } } if (!isVariable(q[1])) { return PO_SC; } return S_POC; }
Cassandra12xTripleIndexDAO implements TripleIndexDAO { String tripleStoreColumnFamily(final byte[][] q) { if (!isVariable(q[0])) { if (!isVariable(q[2])) { return O_SPC; } else { return S_POC; } } if (!isVariable(q[2])) { if (!isVariable(q[1])) { return PO_SC; } else { return O_SPC; } } if (!isVariable(q[1])) { return PO_SC; } return S_POC; } }
Cassandra12xTripleIndexDAO implements TripleIndexDAO { String tripleStoreColumnFamily(final byte[][] q) { if (!isVariable(q[0])) { if (!isVariable(q[2])) { return O_SPC; } else { return S_POC; } } if (!isVariable(q[2])) { if (!isVariable(q[1])) { return PO_SC; } else { return O_SPC; } } if (!isVariable(q[1])) { return PO_SC; } return S_POC; } Cassandra12xTripleIndexDAO(final DataAccessLayerFactory factory, final ITopLevelDictionary dictionary); }
Cassandra12xTripleIndexDAO implements TripleIndexDAO { String tripleStoreColumnFamily(final byte[][] q) { if (!isVariable(q[0])) { if (!isVariable(q[2])) { return O_SPC; } else { return S_POC; } } if (!isVariable(q[2])) { if (!isVariable(q[1])) { return PO_SC; } else { return O_SPC; } } if (!isVariable(q[1])) { return PO_SC; } return S_POC; } Cassandra12xTripleIndexDAO(final DataAccessLayerFactory factory, final ITopLevelDictionary dictionary); @Override void clear(); @Override void close(); @Override Iterator<byte[][]> dateRangeQuery(
			final Value[] query, 
			final long lowerBound, 
			final boolean equalsLower,
			final long upperBound, 
			final boolean equalsUpper,
			final boolean reverse, 
			final int limit); @Override List<byte[][]> deleteTriples(
			final Iterator<byte[][]> nodes, 
			final int batchSize, 
			final boolean rangesEnabled); @Override void executePendingMutations(); @Override void initialiseRdfIndex(); @Override void insertRanges(final byte[][] ids, final double value); @Override void insertRanges(final byte[][] ids, final long value); @Override void insertTriple(final byte[][] ids); @Override Iterator<byte[][]> numericRangeQuery(
			final Value[] query, 
			final double lowerBound, 
			final boolean equalsLower,
			final double upperBound, 
			final boolean equalsUpper,
			final boolean reverse, 
			final int limit); @SuppressWarnings("unchecked") @Override Iterator<byte[][]> query(final byte[][] query, final int limit); }
Cassandra12xTripleIndexDAO implements TripleIndexDAO { String tripleStoreColumnFamily(final byte[][] q) { if (!isVariable(q[0])) { if (!isVariable(q[2])) { return O_SPC; } else { return S_POC; } } if (!isVariable(q[2])) { if (!isVariable(q[1])) { return PO_SC; } else { return O_SPC; } } if (!isVariable(q[1])) { return PO_SC; } return S_POC; } Cassandra12xTripleIndexDAO(final DataAccessLayerFactory factory, final ITopLevelDictionary dictionary); @Override void clear(); @Override void close(); @Override Iterator<byte[][]> dateRangeQuery(
			final Value[] query, 
			final long lowerBound, 
			final boolean equalsLower,
			final long upperBound, 
			final boolean equalsUpper,
			final boolean reverse, 
			final int limit); @Override List<byte[][]> deleteTriples(
			final Iterator<byte[][]> nodes, 
			final int batchSize, 
			final boolean rangesEnabled); @Override void executePendingMutations(); @Override void initialiseRdfIndex(); @Override void insertRanges(final byte[][] ids, final double value); @Override void insertRanges(final byte[][] ids, final long value); @Override void insertTriple(final byte[][] ids); @Override Iterator<byte[][]> numericRangeQuery(
			final Value[] query, 
			final double lowerBound, 
			final boolean equalsLower,
			final double upperBound, 
			final boolean equalsUpper,
			final boolean reverse, 
			final int limit); @SuppressWarnings("unchecked") @Override Iterator<byte[][]> query(final byte[][] query, final int limit);  }