会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132837个问题
JAVA 全系列/第一阶段:JAVA 快速入门/飞机大战小项目训练 31606楼
JAVA 全系列/第一阶段:JAVA 快速入门/变量、数据类型、运算符 31607楼
人工智能/第十阶段:机器学习-Kaggle竞赛实战/网页分类案例 31608楼

   val kafkaDDL :String = 
        """
        |create table MyTable (
        |componentType STRING,
        |endDate  STRING,
        |envName  STRING,
        |resultId  STRING,
        |spendTime  STRING,
        |returnDataNum  STRING,
        |startDate  STRING,
        |tableName  STRING,
        |tenantName  STRING
        |) with (
        |    'connector.type' = 'kafka',
        |    'connector.version' = '0.10',
        |    'connector.topic' = 'test',
        |    'connector.properties.1.key' = 'bootstrap.servers',
        |    'connector.properties.1.value' = 'localhost:9092',
        |    'connector.properties.0.key' = 'zookeeper.connect',
        |    'connector.properties.0.value' = 'localhost:2181',
        |    'connector.properties.2.key' = 'group.id',
        |    'connector.properties.2.value' = 'testGroup',
        |    'connector.startup-mode' = 'earliest-offset',
        |    'connector.property-version' = '1',
        |    'format.type' = 'json',
        |    'format.property-version' = '1',
        |    'update-mode' = 'append'
        |)
        """.stripMargin
        tableEnv.sqlUpdate(kafkaDDL)
    val hbaseDDL :String =
      """
        |Create table flink_log1 (
        |rowkey string,
        |cf ROW(f1 BIGINT,f2 BIGINT,f3 INT,f4 INT,f5 BIGINT,tenantName VARCHAR)
        |) with(
        |   'connector.type' = 'hbase',
        |   'connector.version' = '1.4.3',
        |   'connector.table-name' = 'flink_log1',
        |   'connector.zookeeper.quorum' = '....:2181,....:2181',
        |   'connector.zookeeper.znode.parent' = '/hbase',
        |   'connector.write.buffer-flush.max-size' = '10mb',
        |   'connector.write.buffer-flush.max-rows' = '1000'
        |)
      """.stripMargin
    tableEnv.sqlUpdate(hbaseDDL)
    val sql =
        "select CONCAT_WS('_',tenantName,tenantName) as tm_tenantName, " +
        "count(tenantName) as f1 ," +
        "count(case when resultId =  '2' then resultId else '' end) as f2 ,"+
        "avg(spendTime) as f3 ,"+
        "sum(returnDataNum) as f4 ,"+
        "count(case when resultId =  '1' then tenantName else '' end) as f5 ,"+
        "tenantName "+
        "from MyTable where substring(endDate,1,10)='2020-06-28' " +
        "group by CONCAT_WS('_',tenantName,tenantName) , tenantName"
    val table: Table = tableEnv.sqlQuery(sql)
    tableEnv.createTemporaryView("tmp",table)
    tableEnv.sqlUpdate("insert into flink_log1 " +
      "select tm_tenantName,ROW(f1,f2,f3,f4,f5,tenantName) as cf from tmp ")
    streamEnv.execute("my insert hbase sql")


这里的情况主要是插入hbase的时候group by 多个字段会导致

报:

Exception in thread "main" org.apache.flink.table.api.TableException: UpsertStreamTableSink requires that Table has full primary keys if it is updated.

但是我group by 单个字段是的时候是没有问题的,也就是当我加上group by tenantName的时候就会报这个错误

麻烦老师看一下这是什么问题

谢谢~

大数据全系列/第二十二阶段:Flink实时计算引擎/TableAPI和Flink的SQL 31610楼
JAVA 全系列/第一阶段:JAVA 快速入门/面向对象详解和JVM底层内存分析 31611楼

"""开发画图软件"""
import tkinter as tk


