Package cz.o2.proxima.direct.client
Class Options
- java.lang.Object
-
- cz.o2.proxima.direct.client.Options
-
public class Options extends java.lang.ObjectClient related options.
-
-
Constructor Summary
Constructors Constructor Description Options()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.ExecutorgetExecutor()Executor to use for grpc.intgetFlushUsec()How often to flush the data in microseconds.intgetMaxFlushRecords()Maximal size of the bulk before being sent even before flushUsec.intgetMaxInflightRequests()Maximal count of inflight records.voidsetExecutor(java.util.concurrent.Executor executor)Executor to use for grpc.voidsetFlushUsec(int flushUsec)How often to flush the data in microseconds.voidsetMaxFlushRecords(int maxFlushRecords)Maximal size of the bulk before being sent even before flushUsec.voidsetMaxInflightRequests(int maxInflightRequests)Maximal count of inflight records.
-
-
-
Method Detail
-
getFlushUsec
public int getFlushUsec()
How often to flush the data in microseconds.
-
setFlushUsec
public void setFlushUsec(int flushUsec)
How often to flush the data in microseconds.
-
getMaxFlushRecords
public int getMaxFlushRecords()
Maximal size of the bulk before being sent even before flushUsec.
-
setMaxFlushRecords
public void setMaxFlushRecords(int maxFlushRecords)
Maximal size of the bulk before being sent even before flushUsec.
-
getExecutor
public java.util.concurrent.Executor getExecutor()
Executor to use for grpc.
-
setExecutor
public void setExecutor(java.util.concurrent.Executor executor)
Executor to use for grpc.
-
getMaxInflightRequests
public int getMaxInflightRequests()
Maximal count of inflight records.
-
setMaxInflightRequests
public void setMaxInflightRequests(int maxInflightRequests)
Maximal count of inflight records.
-
-