code: @Override
      public void write(final IBucket pBucket) throws TTIOException, TTByteHandleException {
          try {
              // writer.write(pBucket.getBucketKey() + "," + pBucket.getClass().getName() + "\n");
              // writer.flush();
              //
              // writeCounter++;
              // long time = System.currentTimeMillis();
              new WriteTask(pBucket).call();
              // writeTime = writeTime + System.currentTimeMillis() - time;
              // Future<Long> task = mWriterCompletion.submit(new WriteTask(pBucket));
              // mRunningWriteTasks.put(pBucket.getBucketKey(), task);
              // mReader.mCache.put(pBucket.getBucketKey(), pBucket);
          } catch (final Exception exc) {
              throw new TTIOException(exc);
          }
      }
docs: {@inheritDoc}