Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MrSuiChuan/data-warehouse-learning
/ functions
Functions
532 in github.com/MrSuiChuan/data-warehouse-learning
⨍
Functions
532
◇
Types & classes
165
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SlidingWindowDemo.java:59
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SessionWindowDemo.java:60
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/WithIdLenessDemo.java:62
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/SideOutputDemo.java:79
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:60
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/AllowedLatenessDemo.java:77
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PeriodicWatermarkDemo.java:80
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FailureRateRestartStrategyDemo.java:110
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/NoRestartStrategyDemo.java:106
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FixedDelayRestartStrategyDemo.java:110
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:69
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/RocksDBStateBackendDemo.java:103
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/FsStateBackendDemo.java:99
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/MemoryStateBackendDemo.java:102
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:111
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/CheckpointModeDemo.java:101
Method
cancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:106
Method
chat
(self, prompt: str, history: List[dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:48
Method
chat
(self, prompt: str, history: List = [], content: str='')
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:67
Method
chat
(self, prompt: str, history: List[Dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:84
Method
chat
(self, prompt: str, history: List[Dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:105
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffSerializer.java:35
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:26
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:44
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/CompanySerializer.java:44
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:29
Method
close
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:30
Method
closeCon
关闭连接资源 @param connection
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:86
Method
closeRes
关闭结果集 @param res
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:62
Method
closeStmt
关闭预处理对象 @param stmt
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:74
Method
commit
(YRCanbusTransaction yrCanbusTransaction)
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:224
Function
compare
比较两个浮点数的大小。 :param a: 第一个浮点数。 :param b: 第二个浮点数。 :return: 比较结果的字符串表示。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:31
Method
configure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffSerializer.java:14
Method
configure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CompanyDeserailizer.java:11
Method
configure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:12
Method
configure
(Map<String, ?> configs)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:48
Method
configure
(Map<String, ?> configs)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/DemoPartitioner.java:30
Method
configure
(Map configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/CompanySerializer.java:10
Method
configure
(Map<String, ?> map)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:36
Method
configure
(Map<String, ?> map)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:34
Function
count_letter_in_string
统计字符串中某个字母的出现次数。 :param a: 要搜索的字符串。 :param b: 要统计的字母。 :return: 字母在字符串中出现的次数。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:45
Method
createTimestampAssigner
(TimestampAssignerSupplier.Context context)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:81
Method
createTopic
代码清单4-1
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/TopicCommandUtils.java:14
Method
createTopic
()
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/KafkaAdminTopicOperation.java:29
Method
createWatermarkGenerator
(WatermarkGeneratorSupplier.Context context)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:76
Method
deleteTopic
()
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/KafkaAdminTopicOperation.java:63
Method
describeTopic
代码清单4-2
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/TopicCommandUtils.java:28
Method
deserialize
(String topic, byte[] data)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CompanyDeserailizer.java:14
Method
deserialize
(String topic, byte[] data)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:16
Method
eval
(String jsonStr)
src/main/java/org/bigdatatechcir/warehouse/flink/udf/JsonDisplaysArrayParser.java:18
Method
eval
(String jsonStr)
src/main/java/org/bigdatatechcir/warehouse/flink/udf/JsonActionsArrayParser.java:18
Method
extractTimestamp
(Tuple3<String, Integer, Long> element, long recordTimestamp)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:132
Method
forward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:59
Method
forward
(self, x: torch.Tensor, freqs_cos: torch.Tensor, freqs_sin: torch.Tensor)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:180
Method
forward
(self, x, freqs_cos, freqs_sin)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:275
Method
forward
- tokens: Optional[torch.Tensor], 输入 token 张量。 - targets: Optional[torch.Tensor], 目标 token 张量。 - kv_cache: bool, 是否使用键值缓存。
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:338
Method
forward
(self, q: torch.Tensor, k: torch.Tensor, v: torch.Tensor)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:58
Method
forward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:112
Method
forward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:148
Method
forward
分别通过 N 层 Encoder Layer
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:165
Method
forward
(self, x, enc_out)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:186
Method
forward
Pass the input (and mask) through each layer in turn.
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:206
Method
forward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:233
Method
generateBirthday
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:49
Method
generateBrand
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:84
Method
generateCategory
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:112
Method
generateCategoryData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/CategoryDataGenerator.java:20
Method
generateColor
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:80
Method
generateDateTime
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:100
Method
generateEmail
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:45
Method
generateFinancialData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/FinancialDataGenerator.java:23
Method
generateGender
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:57
Method
generateNickName
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:30
Method
generateOrderDetailData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/OrderDetailGenerator.java:22
Method
generateOrderNo
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:88
Method
generateOrderStatusLog
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/OrderStatusLogGenerator.java:21
Method
generatePassword
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:34
Method
generatePaymentData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/PaymentGenerator.java:23
Method
generateProductDetailData
(int skuCount, int spuCount)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/ProductDetailGenerator.java:21
Method
generateRefundData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/RefundGenerator.java:24
Method
generateSeckillData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/SeckillDataGenerator.java:22
Method
generateSku
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:92
Method
generateSpuCode
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:108
Method
generateUUID
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:96
Method
getDataSource
获取连接池对象 @return
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:37
Method
get_content
(self, max_token_len: int = 600, cover_content: int = 150)
src/main/java/org/bigdatatechcir/learn_llm/rag/utils.py:51
Method
get_content
(self)
src/main/java/org/bigdatatechcir/learn_llm/rag/utils.py:157
Function
get_current_datetime
获取当前日期和时间。 :return: 当前日期和时间的字符串表示。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:4
Method
get_embedding
(self, text: str, model: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:29
Method
get_embedding
(self, text: str, model: str = "text-embedding-3-large")
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:56
Method
get_embedding
(self, text: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:94
Method
get_embedding
(self, text: str, model: str='text-embedding-v1')
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:112
Method
get_vector
(self, EmbeddingModel: BaseEmbeddings)
src/main/java/org/bigdatatechcir/learn_llm/rag/VectorBase.py:23
Function
group_texts
(examples)
src/main/java/org/bigdatatechcir/learn_llm/llm/pretrain.py:209
Method
hasKeyContext
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:209
Method
initializeState
(FunctionInitializationContext context)
src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:93
Method
initializeState
(FunctionInitializationContext context)
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:106
Method
invoke
(Tuple3<String, Integer, Long> value, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:117
Method
invoke
(Tuple3<String, Integer, Long> value, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:132
Method
invoke
(YRCanbusTransaction yrCanbusTransaction, YRcanbusStore yRcanbusStore, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:209
← previous
next →
301–400 of 532, ranked by callers