This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package test; | |
import org.apache.commons.math.stat.descriptive.SummaryStatistics; | |
import org.openrdf.query.parser.sparql.SPARQLParser; | |
public class ParseTest { | |
public static void main(String[] args) throws Exception { | |
final String q = "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#>\n" + |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// some initialization which takes place in the constructor of the streamed | |
// protobug message writer | |
mBytes = new ByteArrayOutputStream((int)(64 * (1 << 10))); | |
coded = CodedOutputStream.newInstance(mBytes); | |
// then as protobuf messages come in, i append to the stream | |
// if the message puts us over the threshold of 64k, we write out what's in | |
// the buffer and start fresh | |
private void write(final MessageLite aObj) throws IOException { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// Copyright (c) 2010 - 2013, Clark & Parsia, LLC. <http://www.clarkparsia.com> | |
// For more information about licensing and copyright of this software, please contact | |
// inquiries@clarkparsia.com or visit http://stardog.com | |
package netty; | |
import java.io.ByteArrayInputStream; | |
import java.io.File; | |
import java.io.FileInputStream; | |
import java.io.FileNotFoundException; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package netty; | |
import io.netty.bootstrap.Bootstrap; | |
import io.netty.bootstrap.ServerBootstrap; | |
import io.netty.channel.Channel; | |
import io.netty.channel.ChannelFuture; | |
import io.netty.channel.ChannelHandlerContext; | |
import io.netty.channel.ChannelInboundHandlerAdapter; | |
import io.netty.channel.ChannelInitializer; | |
import io.netty.channel.EventLoopGroup; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public static final class ByteBufHttpOutputStream extends OutputStream { | |
/** | |
* The channel to which the {@link ByteBuf} objects are written | |
*/ | |
private final ChannelHandlerContext mChannelHandlerContext; | |
/** | |
* The {@link ByteBuf} to which data is currently being written | |
*/ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Override | |
public void channelRead0( | |
ChannelHandlerContext ctx, FullHttpRequest request) throws Exception { | |
if (!request.getDecoderResult().isSuccess()) { | |
sendError(ctx, BAD_REQUEST); | |
return; | |
} | |
if (request.getMethod() != GET) { | |
sendError(ctx, METHOD_NOT_ALLOWED); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// this is where we'll store our constraints | |
Sail aConstraints = new MemoryStore(); | |
aConstraints.initialize(); | |
// more specifically, we'll store them in a particular named graph | |
URI aConstraintGraph = Values.iri("urn:icv"); | |
// and here is our database. note this can be *any* type of Repository | |
Repository aRepo = new SailRepository(new MemoryStore()); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/** | |
* <p>This is the extension point for 17.6 (Extensible Value Testing) of the SPARQL spec.</p> | |
* | |
* <p>For implementations of Function to be visible to the query parser and engine, they must be registered | |
* via the JDK {@link java.util.ServiceLoader}. Create a file called | |
* {@code com.complexible.stardog.plan.filter.functions.Function} in the {@code META-INF/services} directory. | |
* The contents of this file should be all of the *fully-qualified* class names for the custom Functions. Then | |
* if a jar containing the {@code META-INF/services} directory and the implementations for the Functions is | |
* included on the classpath, Stardog will pick up the implementations on startup.</p> | |
* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
mhgrove:dist mhgrove$ cat input.nt | |
<urn:foo> <urn:bar> "literal". | |
mhgrove:dist mhgrove$ ./bin/stardog-admin db create -n foo -s input.nt | |
Bulk loading data to new database. | |
Parsing triples: 100% complete in 00:00:00 (1 triples - 0.2K triples/sec) | |
Parsing triples finished in 00:00:00.005 | |
Creating index: 100% complete in 00:00:00 (0.2K triples/sec) | |
Creating index finished in 00:00:00.005 | |
Computing statistics: 100% complete in 00:00:00 (0.2K triples/sec) | |
Computing statistics finished in 00:00:00.006 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
mhgrove:stardog-2.1.3 mhgrove$ ./bin/stardog-admin server start | |
mhgrove:stardog-2.1.3 mhgrove$ ./bin/stardog-admin db create -n describe | |
Creating index: 100% complete in 00:00:00 (0.0K triples/sec) | |
Creating index finished in 00:00:00.010 | |
Loading complete. | |
Inserted 0 triples in 00:00:00.082 at 0.0 triples/sec | |
Successfully created database 'describe'. | |
mhgrove:stardog-2.1.3 mhgrove$ ./bin/stardog data add --named-graph urn:context describe ~/Downloads/census-2011_qs103sc.ttl | |
Adding data from file: /Users/mhgrove/Downloads/census-2011_qs103sc.ttl |