Return-Path: X-Original-To: apmail-hama-dev-archive@www.apache.org Delivered-To: apmail-hama-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E222E181B7 for ; Thu, 9 Jul 2015 01:15:14 +0000 (UTC) Received: (qmail 41614 invoked by uid 500); 9 Jul 2015 01:15:14 -0000 Delivered-To: apmail-hama-dev-archive@hama.apache.org Received: (qmail 41581 invoked by uid 500); 9 Jul 2015 01:15:14 -0000 Mailing-List: contact dev-help@hama.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hama.apache.org Delivered-To: mailing list dev@hama.apache.org Received: (qmail 41568 invoked by uid 99); 9 Jul 2015 01:15:14 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Jul 2015 01:15:14 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 05583181A36 for ; Thu, 9 Jul 2015 01:15:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.969 X-Spam-Level: X-Spam-Status: No, score=0.969 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H4=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_HELO_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 2gA_yy229nm0 for ; Thu, 9 Jul 2015 01:15:07 +0000 (UTC) Received: from mailout2.samsung.com (mailout2.samsung.com [203.254.224.25]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 6C5F520B6F for ; Thu, 9 Jul 2015 01:15:06 +0000 (UTC) Received: from epcpsbgm2.samsung.com (epcpsbgm2 [203.254.230.27]) by mailout2.samsung.com (Oracle Communications Messaging Server 7.0.5.31.0 64bit (built May 5 2014)) with ESMTP id <0NR7030BT4SWAIB0@mailout2.samsung.com> for dev@hama.apache.org; Thu, 09 Jul 2015 10:14:56 +0900 (KST) X-AuditID: cbfee61b-f79416d0000014c0-6a-559dcb10e88d Received: from epmmp1.local.host ( [203.254.227.16]) by epcpsbgm2.samsung.com (EPCPMTA) with SMTP id 10.F4.05312.01BCD955; Thu, 9 Jul 2015 10:14:56 +0900 (KST) Received: from secPC ([10.251.52.188]) by mmp1.samsung.com (Oracle Communications Messaging Server 7.0.5.31.0 64bit (built May 5 2014)) with ESMTPA id <0NR700CF94SWVU40@mmp1.samsung.com> for dev@hama.apache.org; Thu, 09 Jul 2015 10:14:56 +0900 (KST) From: "Edward J. Yoon" To: dev@hama.apache.org References: In-reply-to: Subject: RE: BSPClass with parameters Date: Thu, 09 Jul 2015 10:14:57 +0900 Message-id: <002201d0b9e4$abba74f0$032f5ed0$@samsung.com> X-Mailer: Microsoft Outlook 14.0 Thread-index: AQHP36aLgDP7abGAFaghET6hgejEmJ3T/qTw Content-language: ko X-Brightmail-Tracker: H4sIAAAAAAAAA+NgFvrJJMWRmVeSWpSXmKPExsVy+t9jAV2B03NDDb4cNbPY/eMXowOjx7vD jYwBjFFcNimpOZllqUX6dglcGWdWv2cr2MpX8WbhB/YGxtPcXYycHBICJhJHj71nh7DFJC7c W88GYgsJLGKUuPlYs4uRC8huYJI4fvUIM0iCTcBAYu2i1UwgtoiAuMSzpk+MEA0BEnt6G8EG cQoES6y4eh3MFhZQlTg56z8riM0CZB/c1woW5xWwlHgw9RELxGIFiR1nXwPN4QCaaSTRMbUS JMwsICKx78U7xgmMfLOQuAsYGVcxiqYWJBcUJ6XnGukVJ+YWl+al6yXn525iBAfIM+kdjKsa LA4xCnAwKvHwNuycGyrEmlhWXJl7iFGCg1lJhFdjJVCINyWxsiq1KD++qDQntfgQozQHi5I4 78l8n1AhgfTEktTs1NSC1CKYLBMHp1QD40YDM5a87Qy6W+KeXv/4YOe8hwdFc9aoJ01RfTX3 yx1+1T+PdDPUlEvv5LuFros7Lqx1bdndayvP2rQ+mPz09Wm/vqWrzvYWM7acmX5m/nfuQxLR f8tn7ym8+UnH1sb13Mx2r1Bur193HHX/L+Z8MfEob+ev98ViRzz37l225/YXqf43eSdb06qU WIozEg21mIuKEwHTaTjdDAIAAA== Hi Behroz, You should specify the job parameters using BSPJob's get/set methods like below: BSPJob admm = new BSPJob(); admm.set("param1", "value"); admm.setBspClass(ExchangeADMMSolver.class); Then, public class ExchangeADMMSolver extends BSP { String param1; @Override public void setup(BSPPeer peer) { this.param1 = peer.getConfiguration().get("param1"); } } Thanks. -- Best Regards, Edward J. Yoon -----Original Message----- From: Behroz Sikander [mailto:behroz89@gmail.com] Sent: Thursday, July 09, 2015 9:02 AM To: dev@hama.apache.org Subject: BSPClass with parameters Hi, I was recently working on something and need your suggestion. I am building a small framework on top of Hama. Using my framework, users will submit a job to my framework and my framework will internally run the Hama job. Here is a sample code of what user might submit to my framework. //Extra Hama related Params here like JobName, output Path etc IFunction f = new MasterFunction(, ); IFunction g = new SlaveFunction(, ); ExchangeADMMSolver admm = new ExchangeADMMSolver(f, g); //Problem here admm.solve(); Here ExchangeADMMSolver will be a BSP class (this is what I am hoping to acheive) and *"solve" *method will internally create a HamaJob and will submit it to Hama. I am a little confused here that how will I pass all the parameters to the BSP class (e.g f,g) ? because in Hama if I want to set the bsp class I do the following HamaJob. setBspClass(ExchangeADMMSolver.class); So, Instead of this I am looking for something like HamaJob.setBspObject(admm); I might need to override some Hama classes but before doing that I need some suggestions that what can be the best solution. Regards, Behroz Sikander