Skip to content
This repository was archived by the owner on Jul 9, 2021. It is now read-only.
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 9 additions & 0 deletions src/java/org/apache/sqoop/manager/OracleManager.java
Original file line number Diff line number Diff line change
Expand Up @@ -455,6 +455,15 @@ public void importTable(
super.importTable(context);
}

@Override
public void importQuery(com.cloudera.sqoop.manager.ImportJobContext context)
throws IOException, ImportException {
context.setConnManager(this);
// Specify the Oracle-specific DBInputFormat for import.
context.setInputFormat(OracleDataDrivenDBInputFormat.class);
super.importQuery(context);
}

/**
* Export data stored in HDFS into a table in a database.
*/
Expand Down