[
https://issues.apache.org/jira/browse/SQOOP-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Veena Basavaraj updated SQOOP-2035:
-----------------------------------
Summary: Sqoop2: KiteConnector From side need to send BigDecimal for
decimal type and JODA for date type in Object array (was: Sqoop2:
KiteConnector need to send BigDecimal for decimal type and JODA for date type
in Object array)
> Sqoop2: KiteConnector From side need to send BigDecimal for decimal type and
> JODA for date type in Object array
> ----------------------------------------------------------------------------------------------------------------
>
> Key: SQOOP-2035
> URL: https://issues.apache.org/jira/browse/SQOOP-2035
> Project: Sqoop
> Issue Type: Bug
> Reporter: Veena Basavaraj
> Assignee: Qian Xu
> Fix For: 1.99.6
>
>
> At this point, we do not see the Kite Connector sending BigDecimal for
> objects that are Sqoop Decimal type, as we prescribe JODA for date objects,
> we need BigDecimal for decimal objects.
> code to be fixed
> {code}
> @Override
> public void extract(ExtractorContext context, LinkConfiguration linkConfig,
> FromJobConfiguration fromJobConfig, KiteDatasetPartition partition) {
> String uri = partition.getUri();
> LOG.info("Loading data from " + uri);
> KiteDatasetExecutor executor = getExecutor(uri);
> DataWriter writer = context.getDataWriter();
> Object[] array;
> rowsRead = 0L;
> try {
> while ((array = executor.readRecord()) != null) {
> // TODO: SQOOP-1616 will cover more column data types. Use schema and
> do data type conversion (e.g. datatime).
> writer.writeArrayRecord(array);
> rowsRead++;
> }
> } finally {
> executor.closeReader();
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
