Class Options


  • public class Options
    extends java.lang.Object
    Client related options.
    • Constructor Summary

      Constructors 
      Constructor Description
      Options()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.concurrent.Executor getExecutor()
      Executor to use for grpc.
      int getFlushUsec()
      How often to flush the data in microseconds.
      int getMaxFlushRecords()
      Maximal size of the bulk before being sent even before flushUsec.
      int getMaxInflightRequests()
      Maximal count of inflight records.
      void setExecutor​(java.util.concurrent.Executor executor)
      Executor to use for grpc.
      void setFlushUsec​(int flushUsec)
      How often to flush the data in microseconds.
      void setMaxFlushRecords​(int maxFlushRecords)
      Maximal size of the bulk before being sent even before flushUsec.
      void setMaxInflightRequests​(int maxInflightRequests)
      Maximal count of inflight records.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • Options

        public Options()
    • 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.