Uses of Class
org.apache.jena.riot.system.AsyncParserBuilder
Packages that use AsyncParserBuilder
-
Uses of AsyncParserBuilder in org.apache.jena.riot.system
Methods in org.apache.jena.riot.system that return AsyncParserBuilderModifier and TypeMethodDescriptionAsyncParserBuilder.mutateSources(Consumer<RDFParserBuilder> mutator) Run an operation on all RDFParserBuilder sources in this builder.static AsyncParserBuilderAsyncParser.of(InputStream input, Lang lang, String baseURI) Create anAsyncParserBuilderfrom an input stream.static AsyncParserBuilderCreate anAsyncParserBuilderfrom a file or URL.static AsyncParserBuilderAsyncParser.of(RDFParserBuilder source) Create anAsyncParserBuilderfrom anRDFParserBuilder.static AsyncParserBuilderAsyncParser.ofLocations(List<String> filesOrURLs) Create anAsyncParserBuilderfrom a set of files and/or URLs.static AsyncParserBuilderAsyncParser.ofSources(List<RDFParserBuilder> sources) Create anAsyncParserBuilderfrom a set ofRDFParserBuilderinstances.AsyncParserBuilder.setChunkSize(int chunkSize) The chunk size controls the maxmimum number of elements the parser thread transfers at once to the client iterator's queue.AsyncParserBuilder.setDaemonMode(boolean daemonMode) Whether the parser thread should run as a daemon thread.AsyncParserBuilder.setPrematureDispatch(Predicate<EltStreamRDF> prematureDispatch) Set a custom dispatch (flush) policy: When the predicate returns true for an element then that element and any gathered data is dispatched immediately.AsyncParserBuilder.setQueueSize(int queueSize) The queue size controls the number of chunks the parser thread can read ahead.AsyncParserBuilder.setSources(List<RDFParserBuilder> sources)