docs: public void initialize(
              final int clusterIndex,
              final long siteId,
              final int partitionId,
              final int sitesPerHost,
              final int hostId,
              final String hostname,
              final int drClusterId,
              final int defaultDrBufferSize,
              final long tempTableMemory,
              final HashinatorConfig hashinatorConfig,
              final boolean createDrReplicatedStream,
              final long exportFlushTimeout)
      {
          synchronized(printLockObject) {
              System.out.println("Initializing an IPC EE " + this + " for hostId " + hostId + " siteId " + siteId + " from thread " + Thread.currentThread().getId());
          }
          int result = ExecutionEngine.ERRORCODE_ERROR;
          m_data.clear();
          m_data.putInt(Commands.Initialize.m_id);
          m_data.putInt(clusterIndex);
          m_data.putLong(siteId);
          m_data.putInt(partitionId);
          m_data.putInt(sitesPerHost);
          m_data.putInt(hostId);
          m_data.putInt(drClusterId);
          m_data.putInt(defaultDrBufferSize);
          m_data.putLong(EELoggers.getLogLevels());
          m_data.putLong(tempTableMemory);
          m_data.putInt(createDrReplicatedStream ? 1 : 0);
          m_data.putInt((short)hostname.length());
          m_data.put(hostname.getBytes(Charsets.UTF_8));
          try {
              m_data.flip();
              m_connection.write();
              result = m_connection.readStatusByte();
          } catch (final IOException e) {
              System.out.println("Exception: " + e.getMessage());
              throw new RuntimeException(e);
          }
          checkErrorCode(result);
          updateHashinator(hashinatorConfig);
      }