path	# lines of code	# active days	days since first update	days since last update	# commits	# contributors	first updated	last updated	first contributor	last contributor
core/src/main/resources/logback.xml	36	8	279	185	13	1	2022-11-06	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java	94	16	297	188	18	2	2022-10-19	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/running/RocketMQClient.java	42	7	297	179	8	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContext.java	22	13	297	188	17	2	2022-10-19	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java	125	16	297	188	21	2	2022-10-19	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/running/Processor.java	7	4	297	220	6	1	2022-10-19	2023-01-04	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java	222	35	297	71	51	4	2022-10-19	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java	53	20	297	179	25	2	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java	68	14	297	36	18	6	2022-10-19	2023-07-07	unclerangoo@gmail.com	44845151+elenacliu@users.noreply.github.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/TopologyBuilder.java	73	7	297	188	9	1	2022-10-19	2023-02-05	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SinkFactory.java	22	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/real/RealProcessorFactory.java	7	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java	21	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java	24	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/AbstractGraphNode.java	49	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SourceGraphNode.java	23	4	297	218	4	1	2022-10-19	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ShuffleProcessorNode.java	32	11	297	218	11	1	2022-10-19	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/GraphNode.java	12	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/ProcessorNode.java	56	5	297	179	7	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual/SinkGraphNode.java	23	4	297	218	4	1	2022-10-19	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/Pipeline.java	70	9	297	179	11	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java	177	21	297	163	32	3	2022-10-19	2023-03-02	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java	20	16	297	163	20	3	2022-10-19	2023-03-02	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/StreamBuilder.java	40	10	297	179	12	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java	102	14	297	177	17	1	2022-10-19	2023-02-16	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/JoinedStream.java	136	11	276	221	17	1	2022-11-09	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java	196	22	297	71	29	6	2022-10-19	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java	24	10	297	71	13	4	2022-10-19	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java	19	12	297	177	14	1	2022-10-19	2023-02-16	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java	34	20	276	179	28	2	2022-11-09	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/util/Pair.java	31	5	289	237	6	1	2022-10-27	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java	115	24	296	185	27	2	2022-10-20	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/util/RocketMQUtil.java	178	11	246	179	16	1	2022-12-09	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueSerializer.java	4	2	297	237	2	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/serialization/ShuffleProtocol.java	39	7	297	237	7	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java	47	9	295	188	10	2	2022-10-21	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/serialization/KeyValueDeserializer.java	7	3	297	237	3	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java	41	7	295	188	7	2	2022-10-21	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/ValueMapperAction.java	4	5	297	237	5	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/ValueJoinAction.java	4	4	275	237	5	1	2022-11-10	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/ForeachAction.java	5	4	297	237	4	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/FilterAction.java	5	6	297	218	6	1	2022-10-19	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java	36	12	297	71	12	5	2022-10-19	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java	245	14	228	71	21	5	2022-12-27	2023-06-02	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java	117	6	228	188	8	2	2022-12-27	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java	118	19	275	71	29	5	2022-11-10	2023-06-02	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SumAggregate.java	28	2	223	221	2	1	2023-01-01	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/FilterSupplier.java	30	6	297	237	6	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/KeySelectSupplier.java	28	8	297	221	8	1	2022-10-19	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java	68	18	297	188	19	2	2022-10-19	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SinkSupplier.java	70	15	297	179	19	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AddTagSupplier.java	32	3	275	237	5	1	2022-11-10	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java	243	34	297	71	52	5	2022-10-19	2023-06-02	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/TimestampSelectorSupplier.java	30	8	291	188	8	2	2022-10-25	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ForeachSupplier.java	28	7	297	237	7	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java	41	6	219	71	6	5	2023-01-05	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/PrintSupplier.java	36	5	297	237	5	1	2022-10-19	2022-12-18	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java	55	13	297	188	15	2	2022-10-19	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java	69	6	223	188	7	2	2023-01-01	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/function/AggregateAction.java	4	7	297	221	7	1	2022-10-19	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java	54	2	188	184	3	2	2023-02-05	2023-02-09	jargon9@pku.edu.cn	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/Accumulator.java	8	3	228	218	3	1	2022-12-27	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/CountAccumulator.java	29	2	228	221	2	1	2022-12-27	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/MinAccumulator.java	36	2	228	221	2	1	2022-12-27	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/function/SelectAction.java	5	2	229	221	2	1	2022-12-26	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java	161	16	297	96	17	3	2022-10-19	2023-05-08	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java	314	37	296	53	48	5	2022-10-20	2023-06-20	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java	161	23	297	185	32	2	2022-10-19	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/state/StateStore.java	19	16	297	218	19	1	2022-10-19	2023-01-06	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java	19	19	297	185	25	2	2022-10-19	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/WindowInfo.java	63	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/Window.java	30	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/WindowState.java	175	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/WindowStore.java	73	4	221	188	6	2	2023-01-03	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/window/JoinType.java	5	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/StreamType.java	5	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/Time.java	41	4	221	188	5	2	2023-01-03	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AbstractWindowFire.java	24	4	190	179	5	1	2023-02-03	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java	57	5	194	185	8	2	2023-01-30	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java	170	8	194	179	11	2	2023-01-30	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java	63	6	194	24	9	3	2023-01-30	2023-07-19	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java	59	5	194	185	8	2	2023-01-30	2023-02-08	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/WindowFire.java	11	4	194	188	5	2	2023-01-30	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java	65	6	194	24	9	3	2023-01-30	2023-07-19	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java	241	8	192	24	10	4	2023-02-01	2023-07-19	unclerangoo@gmail.com	karp@apache.org
core/src/main/java/org/apache/rocketmq/streams/core/window/WindowKey.java	98	4	221	188	5	2	2023-01-03	2023-02-05	unclerangoo@gmail.com	jargon9@pku.edu.cn
core/src/main/java/org/apache/rocketmq/streams/core/window/TimeType.java	5	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/window/WindowBuilder.java	23	1	221	221	2	1	2023-01-03	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/RocketMQStream.java	60	14	297	179	20	1	2022-10-19	2023-02-14	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/exception/RStreamsException.java	18	1	220	220	2	1	2023-01-04	2023-01-04	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/exception/RecoverStateStoreThrowable.java	17	1	220	220	2	1	2023-01-04	2023-01-04	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/exception/DeserializeThrowable.java	18	1	220	220	2	1	2023-01-04	2023-01-04	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/exception/DataProcessThrowable.java	17	1	220	220	2	1	2023-01-04	2023-01-04	unclerangoo@gmail.com	unclerangoo@gmail.com
core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java	13	15	297	71	17	4	2022-10-19	2023-06-02	unclerangoo@gmail.com	nizeze.ni@alibaba-inc.com
core/src/main/java/org/apache/rocketmq/streams/core/metadata/Data.java	52	9	291	221	9	1	2022-10-25	2023-01-03	unclerangoo@gmail.com	unclerangoo@gmail.com