public class GraphHttpPersistWriter extends SimpleHTTPPostPersistWriter
Modifier and Type | Field and Description |
---|---|
protected GraphHttpConfiguration |
configuration |
protected HttpGraphHelper |
httpGraphHelper |
protected ReadWriteLock |
lock |
protected QueryGraphHelper |
queryGraphHelper |
static String |
STREAMS_ID |
authHeader, httpclient, uriBuilder
Constructor and Description |
---|
GraphHttpPersistWriter() |
GraphHttpPersistWriter(GraphHttpConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp() |
protected com.fasterxml.jackson.databind.node.ObjectNode |
executePost(org.apache.http.client.methods.HttpPost httpPost) |
void |
prepare(Object configurationObject) |
protected com.fasterxml.jackson.databind.node.ObjectNode |
preparePayload(StreamsDatum entry) |
getId, prepareHttpPost, prepareParams, prepareURI, write
public static final String STREAMS_ID
protected GraphHttpConfiguration configuration
protected QueryGraphHelper queryGraphHelper
protected HttpGraphHelper httpGraphHelper
protected final ReadWriteLock lock
public GraphHttpPersistWriter()
public GraphHttpPersistWriter(GraphHttpConfiguration configuration)
protected com.fasterxml.jackson.databind.node.ObjectNode preparePayload(StreamsDatum entry) throws Exception
preparePayload
in class SimpleHTTPPostPersistWriter
Exception
protected com.fasterxml.jackson.databind.node.ObjectNode executePost(org.apache.http.client.methods.HttpPost httpPost)
executePost
in class SimpleHTTPPostPersistWriter
public void prepare(Object configurationObject)
prepare
in interface StreamsOperation
prepare
in class SimpleHTTPPostPersistWriter
public void cleanUp()
cleanUp
in interface StreamsOperation
cleanUp
in class SimpleHTTPPostPersistWriter
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.