apex-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shubham Pathak <shub...@datatorrent.com>
Subject Re: CsvFormatter schema for enum property
Date Tue, 19 Jul 2016 06:46:48 GMT
Hello,

Created JIRA's to track above requirement.
https://issues.apache.org/jira/browse/APEXMALHAR-2159
https://issues.apache.org/jira/browse/APEXMALHAR-2160

Thanks,
Shubham

On Tue, Jul 19, 2016 at 9:57 AM, Shubham Pathak <shubham@datatorrent.com>
wrote:

> Hello Yogi,
>
> Enum type is not supported in CSV Formatter.
> Currently, only following types are supported
> BOOLEAN, DOUBLE, INTEGER, FLOAT, LONG, SHORT, CHARACTER, STRING, DATE
>
> Thanks,
> Shubham
>
> On Mon, Jul 18, 2016 at 5:57 PM, Yogi Devendra <yogidevendra@apache.org>
> wrote:
>
>>
>> Hi,
>>
>> We have a java object which has a enum field. We wish to send these
>> objects to CSVFormatter.
>> What should I specify for "type" of this field?
>>
>> For example,
>>
>> My Java Object is :
>>
>> https://github.com/yogidevendra/examples/blob/13cd0ec8d24b5e5b125fe7567c18197b0a9a8f7e/tutorials/filter/src/main/java/com/datatorrent/tutorial/filter/TransactionPOJO.java
>>
>> I am using schema as follows:
>> {"separator": "|","quoteChar":"\"","lineDelimiter":"\n","fields":
>> [{"name": "trasactionId","type": "long"},{"name": "amount","type":
>> "double"},{"name": "type","type":
>> "com.datatorrent.tutorial.filter.TransactionPOJO.TRANSACTION_TYPE"}]}
>>
>> But, it gives following exception:
>>
>> Abandoning deployment due to setup failure.
>> java.lang.IllegalArgumentException: No enum constant
>>
>> com.datatorrent.contrib.parser.DelimitedSchema.FieldType.COM.DATATORRENT.TUTORIAL.FILTER.TRANSACTIONPOJO.TRANSACTION_TYPE
>> at java.lang.Enum.valueOf(Enum.java:236)
>> at
>> com.datatorrent.contrib.parser.DelimitedSchema$FieldType.valueOf(DelimitedSchema.java:161)
>> at
>> com.datatorrent.contrib.parser.DelimitedSchema$Field.<init>(DelimitedSchema.java:289)
>> at
>> com.datatorrent.contrib.parser.DelimitedSchema.initialize(DelimitedSchema.java:199)
>> at
>> com.datatorrent.contrib.parser.DelimitedSchema.<init>(DelimitedSchema.java:169)
>> at
>> com.datatorrent.contrib.formatter.CsvFormatter.setup(CsvFormatter.java:128)
>> at
>> com.datatorrent.contrib.formatter.CsvFormatter.setup(CsvFormatter.java:67)
>> at com.datatorrent.stram.engine.Node.setup(Node.java:187)
>> at
>> com.datatorrent.stram.engine.StreamingContainer.setupNode(StreamingContainer.java:1309)
>> at
>> com.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContainer.java:130)
>> at
>> com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1388)
>>
>> ~ Yogi
>>
>>
>

Mime
View raw message