docs: @Override
      public void putNext(Tuple t) throws IOException {
          pigTuple.setTuple(t);
  
          if (trace) {
              log.trace("Writing out tuple " + t);
          }
          try {
              writer.write(null, pigTuple);
          } catch (InterruptedException ex) {
              throw new EsHadoopIllegalArgumentException("interrupted", ex);
          }
      }