B C E G H I L M N O P R S T 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

CypherQueryResponse - Class in org.apache.streams.neo4j

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

E

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

equals(Object) - Method in class org.apache.streams.neo4j.CypherQueryResponse

equals(Object) - Method in class org.apache.streams.neo4j.ItemData

equals(Object) - Method in class org.apache.streams.neo4j.ItemMetadata

equals(Object) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

equals(Object) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

equals(Object) - Method in class org.apache.streams.neo4j.Params

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

G

getAdditionalProperties() - Method in class org.apache.streams.neo4j.CypherQueryResponse

getAdditionalProperties() - Method in class org.apache.streams.neo4j.ItemData

getAdditionalProperties() - Method in class org.apache.streams.neo4j.ItemMetadata

getAdditionalProperties() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

getAdditionalProperties() - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

getAdditionalProperties() - Method in class org.apache.streams.neo4j.Params

getColumns() - Method in class org.apache.streams.neo4j.CypherQueryResponse

getData() - Method in class org.apache.streams.neo4j.CypherQueryResponse

getData() - Method in class org.apache.streams.neo4j.ItemMetadata

getHosts() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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.

getParams() - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

getPassword() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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

getPort() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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.

getQuery() - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

(Required)

getScheme() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

getUsername() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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.

H

hashCode() - Method in class org.apache.streams.neo4j.CypherQueryResponse

hashCode() - Method in class org.apache.streams.neo4j.ItemData

hashCode() - Method in class org.apache.streams.neo4j.ItemMetadata

hashCode() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

hashCode() - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

hashCode() - Method in class org.apache.streams.neo4j.Params

I

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

ItemData - Class in org.apache.streams.neo4j

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

ItemMetadata - Class in org.apache.streams.neo4j

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

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(Queue<StreamsDatum>) - Constructor for class org.apache.streams.neo4j.bolt.Neo4jBoltPersistReader

Neo4jBoltPersistReader constructor - uses supplied persistQueue.

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

Neo4jConfiguration - Class in org.apache.streams.neo4j

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

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

Neo4jReaderConfiguration - Class in org.apache.streams.neo4j

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

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

Params - Class in org.apache.streams.neo4j

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

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

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.CypherQueryResponse

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.ItemData

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.ItemMetadata

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Params

setColumns(List<String>) - Method in class org.apache.streams.neo4j.CypherQueryResponse

setData(List<List<List<ItemMetadata>>>) - Method in class org.apache.streams.neo4j.CypherQueryResponse

setData(ItemData) - Method in class org.apache.streams.neo4j.ItemMetadata

setHosts(List<String>) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

setParams(Params) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

setPassword(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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

setPort(Long) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

setQuery(String) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

(Required)

setScheme(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

setUsername(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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

T

toString() - Method in class org.apache.streams.neo4j.CypherQueryResponse

toString() - Method in class org.apache.streams.neo4j.ItemData

toString() - Method in class org.apache.streams.neo4j.ItemMetadata

toString() - Method in class org.apache.streams.neo4j.Neo4jConfiguration

toString() - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

toString() - Method in class org.apache.streams.neo4j.Params

V

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

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

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.CypherQueryResponse

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.ItemData

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.ItemMetadata

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.neo4j.Params

withColumns(List<String>) - Method in class org.apache.streams.neo4j.CypherQueryResponse

withData(List<List<List<ItemMetadata>>>) - Method in class org.apache.streams.neo4j.CypherQueryResponse

withData(ItemData) - Method in class org.apache.streams.neo4j.ItemMetadata

withHosts(List<String>) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

withParams(Params) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

withPassword(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

withPort(Long) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

withQuery(String) - Method in class org.apache.streams.neo4j.Neo4jReaderConfiguration

withScheme(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

withUsername(String) - Method in class org.apache.streams.neo4j.Neo4jConfiguration

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 H I L M N O P R S T V W