B C E G I L M N O P R S V W

B

buildDatum(Record) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

C

cleanUp() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

cleanUp() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistWriter

cleanUp() - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

client() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

client - Variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

client() - Method in class org.apache.streams.neo4j.http.Neo4jHttpClient

config - Variable in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

config() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

config - Variable in class org.apache.streams.neo4j.http.Neo4jHttpClient

config() - Method in class org.apache.streams.neo4j.http.Neo4jHttpClient

createActorObjectEdge(Activity) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

createActorObjectEdge.

createActorTargetEdge(Activity) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

createActorTargetEdge.

createEdgeStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

createVertexRequest(ActivityObject) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

createVertexRequest.

createVertexStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

CypherQueryGraphHelper - Class in org.apache.streams.neo4j

Supporting class for interacting with neo4j via rest API

CypherQueryGraphHelper() - Constructor for class org.apache.streams.neo4j.CypherQueryGraphHelper

E

edgeStatements(Activity) - Static method in class org.apache.streams.neo4j.Neo4jPersistUtil

executePost(HttpPost) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

G

getId() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

getId() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistWriter

getId() - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

getInstance(Neo4jConfiguration) - Static method in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

getInstance(Neo4jConfiguration) - Static method in class org.apache.streams.neo4j.http.Neo4jHttpClient

getLabels(ActivityObject) - Static method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getLabels.

getPersistQueue() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

getPropertyCreater(Map<String, Object>) - Static method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getPropertyCreater.

getPropertyParamSetter(Map<String, Object>, String) - Static method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getPropertyParamSetter.

getPropertyValueSetter(Map<String, Object>, String) - Static method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getPropertyValueSetter.

getVertexLongIdStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVertexRequest(String) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVertexRequest(Long) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVertexRequest.

getVertexStringIdStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVerticesLabelIdStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVerticesRequest(String) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

getVerticesRequest gets all vertices with a label.

I

isRunning() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

L

lock - Variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

lock - Variable in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

LOGGER - Static variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

M

mergeVertexRequest(ActivityObject) - Method in class org.apache.streams.neo4j.CypherQueryGraphHelper

mergeVertexRequest.

mergeVertexStatementTemplate - Static variable in class org.apache.streams.neo4j.CypherQueryGraphHelper

N

Neo4jBoltClient - Class in org.apache.streams.neo4j.bolt

Neo4jBoltPersistReader - Class in org.apache.streams.neo4j.bolt

Neo4jBoltPersistReader reads documents from neo4j.

Neo4jBoltPersistReader() - Constructor for class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

Neo4jBoltPersistReader constructor - resolves Neo4jReaderConfiguration from JVM 'neo4j'.

Neo4jBoltPersistReader(Neo4jReaderConfiguration) - Constructor for class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

Neo4jBoltPersistReader constructor - uses supplied Neo4jReaderConfiguration.

Neo4jBoltPersistReader.Neo4jBoltPersistReaderTask - Class in org.apache.streams.neo4j.bolt

Neo4jBoltPersistReaderTask(Neo4jBoltPersistReader) - Constructor for class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader.Neo4jBoltPersistReaderTask

Neo4jBoltPersistWriter - Class in org.apache.streams.neo4j.bolt

Created by sblackmon on 12/16/16.

Neo4jBoltPersistWriter(Neo4jConfiguration) - Constructor for class org.apache.streams.neo4j.bolt.Neo4jBoltPersistWriter

Neo4jHttpClient - Class in org.apache.streams.neo4j.http

Neo4jHttpGraphHelper - Class in org.apache.streams.neo4j.http

Supporting class for interacting with neo4j via rest API.

Neo4jHttpGraphHelper() - Constructor for class org.apache.streams.neo4j.http.Neo4jHttpGraphHelper

Neo4jHttpPersistReader - Class in org.apache.streams.neo4j.http

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

Neo4jHttpPersistReader() - Constructor for class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

GraphVertexReader constructor - resolve GraphReaderConfiguration from JVM 'graph'.

Neo4jHttpPersistReader(Neo4jReaderConfiguration) - Constructor for class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

GraphVertexReader constructor - use supplied GraphReaderConfiguration.

Neo4jHttpPersistWriter - Class in org.apache.streams.neo4j.http

Adds activityobjects as vertices and activities as edges to a graph database with an http rest endpoint (such as neo4j).

Neo4jHttpPersistWriter() - Constructor for class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

GraphHttpPersistWriter constructor - resolve GraphHttpConfiguration from JVM 'graph'.

Neo4jHttpPersistWriter(Neo4jConfiguration) - Constructor for class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

GraphHttpPersistWriter constructor - use supplied GraphHttpConfiguration.

Neo4jPersistUtil - Class in org.apache.streams.neo4j

Created by steve on 1/2/17.

Neo4jPersistUtil() - Constructor for class org.apache.streams.neo4j.Neo4jPersistUtil

O

org.apache.streams.neo4j - package org.apache.streams.neo4j

org.apache.streams.neo4j.bolt - package org.apache.streams.neo4j.bolt

org.apache.streams.neo4j.http - package org.apache.streams.neo4j.http

P

parse(JsonNode) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

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

persistQueue - Variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

prepare(Object) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

prepare(Object) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistWriter

prepare(Object) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

prepare(Object) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

prepareHttpRequest(URI) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

prepareHttpRequest

preparePayload(StreamsDatum) - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

prepareStatements(StreamsDatum) - Static method in class org.apache.streams.neo4j.Neo4jPersistUtil

R

readAll() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

readAll() - Method in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

readCurrent() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

readData(Pair<String, Map<String, Object>>) - Method in class org.apache.streams.neo4j.http.Neo4jHttpGraphHelper

readDataStatement neo4j rest json read data payload.

readNew(BigInteger) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

run() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader.Neo4jBoltPersistReaderTask

S

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

start() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

start() - Method in class org.apache.streams.neo4j.http.Neo4jHttpClient

startStream() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

statementResult - Variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

stop() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltClient

stop() - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

stop() - Method in class org.apache.streams.neo4j.http.Neo4jHttpClient

STREAMS_ID - Static variable in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

STREAMS_ID - Static variable in class org.apache.streams.neo4j.http.Neo4jHttpPersistReader

STREAMS_ID - Static variable in class org.apache.streams.neo4j.http.Neo4jHttpPersistWriter

V

vertexStatement(ActivityObject) - Static method in class org.apache.streams.neo4j.Neo4jPersistUtil

vertexStatements(Activity) - Static method in class org.apache.streams.neo4j.Neo4jPersistUtil

W

write(StreamsDatum) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

write(StreamsDatum) - Method in class org.apache.streams.neo4j.bolt.Neo4jBoltPersistWriter

writeData(Pair<String, Map<String, Object>>) - Method in class org.apache.streams.neo4j.http.Neo4jHttpGraphHelper

writeDataStatement neo4j rest json write data payload.

B C E G I L M N O P R S V W