org.apache.streams.neo4j.http

Class Neo4jHttpPersistReader

java.lang.Object

org.apache.streams.components.http.provider.SimpleHttpProvider

org.apache.streams.neo4j.http.Neo4jHttpPersistReader

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsPersistReader, StreamsProvider

public class Neo4jHttpPersistReader
extends SimpleHttpProvider
implements StreamsPersistReader

Reads a stream of activityobjects from vertices in a graph database with an http rest endpoint (such as neo4j).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	STREAMS_ID

Fields inherited from class org.apache.streams.components.http.provider.SimpleHttpProvider

configuration, httpclient, lock, providerQueue, uriBuilder

Constructor Summary

Constructors

Constructor and Description
Neo4jHttpPersistReader() GraphVertexReader constructor - resolve GraphReaderConfiguration from JVM 'graph'.
Neo4jHttpPersistReader(Neo4jReaderConfiguration configuration) GraphVertexReader constructor - use supplied GraphReaderConfiguration.

Method Summary

Modifier and Type	Method and Description
String	getId()
List<com.fasterxml.jackson.databind.node.ObjectNode>	parse(com.fasterxml.jackson.databind.JsonNode jsonNode) Neo API query returns something like this: { "columns": [ "v" ], "data": [ [ { "data": { props }, etc...
void	prepare(Object configurationObject)
org.apache.http.client.methods.HttpRequestBase	prepareHttpRequest(URI uri) prepareHttpRequest
StreamsResultSet	readAll()

Methods inherited from class org.apache.streams.components.http.provider.SimpleHttpProvider

cleanUp, isRunning, prepareParams, readCurrent, readNew, readRange, shutdownAndAwaitTermination, startStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.streams.core.StreamsPersistReader

readNew, readRange

Methods inherited from interface org.apache.streams.core.StreamsProvider

isRunning, readCurrent, startStream

Methods inherited from interface org.apache.streams.core.StreamsOperation

cleanUp

Field Detail

STREAMS_ID

public static final String STREAMS_ID

Constructor Detail

Neo4jHttpPersistReader

public Neo4jHttpPersistReader()

GraphVertexReader constructor - resolve GraphReaderConfiguration from JVM 'graph'.

Neo4jHttpPersistReader

public Neo4jHttpPersistReader(Neo4jReaderConfiguration configuration)

GraphVertexReader constructor - use supplied GraphReaderConfiguration.

Parameters:

configuration - GraphReaderConfiguration

Method Detail

prepareHttpRequest

public org.apache.http.client.methods.HttpRequestBase prepareHttpRequest(URI uri)

prepareHttpRequest

Overrides:

prepareHttpRequest in class SimpleHttpProvider

Parameters:

uri - uri

Returns:

result

parse

public List<com.fasterxml.jackson.databind.node.ObjectNode> parse(com.fasterxml.jackson.databind.JsonNode jsonNode)

Neo API query returns something like this: { "columns": [ "v" ], "data": [ [ { "data": { props }, etc... } ], [ { "data": { props }, etc... } ] ] }

Overrides:

parse in class SimpleHttpProvider

Parameters:

jsonNode - jsonNode

Returns:

result

getId

public String getId()

Specified by:

getId in interface StreamsOperation

Overrides:

getId in class SimpleHttpProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

Overrides:

prepare in class SimpleHttpProvider

readAll

public StreamsResultSet readAll()

Specified by:

readAll in interface StreamsPersistReader