Class ClientReplayImpl

  • All Implemented Interfaces:
    java.lang.AutoCloseable, Client

    public class ClientReplayImpl
    extends ClientImpl
    • Constructor Detail

      • ClientReplayImpl

        public ClientReplayImpl​(Configuration conf,
                                HostAddress hostAddress,
                                java.util.concurrent.locks.ReentrantLock lock,
                                boolean skipPostCommands)
                         throws java.sql.SQLException
        Throws:
        java.sql.SQLException
    • Method Detail

      • sendQuery

        public int sendQuery​(ClientMessage message)
                      throws java.sql.SQLException
        Overrides:
        sendQuery in class ClientImpl
        Throws:
        java.sql.SQLException
      • execute

        public java.util.List<Completion> execute​(ClientMessage message,
                                                  Statement stmt,
                                                  int fetchSize,
                                                  long maxRows,
                                                  int resultSetConcurrency,
                                                  int resultSetType,
                                                  boolean closeOnCompletion)
                                           throws java.sql.SQLException
        Specified by:
        execute in interface Client
        Overrides:
        execute in class ClientImpl
        Throws:
        java.sql.SQLException
      • transactionReplay

        public void transactionReplay​(TransactionSaver transactionSaver)
                               throws java.sql.SQLException
        Throws:
        java.sql.SQLException