Mailing-List: contact dev-help@apex.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@apex.apache.org
MIME-Version: 1.0
In-Reply-To: <D368C24E.25D5%sparmar@threatmetrix.com>
References: <D368C24E.25D5%sparmar@threatmetrix.com>
Date: Mon, 23 May 2016 14:32:11 -0700
Message-ID: <CAKt=akFb8zru=s=QsCFHcLwi3HKDt6v2JXJJusyvTV0zziqgdg@mail.gmail.com>
Subject: Re: Time controlled ingestion operator
From: Priyanka Gugale <priyanka@datatorrent.com>
To: users@apex.apache.org
Cc: "dev@apex.apache.org" <dev@apex.apache.org>,
	"users@apex.incubator.apache.org" <users@apex.incubator.apache.org>,
	"dev@apex.incubator.apache.org" <dev@apex.incubator.apache.org>
Content-Type: multipart/alternative; boundary=94eb2c0cded6631a0a0533892c18
archived-at: Mon, 23 May 2016 21:32:18 -0000

--94eb2c0cded6631a0a0533892c18
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hi Sunil,

I don't think we have exactly pause and resume feature in Malhar yet. But I
can think of some other way to achieve this.
We are adding bandwidth control feature to Malhar. The pull request
<https://github.com/apache/incubator-apex-malhar/pull/279> is already
opened for the same. This doesn't have option to configure timed bandwidth
consumption (i.e. use x bandwidth during given time hours), but I think
it's easy to do that in BandwidthManager. Or quick thing is you can try to
update the property "bandwidth" during the time when u don't want operator
to work using some external script (this is short term solution).

Can you tell the reason why you want to pause the read during certain time
hours?

-Priyanka


On Mon, May 23, 2016 at 2:21 PM, Sunil Parmar <sparmar@threatmetrix.com>
wrote:

> All,
> We=E2=80=99re writing an app for migration data from legacy JDBC system t=
o Kafka.
> Legacy system as it is still being used in production, we would want to
> pause the JDBC poll input operator for configured hours.
>
> Does malhar ibrary has any operator that we can use for time controlled
> operator ?
> Or is there a way to configure input operators to pause and resume for
> given time ?
>
> -Sunil
>
>
>

--94eb2c0cded6631a0a0533892c18--