org.springframework.xd.greenplum.gpfdist

Class GPFDistServer

java.lang.Object

org.springframework.xd.greenplum.gpfdist.GPFDistServer

public class GPFDistServer
extends java.lang.Object

Constructor Summary

Constructors

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)

Method Summary

Methods

Modifier and Type	Method and Description
int	getLocalPort()
reactor.io.net.http.HttpServer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GPFDistServer

public GPFDistServer(org.reactivestreams.Processor<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> processor,
             int port,
             int flushCount,
             int flushTime,
             int batchTimeout,
             int batchCount)

Method Detail

start

public reactor.io.net.http.HttpServer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> start()
                                                                                        throws java.lang.Exception

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Throws:

java.lang.Exception

getLocalPort

public int getLocalPort()