業余磚家

摘要： 一、ES介紹 Elasticsearch 是一個分布式可擴展的實時搜索和分析引擎,一個建立在全文搜索引擎 Apache Lucene? 基礎上的搜索引擎.當然 Elasticsearch 并不僅僅是 Lucene 那么簡單，它不僅包括了全文搜索功能，還可以進行以下工作: (1).分布式實時文件存儲， 閱讀全文

摘要： 1．概述 在Python中，我們可以使用split()函數來按照指定的分隔符對字符串進行分割。默認情況下，split()函數以空格作為分隔符，將字符串分割成一個列表。然而，如果字符串中有多個連續的空格，split()函數會將它們都當作分隔符，導致分割后的列表中會有空白項。本文將教會你如何按照空格分割 閱讀全文

摘要： python-docx官網文檔：https://github.com/python-openxml/python-docx 閱讀全文

摘要： 1. 線程池 為什么要使用線程池？ 1）、多線程中, 線程的數量并非越多越好； 不是線程數量越多，程序的執行效率就越快。線程也是一個對象，是需要占用資源的，線程數量過多的話肯定會消耗過多的資源，同時線程間的上下文切換也是一筆不小的開銷，所以有時候開辟過多的線程不但不會提高程序的執行效率，反而會適得其 閱讀全文

摘要： 1、什么是ZooKeeper？ - 期望回答：ZooKeeper是一個分布式協調服務，提供了高度可靠且具有高性能的分布式應用協調服務。 ZooKeeper是一個開源的分布式協調服務，它提供了一個簡單而健壯的分布式應用程序協調解決方案。其主要設計目標是通過提供高性能、可靠性、且具備高度可擴展性的服務， 閱讀全文

摘要： 背景： 啟動Flink的sql-client.sh，創建Kafka的source端表，然后查詢Kafka的數據時報錯。 報錯信息： 2024-06-18 16:10:12 org.apache.flink.util.FlinkException: Global failure triggered b 閱讀全文

摘要： Java代碼 import org.apache.spark.SparkConf; import org.apache.spark.api.java.function.VoidFunction; import org.apache.spark.streaming.api.java.JavaInput 閱讀全文

摘要： 一、spark直接讀取本地文件系統的文件（不推薦）file前綴地址“file:///”，例如：文件絕對路徑為/data/20240606，那么文件名應該設置為：file:///data/20240606 說明： （1）本地文件系統地址的前綴是“file:///”后邊也必須是全部的絕對路徑，不能用相對 閱讀全文

摘要： 問題 在跑spark任務的時候發現任務不能執行。在查看的時候發現spark work節點的/usr/local/spark/work/目錄占用了很大空間，導致根目錄/滿了。 原因使用spark standalone模式執行任務，沒提交一次任務，在每個節點work目錄下都會生成一個文件夾，命名規則ap 閱讀全文

摘要： package com.sgcc; import java.io.*; import java.text.DecimalFormat; import java.util.ArrayList; import java.util.List; import java.util.Random; public 閱讀全文