code: @Override
      public void emitBatch(long batchId, TridentCollector collector)
      {
          try
          {
              checkDataFile(collector);
          }
          catch (Exception ex)
          {
              String logFormat = "Check file failed, skip batch. FilePath={0}";
              logger.warn(MessageFormat.format(logFormat, this.targetFile.getAbsolutePath()), ex);
          }
      }
docs: {@inheritDoc}