Mailing-List: contact dev-help@spark.apache.org; run by ezmlm
Precedence: bulk
From: "Ulanov, Alexander" <alexander.ulanov@hpe.com>
To: "dev@spark.apache.org" <dev@spark.apache.org>
Subject: Graph edge type pattern matching in GraphX
Thread-Topic: Graph edge type pattern matching in GraphX
Thread-Index: AdHsuWAG891cYGRsRpiPLRacym3rkA==
Date: Tue, 2 Aug 2016 12:29:10 +0000
Message-ID: <DF4PR84MB031390A3676612A6F7F5404D85050@DF4PR84MB0313.NAMPRD84.PROD.OUTLOOK.COM>
Accept-Language: en-US
Content-Language: en-US
received-spf: None (protection.outlook.com: hpe.com does not designate
 permitted sender hosts)
spamdiagnosticoutput: 1:99
spamdiagnosticmetadata: NSPM
Content-Type: multipart/alternative;
	boundary="_000_DF4PR84MB031390A3676612A6F7F5404D85050DF4PR84MB0313NAMP_"
MIME-Version: 1.0
X-MS-Exchange-CrossTenant-originalarrivaltime: 02 Aug 2016 12:29:10.2188
 (UTC)
X-MS-Exchange-CrossTenant-fromentityheader: Hosted
X-MS-Exchange-CrossTenant-id: 105b2061-b669-4b31-92ac-24d304d195dc
X-MS-Exchange-Transport-CrossTenantHeadersStamped: DF4PR84MB0315
archived-at: Tue, 02 Aug 2016 12:29:23 -0000

--_000_DF4PR84MB031390A3676612A6F7F5404D85050DF4PR84MB0313NAMP_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Dear Spark developers,

Could you suggest how to perform pattern matching on the type of the graph =
edge in the following scenario. I need to perform some math by means of agg=
regateMessages on the graph edges if edges are Double. Here is the code:
def my[VD: ClassTag, ED: ClassTag] (graph: Graph[VD, ED]): Double {
graph match {
   g: Graph[_, Double] =3D> g.aggregateMessages[Double](t =3D> t.sendToSrc(=
t.attr), _ + _).values.max
   _ =3D> 0.0
}
}

However, it does not work, because aggregateMessages creates context t of t=
ype [VD, ED, Double]. I expect it to create context of [VD, Double, Double]=
 because of the type pattern matching. Could you suggest what is the issue?

Best regards, Alexander

--_000_DF4PR84MB031390A3676612A6F7F5404D85050DF4PR84MB0313NAMP_
Content-Type: text/html; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

<html xmlns:v=3D"urn:schemas-microsoft-com:vml" xmlns:o=3D"urn:schemas-micr=
osoft-com:office:office" xmlns:w=3D"urn:schemas-microsoft-com:office:word" =
xmlns:m=3D"http://schemas.microsoft.com/office/2004/12/omml" xmlns=3D"http:=
//www.w3.org/TR/REC-html40">
<head>
<meta http-equiv=3D"Content-Type" content=3D"text/html; charset=3Dus-ascii"=
>
<meta name=3D"Generator" content=3D"Microsoft Word 15 (filtered medium)">
<style><!--
/* Font Definitions */
@font-face
	{font-family:"Cambria Math";
	panose-1:2 4 5 3 5 4 6 3 2 4;}
@font-face
	{font-family:Calibri;
	panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
	{margin:0in;
	margin-bottom:.0001pt;
	font-size:11.0pt;
	font-family:"Calibri",sans-serif;}
a:link, span.MsoHyperlink
	{mso-style-priority:99;
	color:#0563C1;
	text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
	{mso-style-priority:99;
	color:#954F72;
	text-decoration:underline;}
span.EmailStyle17
	{mso-style-type:personal-compose;
	font-family:"Calibri",sans-serif;
	color:windowtext;}
.MsoChpDefault
	{mso-style-type:export-only;}
@page WordSection1
	{size:8.5in 11.0in;
	margin:1.0in 1.0in 1.0in 1.0in;}
div.WordSection1
	{page:WordSection1;}
--></style><!--[if gte mso 9]><xml>
<o:shapedefaults v:ext=3D"edit" spidmax=3D"1026" />
</xml><![endif]--><!--[if gte mso 9]><xml>
<o:shapelayout v:ext=3D"edit">
<o:idmap v:ext=3D"edit" data=3D"1" />
</o:shapelayout></xml><![endif]-->
</head>
<body lang=3D"EN-US" link=3D"#0563C1" vlink=3D"#954F72">
<div class=3D"WordSection1">
<p class=3D"MsoNormal">Dear Spark developers,<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal">Could you suggest how to perform pattern matching on=
 the type of the graph edge in the following scenario. I need to perform so=
me math by means of aggregateMessages on the graph edges if edges are Doubl=
e. Here is the code:<o:p></o:p></p>
<p class=3D"MsoNormal">def my[VD: ClassTag, ED: ClassTag] (graph: Graph[VD,=
 ED]): Double {<o:p></o:p></p>
<p class=3D"MsoNormal">graph match {<o:p></o:p></p>
<p class=3D"MsoNormal">&nbsp;&nbsp; g: Graph[_, Double] =3D&gt; g.aggregate=
Messages[Double](t =3D&gt; t.sendToSrc(t.attr), _ &#43; _).values.max<o:p><=
/o:p></p>
<p class=3D"MsoNormal">&nbsp;&nbsp; _ =3D&gt; 0.0<o:p></o:p></p>
<p class=3D"MsoNormal">}<o:p></o:p></p>
<p class=3D"MsoNormal">}<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal">However, it does not work, because aggregateMessages=
 creates context t of type [VD, ED, Double]. I expect it to create context =
of [VD, Double, Double] because of the type pattern matching. Could you sug=
gest what is the issue?<o:p></o:p></p>
<p class=3D"MsoNormal"><o:p>&nbsp;</o:p></p>
<p class=3D"MsoNormal">Best regards, Alexander<o:p></o:p></p>
</div>
</body>
</html>

--_000_DF4PR84MB031390A3676612A6F7F5404D85050DF4PR84MB0313NAMP_--