�����������������������������������������������• ����������������������-���������� ������������������������������������-�������������������-��������������������-���������������������������������� �����������-�� �������� � ��������������������• �������� ����� ������� ���������Ø ��������������������������������Alink v1.0Alink v1.1����� ������������• �������������������• �������������������������������• ������������������� ������������• ����������������������� ������������• ��������������• ������������• ���������������������������� ��������Alink v1.2����� ������������• �������• �������������������• �����������������������• �����������• �����������Alink v1.3����� �������������• ��������������������• ������������• ���������������• ������� ������• �������������������� ������������• ������� ����• �������������������������� ������������• ���������������� �������������• ����� ������� �����������• ������������������������������� �������������• �������������������• ����������������������������������������RuntimeDistributed Streaming DataflowCEPEvent ProcessingDataStream APIStream ProcessingDataSet APIBatch ProcessingLocalSingle JVMCloudGCE EC2ClusterStandalone YARNTableRelationalTableRelationalFlink MLMaching LearningGellyGraph ProcessingAlink MLFor StreamingAlink MLFor BatchAlink StatFor StreamingAlink StatFor BatchStream OperatorStream ProcessingBatch OperatorBatch ProcessingAlink SDK & Web UI & Client & VisualizationProcessing for Structural DataAlink ......For StreamingAlink ......For BatchCommon Libs����������������������������������������������������������• PartitionedData• BroadcastData• ComputeFunction• CommunicateFunction• CompareCriterionFunction• CompleteResultFunction��������Binary ClassificationLogisticRegLinearSvmPerceptronFRegressionLassoRegRidgeRegLinearRegMultiple ClassificationSoftmaxUnified representation: trainer, predictor, modelLoss FunctionRegularizationSurvivalRegParallel OptimizerGDSGDLBFGSOWLQNNEWTONLocal OptimizerGDSGDLBFGSOWLQNNEWTONqRdbkSBHEce AAd SiAk(DFSOSSLBcal……CatalBgAKCSVLibSVMTSV……File SystemXXSBHEceStEeamOCL..XXSiAkStEeamOCL..XXSBHEceBatchOCL..XXSiAkBatchOCL..CatalBgSBHEceStEeamOCCatalBgSiAkStEeamOCCatalBgSBHEceBatchOCCatalBgSiAkBatchOC������(iIeMKFDlDeEbK……Øg地wtMHFeLBcalEAIØyswtMHFeRemBteEAIfrom pyalink.alink import *useLocalEnv(2)# train itemCF modelitem_cf_model = ItemCfTrainBatchOp()\.setUserCol(USER_COL)\.setItemCol(ITEM_COL)\.setRateCol(RATING_COL)\.linkFrom(getSourceRatings())# save pipeline model to localPipelineModel(ItemCfItemsPerUserRecommender()\.setUserCol(USER_COL)\.setRecommCol(RECOMM_COL)\.setModelData(item_cf_model)).save(LOCAL_DIR + "pipeline_model.ak”)BatchOperator.execute()from pyalink.alink import *useRemoteEnv("10.101.**.**", 31805, 2)# train itemCF modelitem_cf_model = ItemCfTrainBatchOp()\.setUserCol(USER_COL)\.setItemCol(ITEM_COL)\.setRateCol(RATING_COL)\.linkFrom(getRemoteSourceRatings())fs = HadoopFileSystem("hdfs://10.*.*.*:9000/")# save pipeline model to hdfsPipelineModel(ItemCfItemsPerUserRecommender()\.setUserCol(USER_COL)\.setRecommCol(RECOMM_COL)\.setModelData(item_cf_model)).save(FilePath(fs, DATA_DIR + "pipeline_model.ak”))BatchOperator.execute().iCeliAeMBdel up���������https://raw.githubusercontent.com/SophonPlus/ChineseNlpCorpus/master/datasets/ChnSentiCorp_htl_all/ChnSentiCorp_htl_all.csv�����������������/��������������������������������������(Prepare data)�����(Text Pre-processing)�����(Text Vectorization)������Model Training)����(Evaluation)����(Prediction)�������HTTP�������������������Text Pre-processing�����Text Vectorization������Model TrainingPipeLine��(PipeLine Definition)�����/��/����������������������������Model Training����EvaluationConfusionMatrixRocCurveRecallPrecisionCurve����Prediction��PipeLine��������������������save��������Operator�������������������load�������������������Load������������������������������������oSf务nqPoScl）X布aysnqPi型up）eT_储nqPi型_储）如何部ri型到oSOCiCeliAe.fit( CiCeliAeMBdel.FaIe(F)LE_.AT( LBcal.EedictBE(F)LE_.AT( .maC(EBw LBcal.EedictBE h制.iCeliAe i型部roS• �����������������• �.���P�J��������A�����+����• �.���P�J��������A��������Alink 教程（即将出版）• ����+����������+�����/��.�������.���• ����+���������������)���/�����+���.����(��• �J��+���������������)���/�����+���.�������()• ����+�����������:+�+����/��)��.)��.��������+�Alink 相关资料欢vVmAliAk！
发表评论取消回复