# 窗口的宽度和高度
win_width=900
win_height=450
class Application(tk.Frame):
    def __init__(self, master = None):
        super().__init__(master)
        self.master = master
        self.bgcolor = '#000000'
        self.x = 0
        self.y = 0
        self.fgcolor = 'red'
        self.startDrawFlag = False
        self.lastDraw = 0
        self.pack()
        self.createWidget()

    def createWidget(self):
        # 创建绘图区
        self.drawpad = tk.Canvas(self, width=win_width, height=win_height * 0.9, bg=self.bgcolor)
        self.drawpad.pack()

        # 创建按钮
        btn_start = tk.Button(self, text='开始', width='10', name='start');btn_start.pack(side='left', padx='10', pady='5')
        btn_pen = tk.Button(self, text='画笔', width='10', name='pen');btn_pen.pack(side='left', padx='10', pady='5')
        btn_rect = tk.Button(self, text='矩形', width='10', name='rect');btn_rect.pack(side='left', padx='10', pady='5')
        btn_clear = tk.Button(self, text='清屏', width='10', name='clear');btn_clear.pack(side='left', padx='10', pady='5')
        btn_erasor = tk.Button(self, text='橡皮擦', width='10', name='erasor');btn_erasor.pack(side='left', padx='10', pady='5')
        btn_line = tk.Button(self, text='直线', width='10', name='line');btn_line.pack(side='left', padx='10', pady='5')
        btn_lineArrow = tk.Button(self, text='箭头直线', width='10', name='lineArrow');btn_lineArrow.pack(side='left', padx='10', pady='5')
        btn_color = tk.Button(self, text='颜色', width='10', name='color');btn_color.pack(side='left', padx='10', pady='5')

        # 事件处理
        btn_pen.bind_class('Button','<1>', self.eventManager)
        self.drawpad.bind('<ButtonRelease-1>', self.stopDraw)

    def eventManager(self,event):
        name = event.widget.winfo_name()
        print(name)
        if name == "line":
            self.drawpad.bind('<B1-Motion>',self.myline)
        elif name == 'lineArrow':
            self.drawpad.bind('<B1-Motion>', self.mylineArrow)


    def stopDraw(self, event):
        self.startDrawFlag = False
        self.lastDraw = 0

    def myline(self, event):
        self.drawpad.delete(self.lastDraw)
        if not self.startDrawFlag:
            self.startDrawFlag = True
            self.x = event.x
            self.y = event.y
        self.lastDraw = self.drawpad.create_line(self.x, self.y, event.x, event.y, fill=self.fgcolor)


    # def stopDraw(self, event):
    #     self.startDrawFlag = False
    #     self.lastDraw = 0

    def mylineArrow(self, event):
        self.drawpad.delete(self.lastDraw)
        if not self.startDrawFlag:
            self.startDrawFlag = True
            self.x = event.x
            self.y = event.y
        self.lastDraw = self.drawpad.create_line(self.x, self.y, event.x, event.y, arrow=LAST, fill=self.fgcolor)

if __name__ == "__main__":
    root = tk.Tk()
    root.title('画画本')
    root.geometry(str(win_width)+'x'+str(win_height))
    app = Application(master = root)
    root.mainloop()

image.png,这里每一步我都是跟着视频照着打,运行错误


Python 全系列/第二阶段:Python 深入与提高/GUI编程(隐藏) 31613楼
Python 全系列/第八阶段:轻量级Web开发利器-Flask框架/Flask数据库 31614楼
Python 全系列/第八阶段:轻量级Web开发利器-Flask框架/Flask数据库 31615楼
JAVA 全系列/第三阶段:数据库编程/JDBC技术(旧) 31616楼

flask项目.zip

image.png

image.png

老师,这个为什么是错误的,


Python 全系列/第九阶段:Flask百战电商后台系统/Flask百战电商后台项目 31617楼

老师:我按书中的程序写了一遍,发现报错,看错误提示是父类(Frame)的属性没有被调用,如下:

# encoding: utf-8
from tkinter import *
from tkinter import messagebox


class Application(Frame):
    def __init__(self,master=None):
        super().__init__(self,master)
        self.master = master
        self.pack()
        self.createWidget()
    def createWidget(self):
        self.btn01 = Button(self)
        self.btn01["text"] = "点我送花"
        self.btn01.pack()
        self.btn01["command"] = self.songhua
        self.btnQuite = Button(self,text="退出", command=root.destroy)
        self.btnQuite.pack()
    def songhua(self):
        messagebox.showinfo("送花", "送你99朵玫瑰花")


