public class GraphVertexReader extends SimpleHttpProvider implements StreamsPersistReader
Modifier and Type | Field and Description |
---|---|
protected GraphReaderConfiguration |
configuration |
static String |
STREAMS_ID |
httpclient, lock, providerQueue, uriBuilder
Constructor and Description |
---|
GraphVertexReader() |
GraphVertexReader(GraphReaderConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
String |
getId() |
List<com.fasterxml.jackson.databind.node.ObjectNode> |
parse(com.fasterxml.jackson.databind.JsonNode jsonNode) |
void |
prepare(Object configurationObject) |
StreamsResultSet |
readAll() |
cleanUp, execute, isRunning, newDatum, prepareHttpRequest, prepareParams, readCurrent, readNew, readRange, shutdownAndAwaitTermination, startStream
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
readNew, readRange
isRunning, readCurrent, startStream
cleanUp
public static final String STREAMS_ID
protected GraphReaderConfiguration configuration
public GraphVertexReader()
public GraphVertexReader(GraphReaderConfiguration configuration)
public List<com.fasterxml.jackson.databind.node.ObjectNode> parse(com.fasterxml.jackson.databind.JsonNode jsonNode)
parse
in class SimpleHttpProvider
public String getId()
getId
in interface StreamsOperation
getId
in class SimpleHttpProvider
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
prepare
in class SimpleHttpProvider
public StreamsResultSet readAll()
readAll
in interface StreamsPersistReader
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.