from pyspark import SparkConf, SparkContext


def myprint(one):
    print(one)


def top2list(one):
    website = one[0]
    locals = one[1]
    localdic = {}
    for local in locals:
        if local in localdic:
            localdic[local] += 1
        else:
            localdic[local] = 1
    site_locallist = sorted(localdic.items(), key=lambda tp: tp[1], reverse=True)
    returnlist = []
    if (len(site_locallist) > 2):
        for i in range(2):
            returnlist.append(site_locallist[i])
    else:
        returnlist = site_locallist
    return website, returnlist


def get_site_uid_count(one):
    uid = one[0]
    sites = one[1]
    siteDic = {}
    for site in sites:
        if site in siteDic:
            siteDic[site] += 1
        else:
            siteDic[site] = 1
    returnlist = []
    for site, count in siteDic.items():
        returnlist.append((site, (uid, count)))
    return returnlist


def top3list(one):
    website = one[0]
    uid_count_itr = one[1]
    top3lists = ['', '', '']
    for uid_count in uid_count_itr:
        count = uid_count[1]
        for i in range(len(top3lists)):
            if top3lists[i] == "":
                top3lists[i] = uid_count
                break
            elif top3lists[i][1] < count://运行时总是提示这行，str与int之间不能比较，打印type(top3lists[i][1])为int)
                for j in range(2, i, -1):
                    top3lists[j] = top3lists[j - 1]
                top3lists = uid_count
                break

    return website, top3lists


def getApv():
    conf = SparkConf()
    conf.setMaster("local")
    conf.setAppName("pv")
    sc = SparkContext(conf=conf)
    linesRDD = sc.textFile("D:\mypython\date\website")
    # linesRDD.map(lambda line:(line.split("\t")[2],1)).reduceByKey(lambda v1,v2:v1+v2).\
    #     sortBy(lambda tp:tp[1],ascending=False).foreach(lambda one:myprint(one=one))
    # 每个网站访问最多的top2地区
    # site_local = linesRDD.map(lambda line:(line.split("\t")[4],line.split("\t")[2])).groupByKey()
    # site_local.map(lambda one:top2list(one)).foreach(print)
    # 每个网站最活跃的用户top3
    linesRDD.map(lambda line: (line.split("\t")[3], line.split("\t")[4])).groupByKey() \
        .flatMap(lambda one: get_site_uid_count(one)).groupByKey().map(lambda one: top3list(one)).foreach(print)


if __name__ == "__main__":
    getApv()

老师您好 能在解释一下第九行构造函数中的self.pack()的含义吗？

老师，我想问一下上面出错的这部分是我自己敲的，下面的是系统自动生成的，明明只有差一个注释的区别，为什么我的会出错 ？

查询受雇日期，找出 2002 年开始工作的哪些人。用 ROUND 和 TRUNC 函 数显示开始的月份。 

视频中讲错了吧，正确SQL应该如下吧：

SELECT employee_id,hire_date,TRUNC(hire_date,'mm'),ROUND(hire_date,'mm')

FROM employees

where TRUNC(hire_date,'Y')>='01-1月-02';

显示所有工作岗位名称从第 4 个字符位置开始包含字符串 REP 的雇员的信息，将雇 员的姓和名连接显示在一起，还显示雇员名的长度，以及名字中字母 a 的位置。

视频中讲错了吧，正确SQL应该是下面这样吧：

SELECT CONCAT(first_name,last_name),LENGTH(last_name),INSTR(last_name,'a')

FROM employees

WHERE INSTR(job_id,'REP',4,1)>0;

老师您好

    请问出现以下异常的原因是什么？

异常1：

package Map;

import java.util.HashMap;

public class HashMapWork01 {
    public static void main(String[] args) {
        //创建对象
        HashMap hm=new HashMap();
        //添加键和值
        hm.put("key01",080);
        System.out.println("根据键获取值"+hm.get("key01"));
//     出现异常key01的值为020，但是输出结果为16，更改值为010时输出为8，更改为080时出现
        【过大的整数：080】异常
    }
}

异常二：

public class HashMapWork01 {
    public static void main(String[] args) {
        //创建对象
        HashMap hm=new HashMap();
        //添加键和值
        hm.put("key01",010);
        hm.put("key02",020);
        hm.put("key03",030);

        //遍历
     for (Object obj:hm.entrySet()){
         System.out.println(obj);
         }
     
    }
}

我这里如果想要修改Collections.sort()默认的排序规则

代码应该怎么写？

package com.bjsxt.Collections;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;

public class TestCollections{
//Collections工具类的使用
	
	public static void main(String[] args) {
			ArrayList<String> al = new ArrayList<String>();
			//向集合中一次性添加N多个元素
			Collections.addAll(al, "aello","corld","bava");
			System.out.println(al);
			//排序
			Collections.sort(al);
			
			System.out.println(al);
	}

	

}

老师，最后的结果还是打印在控制台上，那么将结果封装在对象中的作用是什么？

老师 为什么我的图片都是一个路径 但是下面的商品名称和价钱却不一样

老师，你好，有视频对应的文档吗？啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦啦

老师，我的所有貌似都没有问题，可是按了F12后查看源码，并没有所对应的文件啊

如果有人还是遇到上传成功了但是图片没有回显的问题，那么可能是你没有配置nginx的转发

老师，我问一下，在练习B/S的时候，我没有特意去创建index.html，但是也成功了？这个index.html文件是在哪里啊，具体是个什么情况啊

老师  资料取消了 维护一下  .....

老师，我的输出结果  为什么没有服务器收到了！

以下是服务器端的代码：

package ClientServer;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) throws IOException {
        System.out.println("--------服务器已启动--------");
        /**
         * 创建ServerSocket对象
         */
        ServerSocket server = new ServerSocket(8877);
        /**
         * 监听是否有客户端连接
         */
        Socket socket = server.accept();
        /**
         * 获取输入流数据
         */
        DataInputStream dis = new DataInputStream(socket.getInputStream());
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        while(true) {
            String str = dis.readUTF();
            System.out.println("客户端发送的数据为："+str);
            /**
             * 获取输出流响应客户端的请求
             */
            dos.writeUTF("服务器端收到了："+str);
        }
        /**
         * 关闭流
         */
        //CloseUtil.closeAll(dos,dis,socket);
    }

}

以下为客户端代码：

package ClientServer;

import java.io.DataInputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

public class ChatClient {
    public static void main(String[] args) throws UnknownHostException, IOException {
        /**
         * 创建Socket对象
         */
        Socket client = new Socket("localhost",8877);
        /**
         * 创建发送的线程类对象
         */
        Send send = new Send(client);
        /**
         * 创建接收的线程类对象
         */
        Receive receive = new Receive(client);
        /**
         * 创建Thread类并启动线程
         */
        new Thread(send).start();
        new Thread(receive).start();
        
    }
}