{@inheritDoc}

@see com.taobao.tddl.dbsync.binlog.LogFetcher#close()
765069
public void close() throws IOException {
        try {
            if (conn != null) conn.close();

            conn = null;
            mysqlInput = null;
            mysqlOutput = null;
        } catch (SQLException e) {
            logger.warn("Unable to close connection", e);
        }
    }
95652
@Override
  public void close() throws IOException {
    super.close();
    if (fs != null) {
      try {
        fs.close();
        fs = null;
      } catch(IOException ie) {
        //this might already be closed, ignore
      }
    }
    if (cacheFs != null) {
      try {
        cacheFs.close();
        cacheFs = null;
      } catch(IOException ie) {
        //this might already be closed, ignore
      }
    }
  }
193544
@Override
	public void close() throws IOException {
		if (this.client != null)
			this.client.close();
		indexCache.clear();
		indexCache = null;
		updatePolicy = null;
		insertPolicy = null;
		infoPolicy = null;
		queryPolicy = null;
		moduleCache.clear();
		moduleCache = null;
	}
1145934
@Override
    public void close() throws IOException {
        try {
            if (reference != null) {
                closer.close(reference);
            }
        } catch (Exception e) {
            throw new IOException(e);
        } finally {
            this.wasClosed = true;
        }
    }
159353
@Override
    public void close() throws IOException {
        super.close();
        if (entity != null) {

            entity.close();
        }
        if (snapshot != null) snapshot.close();
    }
1096137
@Override
    public void close() {
        if (this.closed.compareAndSet(false, true)) {
            this.connector.close();
            log.info("{}: Closed.", this.traceObjectId);
        }
    }
698756
@Override
	public void close() {
		try {
			sortAndReduce();
		} catch (Exception e) {
			throw new ExceptionInChainedStubException(this.taskName, e);
		}

		this.outputCollector.close();
	}
275761
@Override
    public void close() throws IOException {
        debug(String.format("close jar provider loader for: %s", pluginJar));
        synchronized (this) {
            closed = true;
        }
        if (null != cachedJar) {
            cachedJar.close();
            classCache.clear();
            cachedJar = null;
        }
    }
629310
@Override
    public void close() {
        if (trainingArchive != null && trainingArchive != weightsArchive) {
            trainingArchive.close();
            trainingArchive = null;
        }
        if (weightsArchive != null) {
            weightsArchive.close();
            weightsArchive = null;
        }
    }
195340
public void close() throws IOException {
        if (!_closed) {
            try {
                flush();
            } catch (Throwable t) {
                LOG.debug(t.getMessage(), t);
            }
            _closed = true;
            super.close();
        }
    }
18553
@Override
    public void close()
    {
        isOpen.set(false);
        Iterator<Future<?>> iterator = futures.iterator();
        while ( iterator.hasNext() )
        {
            Future<?> future = iterator.next();
            iterator.remove();
            if ( !future.isDone() && !future.isCancelled() && !future.cancel(true) )
            {
                log.warn("Could not cancel " + future);
            }
        }
        if (shutdownOnClose) {
            executorService.shutdownNow();
        }
    }
50062
public synchronized void close()
	{
		if (s != null) {
			super.close();
			try {
				s.close();
			}
			catch (final IOException e) {}
			s = null;
		}
	}
544369
@Override
    public void close() {
        if (!this.closed.getAndSet(true)) {
            closeIndices(null, false); // This will close all registered indices, without cleaning the cache.
            this.cache.close();
            log.info("{}: Closed.", this.traceObjectId);
        }
    }
539159
@Override
    public void close() {
        if (!this.closed.get()) {
            Futures.await(Services.stopAsync(this, this.executor));
            log.info("{}: Closed.", this.traceObjectId);
            this.closed.set(true);
        }
    }
871936
public void close() {
		stopFetching = true;
		if(rowFetcher != null)
			rowFetcher.interrupt();
		try {
			results.close();
		} catch (OWLException e) {
			// TODO: Handle this in a reasonable manner
			System.out.println(e);
		}
	}
788140
@Override
    public void close() {
        if (!this.closed.getAndSet(true)) {
            closeAllIndices(false); // Do not individually clear the cache; we are wiping it anyway when closing it.
            this.cache.close();
            log.info("{}: Closed.", this.traceObjectId);
        }
    }
412431
@Override
	public void close() {
		try {
			sortAndCombine();
		} catch (Exception e) {
			throw new ExceptionInChainedStubException(this.taskName, e);
		}

		this.outputCollector.close();
	}