public class GpfdistServer extends Object
Constructor and Description |
---|
GpfdistServer(org.reactivestreams.Processor<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> processor,
int port,
int flushCount,
int flushTime,
int batchTimeout,
int batchCount)
Instantiates a new gpfdist server.
|
Modifier and Type | Method and Description |
---|---|
int |
getLocalPort()
Gets the local port.
|
reactor.io.net.http.HttpServer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> |
start()
Start a server.
|
void |
stop()
Stop a server.
|
public GpfdistServer(org.reactivestreams.Processor<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> processor, int port, int flushCount, int flushTime, int batchTimeout, int batchCount)
processor
- the processorport
- the portflushCount
- the flush countflushTime
- the flush timebatchTimeout
- the batch timeoutbatchCount
- the batch countCopyright © 2016 Pivotal Software, Inc.. All rights reserved.