Mailing-List: contact user-help@uima.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@uima.apache.org
Received-SPF: pass (athena.apache.org: domain of richard.eckart@gmail.com
 designates 74.125.83.47 as permitted sender)
Content-Type: text/plain; charset=windows-1252
Mime-Version: 1.0 (Mac OS X Mail 6.5 \(1508\))
Subject: Re: AnalysisEngine.processAndOutputNewCASes(...) in case of
 JCasMultiplier returns 0 JCases
From: Richard Eckart de Castilho <richard.eckart@gmail.com>
In-Reply-To: <2D3EBE0F-14AB-49A3-AF17-2E7705375D54@gmail.com>
Date: Thu, 5 Sep 2013 19:59:11 +0200
Content-Transfer-Encoding: quoted-printable
Message-Id: <77512835-C0FE-4B1E-9DE7-CEDF3AD26E0A@gmail.com>
References: <2D3EBE0F-14AB-49A3-AF17-2E7705375D54@gmail.com>
To: user@uima.apache.org

Hi Artem,

did you try asking the AggregateBuilder for a description,
calling getOperationalProperties().setOutputsNewCASes(true)
on the description and then creating the engine?

I have an apparently working piece of code looking along these lines

// The part starting with a splitter and ending with a merger has to be =
in its own
// aggregate. The flow controller of the aggregate has to drop the =
intermediate CASes.
FlowControllerDescription fcd =3D =
createFlowControllerDescription(FixedFlowController.class,
  FixedFlowController.PARAM_ACTION_AFTER_CAS_MULTIPLIER, "drop");
AnalysisEngineDescription embedded =3D createEngineDescription(fcd, =
splitter, tokenizer, merger);

// The final merged CAS, however, needs to be returned from the =
aggregate
=
embedded.getAnalysisEngineMetaData().getOperationalProperties().setOutputs=
NewCASes(true);

// Need to wrap into another aggregate because runPipeline has no =
immediate support for
// flow control
AnalysisEngineDescription pipelineDesc =3D =
createEngineDescription(sentenceDetector, embedded, consumer);

SimplePipeline.runPipeline(createReaderDescription(=85), pipelineDesc);

Cheers,

-- Richard

On 30.08.2013, at 23:32, Artem Vovk <vovk.artem@gmail.com> wrote:

> Hi,
>=20
> I wanted to write a test for MyJCasMultiplier, to check how many =
JCases are created. Here is my code:
>=20
> AnalysisEngineDescription segmenter =3D   =
createEngineDescription(BreakIteratorSegmenter.class);
>=20
> AnalysisEngineDescription multiplier =3D =
createEngineDescription(MyJCasMultiplier.class);
> =09
> AggregateBuilder ab =3D new AggregateBuilder();
> ab.add(segmenter);
> ab.add(multiplier);
>=20
> AnalysisEngine engine =3D ab.createAggregate();
> =
engine.getAnalysisEngineMetaData().getOperationalProperties().setOutputsNe=
wCASes(true);
>=20
> JCas jCas =3D engine.newJCas();
> jCas.setDocumentText(testString);
> JCasIterator it =3D engine.processAndOutputNewCASes(jCas);
>=20
> The problem is that engine.processAndOutputNewCASes(jCas) returns =
always 0 JCases, but I know it should be more :) Did I miss something =
here or it is a framework issue?
>=20
> Best,
> Artem