Functions — github.com/MrSuiChuan/data-warehouse-learning

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

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

⨍ Functions 532◇ Types & classes 165

Methodload_model

(self)

src/main/java/org/bigdatatechcir/learn_llm/rag/LLM.py:40

Methodload_vector

(self, path: str = 'storage')

src/main/java/org/bigdatatechcir/learn_llm/rag/VectorBase.py:39

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_dinky/GlobalWindowDemo.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part4_kafka_topic/KafkaAdminTopicOperation.java:80

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ThirdMultiConsumerThreadDemo.java:32

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CheckOffsetAndPosition.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitSyncPartition.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/KafkaConsumerAnalysis_3.java:39

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/KafkaConsumerAnalysis.java:28

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitSyncBatch.java:32

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitSyncSingle.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitSync.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/SeekToEnd.java:28

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/KafkaConsumerAnalysis_2.java:46

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/SeekDemo.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/KafkaConsumerAnalysis_1.java:47

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/FirstMultiConsumerThreadDemo.java:28

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitAsyncCallback.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CommitSyncInRebalance.java:26

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/SeekDemoAssignment.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerSelfSerializer.java:15

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/KafkaProducerSyncDemo.java:22

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/KafkaUserPartitioner.java:15

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/KafkaProducerAsyncDemo.java:18

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part1_kafka_overwrite/KafkaConsumerDemo.java:19

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_kafka/part1_kafka_overwrite/KafkaProducerDemo.java:20

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/warehouse/datageneration/business_code/BusinessApplication.java:53

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/warehouse/datageneration/userlog_code/UserLogApplication.java:36

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/warehouse/flink/tools/SqlSyntaxValidationRunner.java:19

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/KeyedStateDemo.java:31

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:26

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/GlobalWindowDemo.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/TumblingWindowDemo.java:27

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SlidingWindowDemo.java:27

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part4_flink_window/SessionWindowDemo.java:27

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/RegularFullJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/IntervalLeftJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/RegularInnerJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/IntervalRightJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/IntervalInnerJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/RegularRightJoinDemo.java:7

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part11_flink_join/RegularLeftJoinDemo.java:7

Methodmain

主函数，执行WordCount示例程序。 @param args 命令行参数，通过CLI库解析为程序参数。 @throws Exception 如果程序执行过程中遇到异常。

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/StreamingTableSetApiDemo.java:16

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/TableApiDemo.java:16

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/StreamSQLDemo.java:11

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/ProcessFunctionDemo.java:14

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/WithIdLenessDemo.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/SideOutputDemo.java:31

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:32

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/AllowedLatenessDemo.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PeriodicWatermarkDemo.java:30

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part3_flink_time/IngestionTimeDemo.java:15

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part3_flink_time/EventTimeDemo.java:16

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part3_flink_time/ProcessTimeDemo.java:12

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FailureRateRestartStrategyDemo.java:35

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/NoRestartStrategyDemo.java:35

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FixedDelayRestartStrategyDemo.java:36

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part9_flink_state_ttl/StateTtlDemo.java:29

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/RocksDBStateBackendDemo.java:36

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/FsStateBackendDemo.java:35

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/MemoryStateBackendDemo.java:35

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:44

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/CheckpointModeDemo.java:34

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:39

Methodmain

(String[] args)

src/main/java/org/bigdatatechcir/learn_flink/part2_flink_local_model/SocketWordCountDemo.java:18

Functionmul

计算两个浮点数的积。 :param a: 第一个浮点数。 :param b: 第二个浮点数。 :return: 两个浮点数的积。

src/main/java/org/bigdatatechcir/learn_llm/agent/src/tools.py:22

MethodonAcknowledgement

(RecordMetadata recordMetadata, Exception e)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:20

MethodonAcknowledgement

(RecordMetadata recordMetadata, Exception e)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:21

MethodonCommit

(Map<TopicPartition, OffsetAndMetadata> offsets)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:38

MethodonComplete

(Map<TopicPartition, OffsetAndMetadata> offsets, Exception exceptio

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/OffsetCommitAsyncCallback.java:42

MethodonCompletion

(RecordMetadata metadata, Exception exception)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/KafkaProducerAsyncDemo.java:45

MethodonConsume

( ConsumerRecords<String, String> records)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ConsumerInterceptorTTL.java:16

MethodonEvent

(Tuple3<String, Integer, Long> event, long eventTimestamp, WatermarkOutput output)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:143

MethodonPartitionsAssigned

(Collection<TopicPartition> partitions)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CommitSyncInRebalance.java:37

MethodonPartitionsRevoked

(Collection<TopicPartition> partitions)

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/CommitSyncInRebalance.java:32

MethodonPeriodicEmit

(WatermarkOutput output)

src/main/java/org/bigdatatechcir/learn_flink/part5_flink_watermark/PunctuatedWatermarkDemo.java:156

MethodonSend

(ProducerRecord<String, String> producerRecord)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefix.java:12

MethodonSend

(ProducerRecord<String, String> producerRecord)

src/main/java/org/bigdatatechcir/learn_kafka/part2_kafka_producer/ProducerInterceptorPrefixPlus.java:13

MethodonTimer

(long timestamp, OnTimerContext ctx, Collector<String> out)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/ProcessFunctionDemo.java:92

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/KeyedStateDemo.java:110

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/ProcessFunctionDemo.java:73

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FailureRateRestartStrategyDemo.java:137

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/NoRestartStrategyDemo.java:133

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part10_flink_restart/FixedDelayRestartStrategyDemo.java:137

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/RocksDBStateBackendDemo.java:130

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/FsStateBackendDemo.java:126

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part7_flink_statebackend/MemoryStateBackendDemo.java:129

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:138

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/CheckpointModeDemo.java:128

Methodopen

(Configuration parameters)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/GenericWriteAheadSinkDemo.java:133

Methodpersist

(self, path: str = 'storage')

src/main/java/org/bigdatatechcir/learn_llm/rag/VectorBase.py:30

MethodpreCommit

(YRCanbusTransaction yrCanbusTransaction)

src/main/java/org/bigdatatechcir/learn_flink/part8_flink_checkpoint/TwoPhaseCommitSinkFunctionDemo.java:219

MethodprocessElement

(Event value, Context ctx, Collector<String> out)

src/main/java/org/bigdatatechcir/learn_flink/part1_flink_apis/ProcessFunctionDemo.java:79

Methodquery

(self, query: str, EmbeddingModel: BaseEmbeddings, k: int = 1)

src/main/java/org/bigdatatechcir/learn_llm/rag/VectorBase.py:48

Methodrun

(SourceContext<String> ctx)

src/main/java/org/bigdatatechcir/learn_dinky/GlobalWindowDemo.java:96

Methodrun

()

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ThirdMultiConsumerThreadDemo.java:53

Methodrun

()

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/ThirdMultiConsumerThreadDemo.java:79

Methodrun

()

src/main/java/org/bigdatatechcir/learn_kafka/part3_kafka_consumer/FirstMultiConsumerThreadDemo.java:44

Methodrun

(SourceContext<String> ctx)

src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/KeyedStateDemo.java:56

Methodrun

(SourceContext<String> ctx)

src/main/java/org/bigdatatechcir/learn_flink/part6_flink_state/OperatorStateDemo.java:34

← previous next →401–500 of 532, ranked by callers