class DatabaseJoin extends BaseTransform<DatabaseJoinMeta, DatabaseJoinData> implements ITransform<DatabaseJoinMeta, DatabaseJoinData> {

  public synchronized void stopRunning() throws HopException {
    if ( this.isStopped() || data.isDisposed() ) {
      return;
    }

    if ( data.db != null && data.db.getConnection() != null && !data.isCanceled ) {
      data.db.cancelStatement( data.pstmt );
      setStopped( true );
      data.isCanceled = true;
    }
  }

  public  DatabaseJoin( TransformMeta transformMeta, DatabaseJoinMeta meta, DatabaseJoinData data, int copyNr, PipelineMeta pipelineMeta, Pipeline pipeline );

}