POJOInputOperator in emitting the following output.
>
>
>
>
>
> {
>
> "string": "{\"abv\":\"0.0\"}"
>
> }
>
>
>
>
>
> *From:* Priyanka Gugale [mailto:priya...@datatorrent.com]
> *Sent:* Tuesday, August 23, 201
;}"
}
From: Priyanka Gugale [mailto:priya...@datatorrent.com]
Sent: Tuesday, August 23, 2016 3:01 PM
To: users@apex.apache.org
Subject: Re: connecting two operators
Okay, as I understand, as of now your further processing piece is missing. You
can use ConsoleOutputOperator for time being.
From:* Priyanka Gugale [mailto:priya...@datatorrent.com]
> *Sent:* Tuesday, August 23, 2016 2:49 PM
>
> *To:* users@apex.apache.org
> *Subject:* Re: connecting two operators
>
>
>
> Hi Hitesh,
>
>
>
> "Median" is *not* an output operator, we should connect a
, August 23, 2016 2:49 PM
To: users@apex.apache.org
Subject: Re: connecting two operators
Hi Hitesh,
"Median" is not an output operator, we should connect at least one of the
output port of non i/o operators to next operator. In this example you can
either use ConsoleOutputOperator to log med
om.datatorrent.stram.cli.ApexCli.launchAppPackage(ApexCli.java:3445)
> at com.datatorrent.stram.cli.ApexCli.access$7400(ApexCli.java:151) at
> com.datatorrent.stram.cli.ApexCli$LaunchCommand.execute(ApexCli.java:1900)
> at com.datatorrent.stram.cli.ApexCli$3.run(ApexCli.java:1462)
>
&g
priya...@datatorrent.com]
Sent: Tuesday, August 23, 2016 11:54 AM
To: users@apex.apache.org
Subject: Re: connecting two operators
There are two ways you can do this, first as Yogi suggested add a new operator
to convert object to Number. Below is code example:
CouchBasePOJOInputOpera
There are two ways you can do this, first as Yogi suggested add a new
operator to convert object to Number. Below is code example:
CouchBasePOJOInputOperator inputOperator = dag.addOperator("inputOperator",
CouchBasePOJOInputOperator.class);
ObjectToNumberConverter converter = dag.addOperator("con
Define ObjectToNumberConverter operator which accepts Object on the input
port and emits Number on its output port.
Use this operator in your DAG.
~ Yogi
On 22 August 2016 at 17:42, Hitesh Goyal
wrote:
> Hi team,
>
> Refer to following 3 lines of code.
>
> CouchBasePOJOInputOperator
