Icon

NRU0

Node 1Node 12id to app_idselect id, pp_agen, bundle_id, nameplayregistercount A1join by datecount NRU0join by agent, idNode 41count NRUNode 43Node 44Node 45Node 61Node 62logNode 76Node 77install / first playNode 87Node 97user log (status =1)game infoNode 102playregisterNode 106install / first playcount A1Node 111join by date, agent, idjoin by agent, idcount NRU0Node 116Node 117left.date >= right.datecount NRUNode 121Node 122Node 123Node 124Node 136Node 137Node 139Node 140Node 141Node 142Node 143Node 144Node 1Node 147id to app_idselect id, pp_agen, bundle_id, nameNode 150Node 151Node 154Node 155MongoDB Reader JSON to Table Column Rename Column Filter Nominal ValueRow Filter Nominal ValueRow Filter GroupBy Joiner GroupBy Joiner Rule-basedRow Filter GroupBy Column Rename Column Rename Column Rename Joiner Joiner List Files ReDataLog ParallelChunk Start GroupBy Joiner Create Local BigData Environment Spark DataFrame JavaSnippet (Source) Table to Spark Spark Joiner Spark Row Filter Spark Row Filter Parallel Chunk End Spark GroupBy Spark GroupBy Spark Column Rename Spark Joiner Spark Joiner Spark GroupBy Spark Column Filter Spark Column Rename Spark DataFrameJava Snippet Spark GroupBy Spark Column Rename Spark Joiner Spark Joiner Spark to Table Timer Info Column Filter Math Formula Math Formula Column Filter Math Formula Math Formula Timer Info MongoDB Reader JSON to Table Column Rename Column Filter Destroy SparkContext String Input Persist SparkDataFrame/RDD Unpersist SparkDataFrame/RDD Node 1Node 12id to app_idselect id, pp_agen, bundle_id, nameplayregistercount A1join by datecount NRU0join by agent, idNode 41count NRUNode 43Node 44Node 45Node 61Node 62logNode 76Node 77install / first playNode 87Node 97user log (status =1)game infoNode 102playregisterNode 106install / first playcount A1Node 111join by date, agent, idjoin by agent, idcount NRU0Node 116Node 117left.date >= right.datecount NRUNode 121Node 122Node 123Node 124Node 136Node 137Node 139Node 140Node 141Node 142Node 143Node 144Node 1Node 147id to app_idselect id, pp_agen, bundle_id, nameNode 150Node 151Node 154Node 155MongoDB Reader JSON to Table Column Rename Column Filter Nominal ValueRow Filter Nominal ValueRow Filter GroupBy Joiner GroupBy Joiner Rule-basedRow Filter GroupBy Column Rename Column Rename Column Rename Joiner Joiner List Files ReDataLog ParallelChunk Start GroupBy Joiner Create Local BigData Environment Spark DataFrame JavaSnippet (Source) Table to Spark Spark Joiner Spark Row Filter Spark Row Filter Parallel Chunk End Spark GroupBy Spark GroupBy Spark Column Rename Spark Joiner Spark Joiner Spark GroupBy Spark Column Filter Spark Column Rename Spark DataFrameJava Snippet Spark GroupBy Spark Column Rename Spark Joiner Spark Joiner Spark to Table Timer Info Column Filter Math Formula Math Formula Column Filter Math Formula Math Formula Timer Info MongoDB Reader JSON to Table Column Rename Column Filter Destroy SparkContext String Input Persist SparkDataFrame/RDD Unpersist SparkDataFrame/RDD

Nodes

Extensions

Links