public class GemFireServerSink extends AbstractModuleFixture<GemFireServerSink>
label| Constructor and Description |
|---|
GemFireServerSink(java.lang.String region)
Create a Gemfire Sink module.
|
| Modifier and Type | Method and Description |
|---|---|
GemFireServerSink |
host(java.lang.String host)
Set the host name
|
GemFireServerSink |
json(boolean json)
Configure this to use GemFire JSON representation, i.e., create a gemfire-json-server sink.
|
GemFireServerSink |
keyExpression(java.lang.String keyExpression)
Set the cache key.
|
GemFireServerSink |
port(int port)
Set the gemfire server port.
|
protected java.lang.String |
toDSL()
Returns a representation of the module suitable for inclusion in a stream definition, e.g.
file --dir=xxxx --name=yyyy |
GemFireServerSink |
useLocator(boolean useLocator)
Set the host and port to reference a Gemfire locator instead of a server node.
|
label, toStringpublic GemFireServerSink(java.lang.String region)
region - the name of the region to use for this stream. The region must exist on the server.public GemFireServerSink json(boolean json)
json - true if using gemfire-json-server, false for gemfire-server.public GemFireServerSink useLocator(boolean useLocator)
useLocator - true if using a locator. Default is false.public GemFireServerSink host(java.lang.String host)
host - the host. Default is localhostpublic GemFireServerSink port(int port)
port - the portpublic GemFireServerSink keyExpression(java.lang.String keyExpression)
keyExpression - a SpEL expression evaluating the payloadprotected java.lang.String toDSL()
AbstractModuleFixturefile --dir=xxxx --name=yyyytoDSL in class AbstractModuleFixture<GemFireServerSink>