Package | Description |
---|---|
org.semarglproject.sink | |
org.semarglproject.source |
Modifier and Type | Class and Description |
---|---|
class |
Pipe<S extends DataSink>
Base class for pipeline procecessing blocks with one source and one sink.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CharSink
Interface for handling events from
CharSource |
interface |
QuadSink
Interface for quad consuming
|
interface |
TripleSink
Interface for triple consuming.
|
interface |
XmlSink
Sink interface for streaming XML processors.
|
Modifier and Type | Class and Description |
---|---|
class |
CharOutputSink
Implementation of
CharSink . |
class |
Pipe<S extends DataSink>
Base class for pipeline procecessing blocks with one source and one sink.
|
Modifier and Type | Field and Description |
---|---|
protected S |
Pipe.sink |
Modifier and Type | Method and Description |
---|---|
protected static org.semarglproject.source.AbstractSource |
BaseStreamProcessor.createSourceForSink(DataSink sink)
Creates source appropriate for specified sink.
|
Constructor and Description |
---|
StreamProcessor(DataSink sink)
Instantiates stream processor for pipe starting with specified sink.
|
Copyright © 2012–2013. All rights reserved.