if __name__ == "__main__":
    root = Tk()
    root.title("经典的app程序")
    root.geometry("500x300+100+200")
    app = Application(master=root)
    root.mainloop()

运行

image.png

看到问题提示,我在初始化中将super()该为Frame.问题解决,为什么用super()会出错呢?

# encoding: utf-8
from tkinter import *
from tkinter import messagebox


class Application(Frame):
    def __init__(self,master=None):
        Frame.__init__(self,master)
        self.master = master
        self.pack()
        self.createWidget()
    def createWidget(self):
        self.btn01 = Button(self)
        self.btn01["text"] = "点我送花"
        self.btn01.pack()
        self.btn01["command"] = self.songhua
        self.btnQuite = Button(self,text="退出", command=root.destroy)
        self.btnQuite.pack()
    def songhua(self):
        messagebox.showinfo("送花", "送你99朵玫瑰花")


if __name__ == "__main__":
    root = Tk()
    root.title("经典的app程序")
    root.geometry("500x300+100+200")
    app = Application(master=root)
    root.mainloop()

运行

image.png

Python 全系列/第二阶段:Python 深入与提高/GUI编程(隐藏) 31618楼

"""开发画图软件"""
import tkinter as tk

# 窗口的宽度和高度
win_width=900
win_height=450
class Application(tk.Frame):
    def __init__(self, master = None):
        super().__init__(master)
        self.master = master
        self.bgcolor = '#000000'
        self.x = 0
        self.y = 0
        self.fgcolor = '#ff0000'
        self.lastDraw = 0
        self.pack()
        self.createWidget()

    def createWidget(self):
        # 创建绘图区
        self.drawpad = tk.Canvas(self, width=win_width, height=win_height * 0.9, bg=self.bgcolor)
        self.drawpad.pack()

        # 创建按钮
        btn_start = tk.Button(self, text='开始', width='10', name='start');btn_start.pack(side='left', padx='10', pady='5')
        btn_pen = tk.Button(self, text='画笔', width='10', name='pen');btn_pen.pack(side='left', padx='10', pady='5')
        btn_rect = tk.Button(self, text='矩形', width='10', name='rect');btn_rect.pack(side='left', padx='10', pady='5')
        btn_clear = tk.Button(self, text='清屏', width='10', name='clear');btn_clear.pack(side='left', padx='10', pady='5')
        btn_erasor = tk.Button(self, text='橡皮擦', width='10', name='erasor');btn_erasor.pack(side='left', padx='10', pady='5')
        btn_line = tk.Button(self, text='直线', width='10', name='line');btn_line.pack(side='left', padx='10', pady='5')
        btn_lineArrow = tk.Button(self, text='箭头直线', width='10', name='lineArrow');btn_lineArrow.pack(side='left', padx='10', pady='5')
        btn_color = tk.Button(self, text='颜色', width='10', name='color');btn_color.pack(side='left', padx='10', pady='5')

    def eventManager(self,event):
        name = event.widget.winfo_name()
        print(name)
        if name == "line":
            self.drawpad.bind('<B1-Motion>',self.myline)

    def myline(self, event):
        self.drawpad.delete(self.lastDraw)
        self.lastDraw = self.drawpad.create_line(self.x, self.y, event.x, event.y, fill=self.fgcolor)


if __name__ == "__main__":
    root = tk.Tk()
    root.title('画画本')
    root.geometry(str(win_width)+'x'+str(win_height))
    app = Application(master = root)
    root.mainloop()

老师,代码写到这里,有点问题:

  1. 全程照着打,为啥,我点击直线没有反应

  2. 如下图,为啥要在事件管理中写呢,直接在对应button后面 ,绑定事件不就可以了嘛

    image.png

  3. 问题2截图中第二三行什么意思,老师木有说道,直接就有了

  4. 如下图,这个fill是什么意思

    image.png

Python 全系列/第二阶段:Python 深入与提高/GUI编程(隐藏) 31619楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637