MCPcopy Create free account

hub / github.com/MrSuiChuan/data-warehouse-learning / functions

Functions532 in github.com/MrSuiChuan/data-warehouse-learning

Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SlidingWindowDemo.java:59
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SessionWindowDemo.java:60
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/WithIdLenessDemo.java:62
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/SideOutputDemo.java:79
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:60
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/AllowedLatenessDemo.java:77
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PeriodicWatermarkDemo.java:80
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FailureRateRestartStrategyDemo.java:110
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/NoRestartStrategyDemo.java:106
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FixedDelayRestartStrategyDemo.java:110
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:69
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/RocksDBStateBackendDemo.java:103
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/FsStateBackendDemo.java:99
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/MemoryStateBackendDemo.java:102
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:111
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/CheckpointModeDemo.java:101
Methodcancel
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:106
Methodchat
(self, prompt: str, history: List[dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:48
Methodchat
(self, prompt: str, history: List = [], content: str='')
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:67
Methodchat
(self, prompt: str, history: List[Dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:84
Methodchat
(self, prompt: str, history: List[Dict], content: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:105
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffSerializer.java:35
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:26
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:44
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/CompanySerializer.java:44
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:29
Methodclose
()
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:30
MethodcloseCon
关闭连接资源 @param connection
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:86
MethodcloseRes
关闭结果集 @param res
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:62
MethodcloseStmt
关闭预处理对象 @param stmt
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:74
Methodcommit
(YRCanbusTransaction yrCanbusTransaction)
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:224
Functioncompare
比较两个浮点数的大小。 :param a: 第一个浮点数。 :param b: 第二个浮点数。 :return: 比较结果的字符串表示。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:31
Methodconfigure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffSerializer.java:14
Methodconfigure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CompanyDeserailizer.java:11
Methodconfigure
(Map<String, ?> configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:12
Methodconfigure
(Map<String, ?> configs)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:48
Methodconfigure
(Map<String, ?> configs)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/DemoPartitioner.java:30
Methodconfigure
(Map configs, boolean isKey)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/CompanySerializer.java:10
Methodconfigure
(Map<String, ?> map)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:36
Methodconfigure
(Map<String, ?> map)
src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:34
Functioncount_letter_in_string
统计字符串中某个字母的出现次数。 :param a: 要搜索的字符串。 :param b: 要统计的字母。 :return: 字母在字符串中出现的次数。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:45
MethodcreateTimestampAssigner
(TimestampAssignerSupplier.Context context)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:81
MethodcreateTopic
代码清单4-1
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/TopicCommandUtils.java:14
MethodcreateTopic
()
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/KafkaAdminTopicOperation.java:29
MethodcreateWatermarkGenerator
(WatermarkGeneratorSupplier.Context context)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:76
MethoddeleteTopic
()
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/KafkaAdminTopicOperation.java:63
MethoddescribeTopic
代码清单4-2
src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/TopicCommandUtils.java:28
Methoddeserialize
(String topic, byte[] data)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CompanyDeserailizer.java:14
Methoddeserialize
(String topic, byte[] data)
src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ProtostuffDeserializer.java:16
Methodeval
(String jsonStr)
src/main/java/org/bigdatatechcir/warehouse/flink/udf/JsonDisplaysArrayParser.java:18
Methodeval
(String jsonStr)
src/main/java/org/bigdatatechcir/warehouse/flink/udf/JsonActionsArrayParser.java:18
MethodextractTimestamp
(Tuple3<String, Integer, Long> element, long recordTimestamp)
src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:132
Methodforward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:59
Methodforward
(self, x: torch.Tensor, freqs_cos: torch.Tensor, freqs_sin: torch.Tensor)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:180
Methodforward
(self, x, freqs_cos, freqs_sin)
src/main/java/org/bigdatatechcir/learn_llm/model/k_model.py:275
Methodforward
- 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
Methodforward
(self, q: torch.Tensor, k: torch.Tensor, v: torch.Tensor)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:58
Methodforward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:112
Methodforward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:148
Methodforward
分别通过 N 层 Encoder Layer
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:165
Methodforward
(self, x, enc_out)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:186
Methodforward
Pass the input (and mask) through each layer in turn.
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:206
Methodforward
(self, x)
src/main/java/org/bigdatatechcir/learn_llm/transformer/transformer.py:233
MethodgenerateBirthday
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:49
MethodgenerateBrand
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:84
MethodgenerateCategory
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:112
MethodgenerateCategoryData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/CategoryDataGenerator.java:20
MethodgenerateColor
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:80
MethodgenerateDateTime
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:100
MethodgenerateEmail
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:45
MethodgenerateFinancialData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/FinancialDataGenerator.java:23
MethodgenerateGender
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:57
MethodgenerateNickName
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:30
MethodgenerateOrderDetailData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/OrderDetailGenerator.java:22
MethodgenerateOrderNo
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:88
MethodgenerateOrderStatusLog
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/OrderStatusLogGenerator.java:21
MethodgeneratePassword
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:34
MethodgeneratePaymentData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/PaymentGenerator.java:23
MethodgenerateProductDetailData
(int skuCount, int spuCount)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/ProductDetailGenerator.java:21
MethodgenerateRefundData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/RefundGenerator.java:24
MethodgenerateSeckillData
(int count)
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/generator/SeckillDataGenerator.java:22
MethodgenerateSku
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:92
MethodgenerateSpuCode
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:108
MethodgenerateUUID
()
src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/util/RandomUtil.java:96
MethodgetDataSource
获取连接池对象 @return
src/main/java/org/bigdatatechcir/learn_flink/util/DruidUtil.java:37
Methodget_content
(self, max_token_len: int = 600, cover_content: int = 150)
src/main/java/org/bigdatatechcir/learn_llm/rag/utils.py:51
Methodget_content
(self)
src/main/java/org/bigdatatechcir/learn_llm/rag/utils.py:157
Functionget_current_datetime
获取当前日期和时间。 :return: 当前日期和时间的字符串表示。
src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:4
Methodget_embedding
(self, text: str, model: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:29
Methodget_embedding
(self, text: str, model: str = "text-embedding-3-large")
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:56
Methodget_embedding
(self, text: str)
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:94
Methodget_embedding
(self, text: str, model: str='text-embedding-v1')
src/main/java/org/bigdatatechcir/learn_llm/rag/Embeddings.py:112
Methodget_vector
(self, EmbeddingModel: BaseEmbeddings)
src/main/java/org/bigdatatechcir/learn_llm/rag/VectorBase.py:23
Functiongroup_texts
(examples)
src/main/java/org/bigdatatechcir/learn_llm/llm/pretrain.py:209
MethodhasKeyContext
()
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:209
MethodinitializeState
(FunctionInitializationContext context)
src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:93
MethodinitializeState
(FunctionInitializationContext context)
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:106
Methodinvoke
(Tuple3<String, Integer, Long> value, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:117
Methodinvoke
(Tuple3<String, Integer, Long> value, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:132
Methodinvoke
(YRCanbusTransaction yrCanbusTransaction, YRcanbusStore yRcanbusStore, Context context)
src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:209
← previousnext →301–400 of 532, ranked by callers