apache / rocketmq-streams
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 95 files with 5,796 lines of code in files.
    • 0 files that are 366+ days old (0 lines of code)
    • 95 files that are 181-365 days old (5,796 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
0% | 100% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 95 files with 5,796 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 65 files have been last changed 181-365 days ago (2,631 lines of code)
    • 16 files have been last changed 91-180 days ago (1,276 lines of code)
    • 11 files have been last changed 31-90 days ago (1,520 lines of code)
    • 3 files have been last changed 1-30 days ago (369 lines of code)
0% | 45% | 22% | 26% | 6%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, txt, sh, gitignore, md, json, yml, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java0% | 100% | 0% | 0% | 0%
xml0% | 100% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 45% | 22% | 26% | 6%
xml0% | 100% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
core0% | 100% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
core0% | 45% | 22% | 26% | 6%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 2022-10-19 2023-06-02 34 5 unclerangoo@gmail.com karp@apache.org
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 2022-10-19 2023-06-02 35 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 2022-10-19 2023-06-02 22 6 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 2022-10-19 2023-03-02 21 3 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21 2022-10-19 2023-05-08 16 3 unclerangoo@gmail.com karp@apache.org
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7 2022-10-19 2023-02-08 23 2 unclerangoo@gmail.com unclerangoo@gmail.com
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12 2022-10-19 2023-02-16 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8 2022-10-19 2023-02-05 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 2022-10-19 2023-02-14 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5 2022-10-19 2023-02-14 15 1 unclerangoo@gmail.com unclerangoo@gmail.com
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5 2022-10-19 2023-07-07 14 6 unclerangoo@gmail.com 44845151+elenacliu@users.no...
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5 2022-10-19 2023-02-05 18 2 unclerangoo@gmail.com jargon9@pku.edu.cn
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4 2022-10-19 2023-02-14 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 56 8 2022-10-19 2023-02-14 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AbstractWindowProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 53 2 2022-10-19 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 49 7 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4 2022-10-19 2023-02-14 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4 2022-10-19 2023-02-14 10 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProtocol.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 39 1 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4 2022-10-19 2023-06-02 12 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
PrintSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 3 2022-10-19 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2022-10-19 2023-01-06 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-19 2022-12-18 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeySelectSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2023-01-03 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 24 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
GroupedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 24 - 2022-10-19 2023-06-02 10 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
SourceGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamContext.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 22 - 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SinkFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 22 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 21 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 20 - 2022-10-19 2023-03-02 16 3 unclerangoo@gmail.com unclerangoo@gmail.com
RStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 19 - 2022-10-19 2023-02-16 12 1 unclerangoo@gmail.com unclerangoo@gmail.com
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2022-10-19 2023-01-06 16 1 unclerangoo@gmail.com unclerangoo@gmail.com
Constant.java
in core/src/main/java/org/apache/rocketmq/streams/core/common
 19 - 2022-10-19 2023-02-08 19 2 unclerangoo@gmail.com unclerangoo@gmail.com
StreamConfig.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 13 - 2022-10-19 2023-06-02 15 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 12 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
Processor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 7 - 2022-10-19 2023-01-04 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
RealProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 7 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeyValueDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 7 1 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2022-12-18 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2023-01-06 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeyValueSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 4 - 2022-10-19 2022-12-18 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
ValueMapperAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-10-19 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
AggregateAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-10-19 2023-01-03 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 2022-10-20 2023-06-20 37 5 unclerangoo@gmail.com karp@apache.org
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ValueJoinAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-11-10 2022-12-18 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
ValueMapperAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-10-19 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeyValueSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 4 - 2022-10-19 2022-12-18 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2022-12-18 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeyValueDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 7 1 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
RealProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 7 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
GraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 12 - 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 21 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 22 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceFactory.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/real
 24 3 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ForeachSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-19 2022-12-18 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pair.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 31 6 2022-10-27 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
AddTagSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 32 5 2022-11-10 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
PrintSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 3 2022-10-19 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProtocol.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization
 39 1 2022-10-19 2022-12-18 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 49 7 2022-10-19 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
AggregateAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-10-19 2023-01-03 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
TimeType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
SelectAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-12-26 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 23 3 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
KeySelectSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 4 2022-10-19 2023-01-03 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
SumAggregate.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 2 2023-01-01 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
CountAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 29 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
Window.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 30 6 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
MinAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 36 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12 2022-10-25 2023-01-03 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowInfo.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 63 15 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 2022-11-09 2023-01-03 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
Processor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 7 - 2022-10-19 2023-01-04 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
DataProcessThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
RecoverStateStoreThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
DeserializeThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStreamsException.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
FilterAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-10-19 2023-01-06 6 1 unclerangoo@gmail.com unclerangoo@gmail.com
Accumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 8 - 2022-12-27 2023-01-06 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
StateStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 19 - 2022-10-19 2023-01-06 16 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
SourceGraphNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 23 3 2022-10-19 2023-01-06 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
ShuffleProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 32 3 2022-10-19 2023-01-06 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 11 1 2023-01-30 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
StreamContext.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 22 - 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-25 2023-02-05 8 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1 2022-10-21 2023-02-05 7 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3 2022-10-21 2023-02-05 9 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AvgAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 54 8 2023-02-05 2023-02-09 2 2 jargon9@pku.edu.cn unclerangoo@gmail.com
AbstractWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 24 2 2023-02-03 2023-02-14 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19 2023-02-01 2023-07-19 8 4 unclerangoo@gmail.com karp@apache.org
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4 2023-01-30 2023-02-14 8 2 unclerangoo@gmail.com unclerangoo@gmail.com
AccumulatorSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 65 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
AccumulatorWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 59 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
AggregateWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 57 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
WindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 11 1 2023-01-30 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4 2023-01-05 2023-06-02 6 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
RStreamsException.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
DeserializeThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 18 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
RecoverStateStoreThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
DataProcessThrowable.java
in core/src/main/java/org/apache/rocketmq/streams/core/exception
 17 5 2023-01-04 2023-01-04 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowState.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 175 17 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowKey.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 98 14 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
WindowInfo.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 63 15 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Window.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 30 6 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 23 3 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
TimeType.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 5 - 2023-01-03 2023-01-03 1 1 unclerangoo@gmail.com unclerangoo@gmail.com
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5 2023-01-01 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SumAggregate.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 28 2 2023-01-01 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9 2022-12-27 2023-06-02 14 5 unclerangoo@gmail.com karp@apache.org
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8 2022-12-27 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
MinAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 36 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
CountAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 29 6 2022-12-27 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
Accumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 8 - 2022-12-27 2023-01-06 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
SelectAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 5 - 2022-12-26 2023-01-03 2 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 2022-12-09 2023-02-14 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6 2022-11-10 2023-06-02 19 5 unclerangoo@gmail.com karp@apache.org
AddTagSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 32 5 2022-11-10 2022-12-18 3 1 unclerangoo@gmail.com unclerangoo@gmail.com
ValueJoinAction.java
in core/src/main/java/org/apache/rocketmq/streams/core/function
 4 - 2022-11-10 2022-12-18 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 136 9 2022-11-09 2023-01-03 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
OperatorNameMaker.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 34 2 2022-11-09 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
logback.xml
in core/src/main/resources
 36 - 2022-11-06 2023-02-08 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
Pair.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 31 6 2022-10-27 2022-12-18 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
Data.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 52 12 2022-10-25 2023-01-03 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-25 2023-02-05 8 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3 2022-10-21 2023-02-05 9 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1 2022-10-21 2023-02-05 7 2 unclerangoo@gmail.com jargon9@pku.edu.cn
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 2022-10-20 2023-06-20 37 5 unclerangoo@gmail.com karp@apache.org
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7 2022-10-20 2023-02-08 24 2 unclerangoo@gmail.com unclerangoo@gmail.com
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 2022-10-19 2023-06-02 34 5 unclerangoo@gmail.com karp@apache.org
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 2022-10-19 2023-06-02 35 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 2022-10-19 2023-06-02 22 6 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 2022-10-19 2023-03-02 21 3 unclerangoo@gmail.com unclerangoo@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
IdleWindowScaner.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 241 19 2023-02-01 2023-07-19 8 4 unclerangoo@gmail.com karp@apache.org
AccumulatorSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 65 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
AggregateSessionWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 63 2 2023-01-30 2023-07-19 6 3 unclerangoo@gmail.com karp@apache.org
MessageQueueListenerWrapper.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 68 5 2022-10-19 2023-07-07 14 6 unclerangoo@gmail.com 44845151+elenacliu@users.no...
RocketMQStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 314 13 2022-10-20 2023-06-20 37 5 unclerangoo@gmail.com karp@apache.org
WindowAccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 245 9 2022-12-27 2023-06-02 14 5 unclerangoo@gmail.com karp@apache.org
WindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 243 9 2022-10-19 2023-06-02 34 5 unclerangoo@gmail.com karp@apache.org
WorkerThread.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 222 10 2022-10-19 2023-06-02 35 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GroupedStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 196 14 2022-10-19 2023-06-02 22 6 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
JoinWindowAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 118 6 2022-11-10 2023-06-02 19 5 unclerangoo@gmail.com karp@apache.org
MultiValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 41 4 2023-01-05 2023-06-02 6 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
ValueChangeSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 36 4 2022-10-19 2023-06-02 12 5 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
GroupedStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 24 - 2022-10-19 2023-06-02 10 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
StreamConfig.java
in core/src/main/java/org/apache/rocketmq/streams/core/metadata
 13 - 2022-10-19 2023-06-02 15 4 unclerangoo@gmail.com nizeze.ni@alibaba-inc.com
AbstractStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 21 2022-10-19 2023-05-08 16 3 unclerangoo@gmail.com karp@apache.org
WindowStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 177 9 2022-10-19 2023-03-02 21 3 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 20 - 2022-10-19 2023-03-02 16 3 unclerangoo@gmail.com unclerangoo@gmail.com
RStreamImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 102 12 2022-10-19 2023-02-16 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
RStream.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 19 - 2022-10-19 2023-02-16 12 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQUtil.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 178 9 2022-12-09 2023-02-14 11 1 unclerangoo@gmail.com unclerangoo@gmail.com
JoinWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 170 4 2023-01-30 2023-02-14 8 2 unclerangoo@gmail.com unclerangoo@gmail.com
Pipeline.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 70 11 2022-10-19 2023-02-14 9 1 unclerangoo@gmail.com unclerangoo@gmail.com
SinkSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 70 5 2022-10-19 2023-02-14 15 1 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQStream.java
in core/src/main/java/org/apache/rocketmq/streams/core
 60 4 2022-10-19 2023-02-14 14 1 unclerangoo@gmail.com unclerangoo@gmail.com
ProcessorNode.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology/virtual
 56 8 2022-10-19 2023-02-14 5 1 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractWindowProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 53 2 2022-10-19 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
RocketMQClient.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 42 4 2022-10-19 2023-02-14 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
StreamBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/rstream
 40 4 2022-10-19 2023-02-14 10 1 unclerangoo@gmail.com unclerangoo@gmail.com
OperatorNameMaker.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 34 2 2022-11-09 2023-02-14 20 2 unclerangoo@gmail.com unclerangoo@gmail.com
AbstractWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 24 2 2023-02-03 2023-02-14 4 1 unclerangoo@gmail.com unclerangoo@gmail.com
AvgAccumulator.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator
 54 8 2023-02-05 2023-02-09 2 2 jargon9@pku.edu.cn unclerangoo@gmail.com
RocksDBStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/state
 161 7 2022-10-19 2023-02-08 23 2 unclerangoo@gmail.com unclerangoo@gmail.com
Utils.java
in core/src/main/java/org/apache/rocketmq/streams/core/util
 115 7 2022-10-20 2023-02-08 24 2 unclerangoo@gmail.com unclerangoo@gmail.com
AccumulatorWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 59 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
AggregateWindowFire.java
in core/src/main/java/org/apache/rocketmq/streams/core/window/fire
 57 2 2023-01-30 2023-02-08 5 2 unclerangoo@gmail.com unclerangoo@gmail.com
logback.xml
in core/src/main/resources
 36 - 2022-11-06 2023-02-08 8 1 unclerangoo@gmail.com unclerangoo@gmail.com
Constant.java
in core/src/main/java/org/apache/rocketmq/streams/core/common
 19 - 2022-10-19 2023-02-08 19 2 unclerangoo@gmail.com unclerangoo@gmail.com
StreamContextImpl.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 125 14 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
JoinAggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 117 8 2022-12-27 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
WindowKey.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 98 14 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AbstractProcessor.java
in core/src/main/java/org/apache/rocketmq/streams/core/running
 94 6 2022-10-19 2023-02-05 16 2 unclerangoo@gmail.com jargon9@pku.edu.cn
TopologyBuilder.java
in core/src/main/java/org/apache/rocketmq/streams/core/topology
 73 8 2022-10-19 2023-02-05 7 1 unclerangoo@gmail.com unclerangoo@gmail.com
WindowStore.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 73 5 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AccumulatorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 69 5 2023-01-01 2023-02-05 6 2 unclerangoo@gmail.com jargon9@pku.edu.cn
AggregateSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 68 5 2022-10-19 2023-02-05 18 2 unclerangoo@gmail.com jargon9@pku.edu.cn
SourceSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 55 6 2022-10-19 2023-02-05 13 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonDeserializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl
 47 3 2022-10-21 2023-02-05 9 2 unclerangoo@gmail.com jargon9@pku.edu.cn
KVJsonSerializer.java
in core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl
 41 1 2022-10-21 2023-02-05 7 2 unclerangoo@gmail.com jargon9@pku.edu.cn
Time.java
in core/src/main/java/org/apache/rocketmq/streams/core/window
 41 11 2023-01-03 2023-02-05 4 2 unclerangoo@gmail.com jargon9@pku.edu.cn
TimestampSelectorSupplier.java
in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier
 30 4 2022-10-25 2023-02-05 8 2 unclerangoo@gmail.com jargon9@pku.edu.cn