Index (streams-persist-neo4j 0.5-incubating API)

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