public class GemFireCQSource extends AbstractModuleFixture<GemFireCQSource>
label| Constructor and Description |
|---|
GemFireCQSource(java.lang.String query)
Create a Gemfire Sink module.
|
| Modifier and Type | Method and Description |
|---|---|
GemFireCQSource |
host(java.lang.String host)
Set the host name
|
GemFireCQSource |
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 |
GemFireCQSource |
useLocator(boolean useLocator)
Set the host and port to reference a Gemfire locator instead of a server node.
|
label, toStringpublic GemFireCQSource(java.lang.String query)
query - the OQL query string.public GemFireCQSource useLocator(boolean useLocator)
useLocator - true if using a locator. Default is false.public GemFireCQSource host(java.lang.String host)
host - the host. Default is localhostpublic GemFireCQSource port(int port)
port - the portprotected java.lang.String toDSL()
AbstractModuleFixturefile --dir=xxxx --name=yyyytoDSL in class AbstractModuleFixture<GemFireCQSource>