path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/SimpleDiagnosticsAppender.java 47 5 2303 2082 5 4 2019-01-17 2019-08-26 rmatharu@linkedin.com 40646191+rmatharu@users.noreply.github.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerdeFactory.java 13 3 2403 2401 4 4 2018-10-09 2018-10-11 pchhokra@pchhokra-mn3.linkedin.biz jvenkatraman@linkedin.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerde.java 38 3 2403 2401 4 4 2018-10-09 2018-10-11 pchhokra@pchhokra-mn3.linkedin.biz jvenkatraman@linkedin.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerdeFactory.java 11 3 2403 2401 4 4 2018-10-09 2018-10-11 pchhokra@pchhokra-mn3.linkedin.biz jvenkatraman@linkedin.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java 102 4 2403 1707 5 5 2018-10-09 2020-09-04 pchhokra@pchhokra-mn3.linkedin.biz pawas2703@gmail.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java 341 26 2403 827 29 16 2018-10-09 2023-02-01 pchhokra@pchhokra-mn3.linkedin.biz 94939653+jia-gao@users.noreply.github.com samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppenderMetrics.java 20 6 2403 875 7 7 2018-10-09 2022-12-15 pchhokra@pchhokra-mn3.linkedin.biz 72765053+shekhars-li@users.noreply.github.com samza-log4j2/src/main/java/org/apache/samza/config/Log4jSystemConfig.java 34 10 2403 2047 13 7 2018-10-09 2019-09-30 pchhokra@pchhokra-mn3.linkedin.biz boryas@apache.org gradle/resources/rat-output-to-html.xsl 153 1 3956 3956 1 1 2014-07-09 2014-07-09 dchen@linkedin.com dchen@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/MetricsValidationFailureException.java 9 1 3327 3327 1 1 2016-03-29 2016-03-29 xiliu@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistry.java 9 6 4248 2177 6 5 2013-09-20 2019-05-23 criccomi@criccomi-mn.linkedin.biz rmatharu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistryListener.java 6 4 3929 2177 4 3 2014-08-05 2019-05-23 yanfang724@gmail.com rmatharu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/MetricsReporterFactory.java 6 3 3976 2431 4 4 2014-06-19 2018-09-11 jghoman@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/MetricsReporter.java 6 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/metrics/MetricsVisitor.java 15 5 3976 2177 5 4 2014-06-19 2019-05-23 jghoman@apache.org rmatharu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/Counter.java 42 2 3976 1310 2 2 2014-06-19 2021-10-06 jghoman@apache.org jon@bringhurst.org samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistryWithSource.java 15 1 1255 1255 1 1 2021-11-30 2021-11-30 calee@linkedin.com calee@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/Gauge.java 31 4 4231 1310 4 4 2013-10-07 2021-10-06 criccomi@criccomi-mn.linkedin.biz jon@bringhurst.org samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistry.java 9 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/metrics/Reservoir.java 6 1 3929 3929 2 2 2014-08-05 2014-08-05 criccomi@criccomi-mn.linkedin.biz yanfang724@gmail.com samza-api/src/main/java/org/apache/samza/metrics/MetricsAccessor.java 7 1 3327 3327 1 1 2016-03-29 2016-03-29 xiliu@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/MetricsValidator.java 7 1 3327 3327 1 1 2016-03-29 2016-03-29 xiliu@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/Snapshot.java 54 4 3929 2890 4 4 2014-08-05 2017-06-09 yanfang724@gmail.com mlogvinenko@gmail.com samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java 75 3 3929 1310 3 3 2014-08-05 2021-10-06 yanfang724@gmail.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/metrics/Timer.java 34 2 3929 3439 2 2 2014-08-05 2015-12-08 yanfang724@gmail.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/metrics/SamzaHistogram.java 52 12 2361 1310 14 9 2018-11-20 2021-10-06 sguirgui@sguirgui-ld2.linkedin.biz jon@bringhurst.org samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java 11 14 4116 2190 14 8 2014-01-30 2019-05-10 criccomi@criccomi-mn.linkedin.biz bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/StreamValidationException.java 8 1 3002 3002 1 1 2017-02-17 2017-02-17 jmaes@linkedin.com jmaes@linkedin.com samza-api/src/main/java/org/apache/samza/system/SystemStream.java 51 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionIterator.java 58 4 3976 2766 4 4 2014-06-19 2017-10-11 jghoman@apache.org nsolis@linkedin.com samza-api/src/main/java/org/apache/samza/system/ChangelogSSPIterator.java 34 6 2045 1367 6 4 2019-10-02 2021-08-10 prateekm@utexas.edu prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/system/SystemFactory.java 20 8 3976 1367 11 5 2014-06-19 2021-08-10 jghoman@apache.org prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java 53 29 4234 1689 34 19 2013-10-04 2020-09-22 criccomi@criccomi-mn.linkedin.biz boryas@apache.org samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionMatcher.java 6 1 3243 3243 1 1 2016-06-21 2016-06-21 jose@stormpath.com jose@stormpath.com samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java 101 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/system/EndOfStreamMessage.java 12 3 2778 1547 3 3 2017-09-29 2021-02-11 xinyuliu.us@gmail.com stuart.m.perks@gmail.com samza-api/src/main/java/org/apache/samza/system/DrainMessage.java 38 1 1014 1014 1 1 2022-07-29 2022-07-29 ajthomas@linkedin.com ajthomas@linkedin.com samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java 41 5 2778 1547 5 4 2017-09-29 2021-02-11 xinyuliu.us@gmail.com stuart.m.perks@gmail.com samza-api/src/main/java/org/apache/samza/system/SystemProducerException.java 14 2 2787 2774 2 2 2017-09-20 2017-10-03 jmaes@linkedin.com xiliu@xiliu-ld1.linkedin.biz samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java 130 5 4094 4073 7 2 2014-02-21 2014-03-14 criccomi@criccomi-ld.linkedin.biz criccomi@criccomi-mn.linkedin.biz samza-api/src/main/java/org/apache/samza/system/ControlMessage.java 43 4 2778 2724 4 3 2017-09-29 2017-11-22 xinyuliu.us@gmail.com boryas@apache.org samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java 129 26 3453 875 30 17 2015-11-24 2022-12-15 mdconference@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-api/src/main/java/org/apache/samza/system/descriptors/GenericOutputDescriptor.java 8 10 2399 2197 13 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/TransformingInputDescriptorProvider.java 5 7 2399 2375 8 4 2018-10-13 2018-11-06 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/GenericSystemDescriptor.java 18 7 2399 2389 10 4 2018-10-13 2018-10-23 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/OutputDescriptorProvider.java 5 4 2399 2395 4 4 2018-10-13 2018-10-17 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/StreamExpander.java 7 7 2399 2375 8 4 2018-10-13 2018-11-06 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/SystemDescriptor.java 72 7 2399 2389 10 4 2018-10-13 2018-10-23 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/StreamDescriptor.java 68 10 2399 2197 13 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/InputTransformer.java 8 4 2399 2395 4 4 2018-10-13 2018-10-17 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/OutputDescriptor.java 8 7 2399 2389 10 4 2018-10-13 2018-10-23 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/InputDescriptor.java 77 7 2399 2389 10 4 2018-10-13 2018-10-23 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/GenericInputDescriptor.java 8 10 2399 2197 13 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.java 5 4 2399 2395 4 4 2018-10-13 2018-10-17 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.java 5 4 2399 2395 4 4 2018-10-13 2018-10-17 pmaheshwari@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/system/StreamSpec.java 114 21 3002 1940 21 14 2017-02-17 2020-01-15 jmaes@linkedin.com svenkataraman@linkedin.com samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java 101 8 4165 1189 8 7 2013-12-12 2022-02-04 jghoman@gmail.com mgaduputi@linkedin.com samza-api/src/main/java/org/apache/samza/system/chooser/MessageChooserFactory.java 6 2 4234 3976 2 2 2013-10-04 2014-06-19 criccomi@criccomi-mn.linkedin.biz jghoman@apache.org samza-api/src/main/java/org/apache/samza/system/chooser/BaseMessageChooser.java 13 3 4234 1310 3 2 2013-10-04 2021-10-06 criccomi@criccomi-mn.linkedin.biz jon@bringhurst.org samza-api/src/main/java/org/apache/samza/system/chooser/MessageChooser.java 10 3 4234 3976 3 2 2013-10-04 2014-06-19 criccomi@criccomi-mn.linkedin.biz jghoman@apache.org samza-api/src/main/java/org/apache/samza/system/SystemProducer.java 8 2 4271 3976 2 2 2013-08-28 2014-06-19 criccomi@criccomi-mn.linkedin.biz jghoman@apache.org samza-api/src/main/java/org/apache/samza/system/BoundedSSPIterator.java 51 2 1723 1310 2 2 2020-08-19 2021-10-06 bkonold@users.noreply.github.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/system/MessageType.java 18 3 2778 1014 3 3 2017-09-29 2022-07-29 xinyuliu.us@gmail.com ajthomas@linkedin.com samza-api/src/main/java/org/apache/samza/Partition.java 40 3 4138 3951 3 1 2014-01-08 2014-07-14 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java 48 3 2411 2409 4 4 2018-10-01 2018-10-03 calee@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/job/model/TaskMode.java 12 3 2303 1310 4 4 2019-01-17 2021-10-06 wsong@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/job/model/LocalityModel.java 31 1 1715 1715 1 1 2020-08-27 2020-08-27 bharath.kumarasubramanian@gmail.com bharath.kumarasubramanian@gmail.com samza-api/src/main/java/org/apache/samza/job/model/JobModel.java 62 3 1715 1367 3 3 2020-08-27 2021-08-10 bharath.kumarasubramanian@gmail.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java 73 8 2411 1310 11 7 2018-10-01 2021-10-06 calee@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java 47 1 1715 1715 1 1 2020-08-27 2020-08-27 bharath.kumarasubramanian@gmail.com bharath.kumarasubramanian@gmail.com samza-api/src/main/java/org/apache/samza/job/StreamJob.java 8 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/job/CommandBuilder.java 28 6 4164 2953 6 5 2013-12-13 2017-04-07 jghoman@gmail.com navina@apache.org samza-api/src/main/java/org/apache/samza/job/JobMetadataChange.java 6 1 1353 1353 1 1 2021-08-24 2021-08-24 calee@linkedin.com calee@linkedin.com samza-api/src/main/java/org/apache/samza/job/StreamJobFactory.java 5 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/job/ApplicationStatus.java 50 2 3976 2927 2 2 2014-06-19 2017-05-03 jghoman@apache.org xiliu@xiliu-ld.linkedin.biz samza-api/src/main/java/org/apache/samza/job/JobCoordinatorMetadata.java 49 1 1612 1612 1 1 2020-12-08 2020-12-08 bharath.kumarasubramanian@gmail.com bharath.kumarasubramanian@gmail.com samza-api/src/main/java/org/apache/samza/metadatastore/MetadataStore.java 18 8 2444 2109 11 5 2018-08-29 2019-07-30 spvenkat@usc.edu dnishimura@gmail.com samza-api/src/main/java/org/apache/samza/metadatastore/MetadataStoreFactory.java 6 3 2444 2437 3 3 2018-08-29 2018-09-05 spvenkat@usc.edu wsong@linkedin.com samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.java 12 3 2330 2305 3 3 2018-12-21 2019-01-15 dnishimura@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStore.java 29 3 2330 2305 3 3 2018-12-21 2019-01-15 dnishimura@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/sql/udfs/SamzaSqlUdfMethod.java 13 6 2298 2197 6 4 2019-01-22 2019-05-03 spunuru@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/sql/udfs/ScalarUdf.java 6 11 2730 2163 11 5 2017-11-16 2019-06-06 spunuru@linkedin.com srinipunuru@users.noreply.github.com samza-api/src/main/java/org/apache/samza/sql/udfs/SamzaSqlUdf.java 12 6 2298 2197 6 4 2019-01-22 2019-05-03 spunuru@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchema.java 52 8 2298 2197 9 4 2019-01-22 2019-05-03 spunuru@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/sql/schema/SqlFieldSchema.java 54 6 2298 2002 6 5 2019-01-22 2019-11-14 spunuru@linkedin.com 57301006+micpod@users.noreply.github.com samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchemaBuilder.java 22 3 2298 2291 3 3 2019-01-22 2019-01-29 spunuru@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/sql/schema/SamzaSqlFieldType.java 19 4 2298 2061 4 4 2019-01-22 2019-09-16 spunuru@linkedin.com atoomula@linkedin.com samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java 67 12 2523 1547 13 8 2018-06-11 2021-02-11 atoomula@linkedin.com stuart.m.perks@gmail.com samza-api/src/main/java/org/apache/samza/runtime/ProcessorContext.java 5 2 2435 2431 3 3 2018-09-07 2018-09-11 boryas@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/LocationIdProviderFactory.java 5 3 2463 2457 3 3 2018-08-10 2018-08-16 spvenkat@usc.edu wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/LocationId.java 29 3 2463 2457 3 3 2018-08-10 2018-08-16 spvenkat@usc.edu wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java 16 23 2984 2309 24 10 2017-03-07 2019-01-11 xiliu@xiliu-ld.linkedin.biz bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListener.java 9 2 2435 2431 3 3 2018-09-07 2018-09-11 boryas@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/LocationIdProvider.java 4 3 2463 2457 3 3 2018-08-10 2018-08-16 spvenkat@usc.edu wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListenerFactory.java 8 2 2435 2431 3 3 2018-09-07 2018-09-11 boryas@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/runtime/ProcessorIdGenerator.java 7 1 2953 2953 1 1 2017-04-07 2017-04-07 navina@apache.org navina@apache.org samza-api/src/main/java/org/apache/samza/serializers/LongSerde.java 20 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/DoubleSerde.java 20 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/StringSerde.java 36 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/Serializer.java 4 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/serializers/KVSerde.java 53 4 2771 1310 4 3 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/Serde.java 4 3 3976 2774 3 3 2014-06-19 2017-10-03 jghoman@apache.org xiliu@xiliu-ld1.linkedin.biz samza-api/src/main/java/org/apache/samza/serializers/DoubleSerdeFactory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2Factory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/UUIDSerde.java 25 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/IntegerSerdeFactory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/Deserializer.java 4 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/serializers/SerdeFactory.java 5 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/serializers/ByteSerde.java 11 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/UUIDSerdeFactory.java 9 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/StringSerdeFactory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2.java 63 3 2771 1310 3 3 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/SerializableSerde.java 57 4 2771 1310 4 4 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/LongSerdeFactory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerdeFactory.java 9 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/SerializableSerdeFactory.java 9 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/ByteSerdeFactory.java 8 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/NoOpSerde.java 12 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerde.java 22 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/serializers/IntegerSerde.java 20 2 2771 1310 2 2 2017-10-06 2021-10-06 pmaheshw@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContext.java 8 11 2411 2375 16 5 2018-10-01 2018-11-06 calee@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/context/TaskContext.java 23 14 2411 695 17 7 2018-10-01 2023-06-13 calee@linkedin.com bharathkk@apache.org samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContext.java 7 11 2411 2375 16 5 2018-10-01 2018-11-06 calee@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/context/JobContext.java 9 9 2411 1715 13 6 2018-10-01 2020-08-27 calee@linkedin.com bharath.kumarasubramanian@gmail.com samza-api/src/main/java/org/apache/samza/context/ExternalContext.java 3 3 2345 2309 3 3 2018-12-06 2019-01-11 calee@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContextFactory.java 15 16 2411 2309 19 5 2018-10-01 2019-01-11 calee@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContextFactory.java 17 16 2411 2309 19 5 2018-10-01 2019-01-11 calee@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/context/Context.java 11 12 2411 2309 15 5 2018-10-01 2019-01-11 calee@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/context/ContainerContext.java 10 10 2411 695 13 6 2018-10-01 2023-06-13 calee@linkedin.com bharathkk@apache.org samza-api/src/main/java/org/apache/samza/table/batching/Batch.java 18 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/batching/Operation.java 7 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/batching/BatchProvider.java 23 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java 109 10 2373 2197 10 4 2018-11-08 2019-05-03 wsong@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/table/TableProvider.java 9 23 2711 1204 26 8 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java 57 15 2373 2183 16 5 2018-11-08 2019-05-17 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/TableProviderFactory.java 6 11 2711 2348 14 4 2017-12-05 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/RecordNotFoundException.java 16 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java 27 15 2711 1204 16 6 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/AsyncReadWriteUpdateTable.java 27 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/Table.java 14 13 2711 1204 15 6 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/ReadWriteUpdateTable.java 23 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java 17 17 2399 1204 21 5 2018-10-13 2022-01-20 pmaheshwari@apache.org ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java 34 8 2373 2348 9 3 2018-11-08 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java 89 8 2373 2348 9 3 2018-11-08 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java 200 28 2373 1204 30 10 2018-11-08 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/descriptors/LocalTableDescriptor.java 108 13 2373 2008 15 4 2018-11-08 2019-11-08 wsong@linkedin.com bharathkk@apache.org samza-api/src/main/java/org/apache/samza/table/descriptors/BaseTableDescriptor.java 39 12 2373 2309 14 3 2018-11-08 2019-01-11 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/descriptors/HybridTableDescriptor.java 9 8 2373 2348 9 3 2018-11-08 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/remote/TablePart.java 11 5 2283 2197 5 3 2019-02-06 2019-05-03 wsong@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/table/remote/TableFunction.java 11 3 2184 1204 3 3 2019-05-16 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/remote/TableWriteFunction.java 79 12 2373 1192 12 4 2018-11-08 2022-02-01 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/table/remote/TableReadFunction.java 46 10 2373 2183 10 3 2018-11-08 2019-05-17 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/remote/TableRateLimiter.java 78 14 2373 2183 16 3 2018-11-08 2019-05-17 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/table/remote/BaseTableFunction.java 13 4 2184 1204 4 3 2019-05-16 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/operators/KV.java 44 5 2779 2093 5 5 2017-09-28 2019-08-15 pmaheshw@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/operators/OutputStream.java 5 4 3003 2774 4 3 2017-02-16 2017-10-03 nickpan47@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-api/src/main/java/org/apache/samza/operators/functions/FoldLeftFunction.java 8 5 2972 2526 5 4 2017-03-19 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/SinkFunction.java 10 7 3080 2526 7 4 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/SupplierFunction.java 8 2 2540 2526 2 2 2018-05-25 2018-06-08 nickpan47@gmail.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/StreamTableJoinFunction.java 9 4 2711 2526 4 3 2017-12-05 2018-06-08 wsong@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/FlatMapFunction.java 9 6 3080 2526 6 4 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/JoinFunction.java 9 6 3080 2526 6 4 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java 7 2 2416 2415 3 3 2018-09-26 2018-09-27 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/operators/functions/FilterFunction.java 8 7 3080 2526 7 4 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/WatermarkFunction.java 6 5 2778 2724 5 4 2017-09-29 2017-11-22 xinyuliu.us@gmail.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/functions/MapFunction.java 8 10 3080 2470 10 6 2016-12-01 2018-08-03 pmaheshw@linkedin.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/operators/functions/AsyncFlatMapFunction.java 11 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/operators/functions/InitableFunction.java 7 13 3003 2395 16 10 2017-02-16 2018-10-17 nickpan47@gmail.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java 6 10 2898 2395 12 7 2017-06-01 2018-10-17 jvenkatr@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/operators/Scheduler.java 5 2 2416 2415 3 3 2018-09-26 2018-09-27 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/operators/MessageStream.java 48 39 3089 1204 43 14 2016-11-22 2022-01-20 nickpan47@gmail.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/operators/UpdateOptions.java 5 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/operators/windows/Window.java 10 7 3080 2526 8 5 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/windows/WindowKey.java 37 6 3020 2764 6 4 2017-01-30 2017-10-13 jvenkatr@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/operators/windows/AccumulationMode.java 4 1 3020 3020 1 1 2017-01-30 2017-01-30 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/windows/WindowPane.java 23 3 3020 2972 3 2 2017-01-30 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowType.java 4 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowInternal.java 106 6 3020 2526 6 4 2017-01-30 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java 54 10 3080 2526 11 5 2016-12-01 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/triggers/CountTrigger.java 10 3 3020 2972 3 2 2017-01-30 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/RepeatingTrigger.java 10 4 3020 2924 4 2 2017-01-30 2017-05-06 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/DurationCharacteristic.java 4 1 3020 3020 1 1 2017-01-30 2017-01-30 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/Trigger.java 6 4 3020 2526 4 3 2017-01-30 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/triggers/FiringType.java 6 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/Triggers.java 29 2 3020 3003 2 2 2017-01-30 2017-02-16 jvenkatr@linkedin.com nickpan47@gmail.com samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.java 16 4 3020 2924 4 2 2017-01-30 2017-05-06 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/TimeTrigger.java 16 4 3020 2924 4 2 2017-01-30 2017-05-06 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/TimeBasedTrigger.java 7 1 2924 2924 1 1 2017-05-06 2017-05-06 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.java 16 4 3020 2924 4 2 2017-01-30 2017-05-06 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/operators/triggers/AnyTrigger.java 14 5 3020 2526 5 3 2017-01-30 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/operators/UpdateMessage.java 50 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-api/src/main/java/org/apache/samza/drain/DrainMode.java 4 2 903 875 2 2 2022-11-17 2022-12-15 ajthomas@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java 55 2 903 875 2 2 2022-11-17 2022-12-15 ajthomas@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-api/src/main/java/org/apache/samza/annotation/InterfaceStability.java 16 1 3089 3089 1 1 2016-11-22 2016-11-22 nickpan47@gmail.com nickpan47@gmail.com samza-api/src/main/java/org/apache/samza/config/ConfigFactory.java 5 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/config/ConfigException.java 14 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/config/ConfigLoaderFactory.java 5 3 1968 1946 7 2 2019-12-18 2020-01-09 kwu@kwu-ld2.linkedin.biz boryas@apache.org samza-api/src/main/java/org/apache/samza/config/MapConfig.java 101 11 3976 1310 13 10 2014-06-19 2021-10-06 jghoman@apache.org jon@bringhurst.org samza-api/src/main/java/org/apache/samza/config/JavaTableConfig.java 43 5 2360 2348 7 3 2018-11-21 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/config/ConfigRewriter.java 4 1 3976 3976 1 1 2014-06-19 2014-06-19 jghoman@apache.org jghoman@apache.org samza-api/src/main/java/org/apache/samza/config/ConfigLoader.java 4 4 1968 1946 6 2 2019-12-18 2020-01-09 kwu@kwu-ld2.linkedin.biz boryas@apache.org samza-api/src/main/java/org/apache/samza/config/Config.java 196 14 4175 1310 15 12 2013-12-02 2021-10-06 garry.turkington@gmail.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/scheduler/ScheduledCallback.java 6 4 2416 2401 7 4 2018-09-26 2018-10-11 wsong@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/scheduler/CallbackScheduler.java 5 5 2411 2401 8 4 2018-10-01 2018-10-11 calee@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java 48 9 2330 2190 9 5 2018-12-21 2019-05-10 dnishimura@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/startpoint/StartpointUpcoming.java 15 9 2330 2190 9 5 2018-12-21 2019-05-10 dnishimura@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java 42 9 2330 2190 9 5 2018-12-21 2019-05-10 dnishimura@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/startpoint/StartpointVisitor.java 18 7 2330 2002 7 5 2018-12-21 2019-11-14 dnishimura@linkedin.com 57301006+micpod@users.noreply.github.com samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java 15 9 2330 2190 9 5 2018-12-21 2019-05-10 dnishimura@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java 40 11 2330 1547 12 7 2018-12-21 2021-02-11 dnishimura@linkedin.com stuart.m.perks@gmail.com samza-api/src/main/java/org/apache/samza/util/Clock.java 4 2 3976 1022 2 2 2014-06-19 2022-07-21 jghoman@apache.org ke.wu.cs@icloud.com samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java 208 21 4271 1310 22 16 2013-08-28 2021-10-06 criccomi@criccomi-mn.linkedin.biz jon@bringhurst.org samza-api/src/main/java/org/apache/samza/util/NoOpMetricsRegistry.java 31 6 4248 2177 6 5 2013-09-20 2019-05-23 criccomi@criccomi-mn.linkedin.biz rmatharu@linkedin.com samza-api/src/main/java/org/apache/samza/util/RateLimiter.java 16 5 2627 2401 7 6 2018-02-27 2018-10-11 wsong@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java 35 10 4094 2774 12 8 2014-02-21 2017-10-03 criccomi@criccomi-ld.linkedin.biz xiliu@xiliu-ld1.linkedin.biz samza-api/src/main/java/org/apache/samza/util/TimestampedValue.java 29 2 2520 2471 2 2 2018-06-14 2018-08-02 rmatharu@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/task/TaskCallback.java 5 1 3215 3215 1 1 2016-07-19 2016-07-19 xiliu@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/task/StreamTask.java 5 2 4066 3976 2 2 2014-03-21 2014-06-19 mkleppmann@linkedin.com jghoman@apache.org samza-api/src/main/java/org/apache/samza/task/DrainListenerTask.java 4 1 1014 1014 1 1 2022-07-29 2022-07-29 ajthomas@linkedin.com ajthomas@linkedin.com samza-api/src/main/java/org/apache/samza/task/InitableTask.java 5 2 2402 2401 4 4 2018-10-10 2018-10-11 calee@linkedin.com jvenkatraman@linkedin.com samza-api/src/main/java/org/apache/samza/task/WindowableTask.java 4 2 4066 3976 2 2 2014-03-21 2014-06-19 mkleppmann@linkedin.com jghoman@apache.org samza-api/src/main/java/org/apache/samza/task/EndOfStreamListenerTask.java 4 1 3141 3141 1 1 2016-10-01 2016-10-01 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-api/src/main/java/org/apache/samza/task/TaskFactory.java 7 5 2435 2389 7 6 2018-09-07 2018-10-23 boryas@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/task/TaskCoordinator.java 9 3 4024 3662 3 3 2014-05-02 2015-04-29 mkleppmann@linkedin.com navgog8@gmail.com samza-api/src/main/java/org/apache/samza/task/AsyncStreamTaskFactory.java 5 3 3019 2431 4 4 2017-01-31 2018-09-11 navina@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java 4 2 2166 695 2 2 2019-06-03 2023-06-13 bharath.kumarasubramanian@gmail.com bharathkk@apache.org samza-api/src/main/java/org/apache/samza/task/TaskExecutorFactory.java 12 2 1155 695 2 2 2022-03-10 2023-06-13 chris.zhang@berkeley.edu bharathkk@apache.org samza-api/src/main/java/org/apache/samza/task/MessageCollector.java 5 1 4066 4066 1 1 2014-03-21 2014-03-21 mkleppmann@linkedin.com mkleppmann@linkedin.com samza-api/src/main/java/org/apache/samza/task/AsyncStreamTask.java 5 2 3215 3165 2 1 2016-07-19 2016-09-07 xiliu@linkedin.com xiliu@linkedin.com samza-api/src/main/java/org/apache/samza/task/StreamTaskFactory.java 5 3 3019 2431 4 4 2017-01-31 2018-09-11 navina@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/task/ClosableTask.java 7 5 3976 2348 6 5 2014-06-19 2018-12-03 jghoman@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java 8 4 3935 1213 5 5 2014-07-30 2022-01-11 criccomi@criccomi-mn.linkedin.biz 58271370+smptx@users.noreply.github.com samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.java 6 2 2347 2346 3 3 2018-12-04 2018-12-05 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapperFactory.java 6 2 2347 2346 3 3 2018-12-04 2018-12-05 wsong@linkedin.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouperFactory.java 5 1 3935 3935 1 1 2014-07-30 2014-07-30 criccomi@criccomi-mn.linkedin.biz criccomi@criccomi-mn.linkedin.biz samza-api/src/main/java/org/apache/samza/container/TaskName.java 30 3 3937 3662 3 3 2014-07-28 2015-04-29 jghoman@apache.org navgog8@gmail.com samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java 76 1 1934 1934 1 1 2020-01-21 2020-01-21 sanil.jain15@gmail.com sanil.jain15@gmail.com samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java 58 2 1934 1906 2 1 2020-01-21 2020-02-18 sanil.jain15@gmail.com sanil.jain15@gmail.com samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementRequestMessage.java 26 1 1934 1934 1 1 2020-01-21 2020-01-21 sanil.jain15@gmail.com sanil.jain15@gmail.com samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignal.java 4 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactoryContext.java 11 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactory.java 4 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-api/src/main/java/org/apache/samza/application/SamzaApplication.java 10 12 2435 2375 15 6 2018-09-07 2018-11-06 boryas@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/application/ApplicationApiType.java 6 2 911 875 2 2 2022-11-09 2022-12-15 ajthomas@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-api/src/main/java/org/apache/samza/application/StreamApplication.java 19 18 2973 2375 21 8 2017-03-18 2018-11-06 nickpan47@gmail.com wsong@linkedin.com samza-api/src/main/java/org/apache/samza/application/TaskApplication.java 14 12 2435 2375 17 6 2018-09-07 2018-11-06 boryas@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptor.java 16 10 2399 2375 13 4 2018-10-13 2018-11-06 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptor.java 27 11 2399 2141 14 5 2018-10-13 2019-06-28 pmaheshwari@apache.org calee@linkedin.com samza-api/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptor.java 19 10 2399 2375 14 4 2018-10-13 2018-11-06 pmaheshwari@apache.org wsong@linkedin.com samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessorFactory.java 10 2 2480 2471 2 2 2018-07-24 2018-08-02 bkumaras@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/storage/BlobStoreAdminFactory.java 6 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java 14 3 1444 637 3 2 2021-05-25 2023-08-10 72765053+shekhars-li@users.noreply.github.com 72765053+shekhars-li@users.noreply.github.com samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/RetriableException.java 15 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/DeletedException.java 15 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java 73 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManagerFactory.java 9 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/StorageEngine.java 16 14 3976 1315 18 12 2014-06-19 2021-10-01 jghoman@apache.org dchen@apache.org samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessor.java 12 2 2480 2471 2 2 2018-07-24 2018-08-02 bkumaras@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/storage/TaskRestoreManager.java 8 6 1462 1233 6 3 2021-05-07 2021-12-22 dchen1@linkedin.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/StoreProperties.java 43 3 3242 1367 3 3 2016-06-22 2021-08-10 nramesh@linkedin.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/StorageEngineFactory.java 27 9 4094 2291 11 9 2014-02-21 2019-01-29 martin@rapportive.com bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java 38 7 1462 892 8 4 2021-05-07 2022-11-28 dchen1@linkedin.com shesharma@linkedin.com samza-api/src/main/java/org/apache/samza/storage/KafkaChangelogRestoreParams.java 46 5 1457 1367 5 2 2021-05-12 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/StateBackendAdmin.java 5 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/storage/kv/ClosableIterator.java 5 1 2775 2775 1 1 2017-10-02 2017-10-02 jagadish@apache.org jagadish@apache.org samza-api/src/main/java/org/apache/samza/storage/kv/Entry.java 15 1 3377 3377 1 1 2016-02-08 2016-02-08 boryas@apache.org boryas@apache.org samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java 44 16 3377 1315 18 10 2016-02-08 2021-10-01 boryas@apache.org dchen@apache.org samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueIterator.java 5 3 3377 3297 3 3 2016-02-08 2016-04-28 boryas@apache.org jacob.maes@gmail.com samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueSnapshot.java 5 3 2556 2526 3 2 2018-05-09 2018-06-08 xiliu@linkedin.com boryas@apache.org samza-api/src/main/java/org/apache/samza/storage/TaskBackupManager.java 13 2 1462 1367 2 2 2021-05-07 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/checkpoint/Checkpoint.java 7 5 3976 1367 5 4 2014-06-19 2021-08-10 jghoman@apache.org prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointId.java 59 5 2024 1367 5 3 2019-10-23 2021-08-10 prateekm@utexas.edu prateekm@utexas.edu samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManager.java 11 12 3976 1008 12 9 2014-06-19 2022-08-04 jghoman@apache.org mgaduputi@linkedin.com samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManagerFactory.java 6 2 3976 3475 2 2 2014-06-19 2015-11-02 jghoman@apache.org navi.trinity@gmail.com samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java 59 3 1463 1310 3 3 2021-05-06 2021-10-06 dchen1@linkedin.com jon@bringhurst.org samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointListener.java 13 4 3097 2291 4 4 2016-11-14 2019-01-29 boryas@apache.org bshkolnik@linkedin.com samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java 39 3 1463 1310 3 3 2021-05-06 2021-10-06 dchen1@linkedin.com jon@bringhurst.org samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java 38 12 4144 2774 15 8 2014-01-02 2017-10-03 criccomi@criccomi-ld.linkedin.biz xiliu@xiliu-ld1.linkedin.biz samza-test/src/main/java/org/apache/samza/system/mock/MockSystemFactory.java 47 1 4144 4144 1 1 2014-01-02 2014-01-02 criccomi@criccomi-ld.linkedin.biz criccomi@criccomi-ld.linkedin.biz samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java 90 7 4144 1353 8 7 2014-01-02 2021-08-24 criccomi@criccomi-ld.linkedin.biz calee@linkedin.com samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java 54 17 2540 2197 19 7 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/WindowExample.java 48 17 2540 2197 19 7 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java 96 19 2540 2197 23 8 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/AsyncApplicationExample.java 86 5 2227 1738 5 5 2019-04-03 2020-08-04 bharath.kumarasubramanian@gmail.com 54013208+mabelyc@users.noreply.github.com samza-test/src/main/java/org/apache/samza/example/models/PageViewEvent.java 20 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/models/PageViewCount.java 20 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/models/EnrichedAdClickEvent.java 20 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/models/Member.java 20 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/models/AdClickEvent.java 15 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java 82 14 2540 2389 16 6 2018-05-25 2018-10-23 nickpan47@gmail.com bshkolnik@linkedin.com samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java 58 17 2540 2197 19 7 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/TaskApplicationExample.java 48 13 2435 2348 18 6 2018-09-07 2018-12-03 boryas@apache.org bshkolnik@linkedin.com samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java 60 19 2540 2197 22 8 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/BroadcastExample.java 42 17 2540 2197 19 7 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/java/org/apache/samza/example/MergeExample.java 42 17 2540 2197 19 7 2018-05-25 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-test/src/main/python/samza_job_yarn_deployer.py 154 10 3767 1738 11 10 2015-01-14 2020-08-04 nramesh@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-test/src/main/python/standalone_deployment.py 65 5 2512 2161 5 3 2018-06-22 2019-06-08 santhoshvenkat1988@gmail.com bshkolnik@linkedin.com samza-test/src/main/python/deployment.py 64 7 3767 1738 7 6 2015-01-14 2020-08-04 nramesh@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-test/src/main/python/templates/yarn-site.xml 9 1 3767 3767 1 1 2015-01-14 2015-01-14 nramesh@linkedin.com nramesh@linkedin.com samza-test/src/main/python/templates.py 7 2 3767 3744 2 2 2015-01-14 2015-02-06 nramesh@linkedin.com dzc@google.com samza-test/src/main/python/perf.py 26 1 3767 3767 1 1 2015-01-14 2015-01-14 nramesh@linkedin.com nramesh@linkedin.com samza-test/src/main/python/samza_failure_testing.py 120 2 3724 3662 2 2 2015-02-26 2015-04-29 navi.trinity@gmail.com navgog8@gmail.com samza-test/src/main/python/stream_processor.py 62 9 2512 1274 11 10 2018-06-22 2021-11-11 santhoshvenkat1988@gmail.com 93950124+apb0001@users.noreply.github.com samza-test/src/main/resources/log4j2.xml 17 5 2403 1942 6 6 2018-10-09 2020-01-13 pchhokra@pchhokra-mn3.linkedin.biz boryas@apache.org samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java 75 9 2204 1204 10 5 2019-04-26 2022-01-20 bshkolnik@linkedin.com ajothomas@users.noreply.github.com samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseBucketRegistry.java 114 2 2204 2197 3 3 2019-04-26 2019-05-03 bshkolnik@linkedin.com wsong@linkedin.com samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/BaseCouchbaseTableFunction.java 117 6 2204 1204 7 4 2019-04-26 2022-01-20 bshkolnik@linkedin.com ajothomas@users.noreply.github.com samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseEnvironmentConfigs.java 16 2 2204 2197 3 3 2019-04-26 2019-05-03 bshkolnik@linkedin.com wsong@linkedin.com samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableReadFunction.java 82 5 2204 1204 6 4 2019-04-26 2022-01-20 bshkolnik@linkedin.com ajothomas@users.noreply.github.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemFactory.scala 30 6 3562 2108 7 7 2015-08-07 2019-07-31 apache.mailbox@gmail.com calee@linkedin.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducer.scala 73 6 3562 2526 6 5 2015-08-07 2018-06-08 apache.mailbox@gmail.com boryas@apache.org samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/TextSequenceFileHdfsWriter.scala 18 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/Bucketer.scala 16 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/HdfsWriter.scala 20 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala 61 2 3562 3243 2 2 2015-08-07 2016-06-21 apache.mailbox@gmail.com ben.smith@ranksoftwareinc.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/AvroDataFileHdfsWriter.scala 49 4 3352 2526 4 3 2016-03-04 2018-06-08 edi_bice@yahoo.com boryas@apache.org samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/BinarySequenceFileHdfsWriter.scala 18 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/JobNameDateTimeBucketer.scala 30 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducerMetrics.scala 13 1 3562 3562 1 1 2015-08-07 2015-08-07 apache.mailbox@gmail.com apache.mailbox@gmail.com samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsConfig.scala 83 7 3562 2526 7 7 2015-08-07 2018-06-08 apache.mailbox@gmail.com boryas@apache.org samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java 180 11 3137 941 11 11 2016-10-05 2022-10-10 lhaiesp@gmail.com james.demichele@redfin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java 135 6 3137 941 6 6 2016-10-05 2022-10-10 lhaiesp@gmail.com james.demichele@redfin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/HdfsFileSystemAdapter.java 33 3 3137 2526 3 3 2016-10-05 2018-06-08 lhaiesp@gmail.com boryas@apache.org samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/FileSystemAdapter.java 23 4 3137 2197 4 4 2016-10-05 2019-05-03 lhaiesp@gmail.com wsong@linkedin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/PartitionDescriptorUtil.java 57 2 3137 1547 2 2 2016-10-05 2021-02-11 lhaiesp@gmail.com stuart.m.perks@gmail.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java 143 1 3137 3137 1 1 2016-10-05 2016-10-05 lhaiesp@gmail.com lhaiesp@gmail.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/HdfsReaderFactory.java 29 1 3137 3137 1 1 2016-10-05 2016-10-05 lhaiesp@gmail.com lhaiesp@gmail.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/SingleFileHdfsReader.java 10 4 3137 2197 4 4 2016-10-05 2019-05-03 lhaiesp@gmail.com wsong@linkedin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java 120 7 3137 2197 8 6 2016-10-05 2019-05-03 lhaiesp@gmail.com wsong@linkedin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java 133 12 3137 941 13 9 2016-10-05 2022-10-10 lhaiesp@gmail.com james.demichele@redfin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsInputDescriptor.java 10 3 2337 2309 3 3 2018-12-14 2019-01-11 halu@linkedin.com bshkolnik@linkedin.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java 112 8 2337 1738 8 6 2018-12-14 2020-08-04 halu@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsOutputDescriptor.java 10 3 2337 2309 3 3 2018-12-14 2019-01-11 halu@linkedin.com bshkolnik@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/indexrequest/DefaultIndexRequestFactory.java 51 6 3590 2197 6 6 2015-07-10 2019-05-03 danharvey42@gmail.com wsong@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/indexrequest/IndexRequestFactory.java 6 1 3590 3590 1 1 2015-07-10 2015-07-10 danharvey42@gmail.com danharvey42@gmail.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducerMetrics.java 17 4 3578 1738 4 3 2015-07-22 2020-08-04 roger.hoover@gmail.com 54013208+mabelyc@users.noreply.github.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemFactory.java 54 7 3590 2046 7 6 2015-07-10 2019-10-01 danharvey42@gmail.com calee@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemAdmin.java 27 7 3590 1738 7 6 2015-07-10 2020-08-04 danharvey42@gmail.com 54013208+mabelyc@users.noreply.github.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/ClientFactory.java 5 1 3590 3590 1 1 2015-07-10 2015-07-10 danharvey42@gmail.com danharvey42@gmail.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/TransportClientFactory.java 30 5 3590 2197 5 5 2015-07-10 2019-05-03 danharvey42@gmail.com wsong@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/NodeClientFactory.java 24 2 3590 2940 2 2 2015-07-10 2017-04-20 danharvey42@gmail.com humpolicek@seznam.cz samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/BulkProcessorFactory.java 25 4 3590 2197 4 4 2015-07-10 2019-05-03 danharvey42@gmail.com wsong@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducer.java 134 6 3590 2197 6 5 2015-07-10 2019-05-03 danharvey42@gmail.com wsong@linkedin.com samza-elasticsearch/src/main/java/org/apache/samza/config/ElasticsearchConfig.java 79 7 3590 1738 7 7 2015-07-10 2020-08-04 danharvey42@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/monitor/MonitorFactory.java 6 2 3145 3089 2 1 2016-09-27 2016-11-22 santhoshvenkat1988@gmail.com santhoshvenkat1988@gmail.com samza-rest/src/main/java/org/apache/samza/monitor/JobsClient.java 70 5 2971 1547 5 5 2017-03-20 2021-02-11 santhoshvenkat1988@gmail.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitor.java 103 17 2971 778 17 9 2017-03-20 2023-03-22 santhoshvenkat1988@gmail.com prateekm@utexas.edu samza-rest/src/main/java/org/apache/samza/monitor/Monitor.java 4 4 3180 1738 4 4 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/monitor/MonitorConfig.java 49 5 3145 941 5 5 2016-09-27 2022-10-10 santhoshvenkat1988@gmail.com james.demichele@redfin.com samza-rest/src/main/java/org/apache/samza/monitor/MonitorLoader.java 16 10 3180 1738 10 7 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/monitor/SamzaMonitorService.java 86 12 3180 1668 12 8 2016-08-23 2020-10-13 jacob.maes@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorFactory.java 11 2 2971 2962 2 2 2017-03-20 2017-03-29 santhoshvenkat1988@gmail.com svenkataraman@linkedin.com samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorConfig.java 29 9 2971 941 9 7 2017-03-20 2022-10-10 santhoshvenkat1988@gmail.com james.demichele@redfin.com samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorMetrics.java 15 3 2962 2724 3 2 2017-03-29 2017-11-22 svenkataraman@linkedin.com boryas@apache.org samza-rest/src/main/java/org/apache/samza/rest/model/Partition.java 64 2 2971 1547 2 2 2017-03-20 2021-02-11 santhoshvenkat1988@gmail.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/rest/model/Task.java 89 4 2971 1547 4 4 2017-03-20 2021-02-11 santhoshvenkat1988@gmail.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/rest/model/JobStatus.java 18 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/model/yarn/YarnApplicationInfo.java 41 6 2766 1547 6 6 2017-10-11 2021-02-11 ashivanna@linkedin.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/rest/model/Job.java 44 2 3180 1547 2 2 2016-08-23 2021-02-11 jacob.maes@gmail.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/rest/resources/Responses.java 13 1 2971 2971 1 1 2017-03-20 2017-03-20 santhoshvenkat1988@gmail.com santhoshvenkat1988@gmail.com samza-rest/src/main/java/org/apache/samza/rest/resources/ResourceFactory.java 6 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/resources/DefaultResourceFactory.java 12 2 3180 2971 2 2 2016-08-23 2017-03-20 jacob.maes@gmail.com santhoshvenkat1988@gmail.com samza-rest/src/main/java/org/apache/samza/rest/resources/BaseResourceConfig.java 31 3 2971 1738 3 3 2017-03-20 2020-08-04 santhoshvenkat1988@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/resources/TasksResource.java 53 8 2971 941 8 6 2017-03-20 2022-10-10 santhoshvenkat1988@gmail.com james.demichele@redfin.com samza-rest/src/main/java/org/apache/samza/rest/resources/ResourceConstants.java 5 2 2971 2941 2 2 2017-03-20 2017-04-19 santhoshvenkat1988@gmail.com svenkataraman@linkedin.com samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResource.java 95 6 3180 1738 6 4 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/resources/YarnJobResourceConfig.java 15 1 2766 2766 1 1 2017-10-11 2017-10-11 ashivanna@linkedin.com ashivanna@linkedin.com samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResourceConfig.java 11 4 3180 1738 4 4 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/script/ScriptRunner.java 78 4 3180 2766 4 4 2016-08-23 2017-10-11 jacob.maes@gmail.com nsolis@linkedin.com samza-rest/src/main/java/org/apache/samza/rest/script/ScriptPathProvider.java 7 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/script/ScriptOutputHandler.java 7 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxyFactory.java 5 2 3180 2971 2 2 2016-08-23 2017-03-20 jacob.maes@gmail.com santhoshvenkat1988@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxyFactory.java 17 4 3180 2046 4 3 2016-08-23 2019-10-01 jacob.maes@gmail.com calee@linkedin.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/AbstractJobProxy.java 59 9 3180 1738 9 7 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobInstance.java 34 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxy.java 15 3 3180 1738 3 3 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobStatusProvider.java 10 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/ScriptJobProxy.java 28 3 3180 2829 3 3 2016-08-23 2017-08-09 jacob.maes@gmail.com nickpan47@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.java 71 9 3180 1738 9 8 2016-08-23 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/job/YarnRestJobStatusProvider.java 99 7 2766 1547 7 6 2017-10-11 2021-02-11 ashivanna@linkedin.com stuart.m.perks@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskResourceConfig.java 12 3 2971 1738 3 3 2017-03-20 2020-08-04 santhoshvenkat1988@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java 101 25 2971 1715 27 15 2017-03-20 2020-08-27 santhoshvenkat1988@gmail.com bharath.kumarasubramanian@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxyFactory.java 29 6 2971 941 6 5 2017-03-20 2022-10-10 santhoshvenkat1988@gmail.com james.demichele@redfin.com samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskProxyFactory.java 4 3 2971 1738 3 3 2017-03-20 2020-08-04 santhoshvenkat1988@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskProxy.java 9 3 2971 1738 3 3 2017-03-20 2020-08-04 santhoshvenkat1988@gmail.com 54013208+mabelyc@users.noreply.github.com samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationFinder.java 7 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationRecord.java 26 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/SimpleInstallationFinder.java 72 2 3180 2108 2 2 2016-08-23 2019-07-31 jacob.maes@gmail.com calee@linkedin.com samza-rest/src/main/java/org/apache/samza/rest/SamzaRestConfig.java 29 2 3180 3145 2 2 2016-08-23 2016-09-27 jacob.maes@gmail.com santhoshvenkat1988@gmail.com samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java 112 17 3180 1099 17 13 2016-08-23 2022-05-05 jacob.maes@gmail.com prateekm@utexas.edu samza-rest/src/main/java/org/apache/samza/rest/SamzaRestApplication.java 47 9 3180 941 9 6 2016-08-23 2022-10-10 jacob.maes@gmail.com james.demichele@redfin.com samza-rest/src/main/resources/log4j.xml 19 1 3180 3180 1 1 2016-08-23 2016-08-23 jacob.maes@gmail.com jacob.maes@gmail.com samza-rest/src/main/resources/log4j2.xml 19 4 2403 1942 5 5 2018-10-09 2020-01-13 pchhokra@pchhokra-mn3.linkedin.biz boryas@apache.org doap_Samza.rdf 41 2 3979 3757 2 2 2014-06-16 2015-01-24 jghoman@apache.org nramesh@linkedin.com samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.java 122 3 1745 1554 4 4 2020-07-28 2021-02-04 calee@linkedin.com 9065044+zitingshen@users.noreply.github.com samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStorageEngineFactory.java 20 4 1745 1367 4 4 2020-07-28 2021-08-10 calee@linkedin.com prateekm@utexas.edu samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/descriptors/InMemoryTableDescriptor.java 26 16 2399 2190 18 5 2018-10-13 2019-05-10 pmaheshwari@apache.org bshkolnik@linkedin.com samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngineMetrics.scala 35 13 4248 2045 13 10 2013-09-20 2019-10-02 criccomi@criccomi-mn.linkedin.biz prateekm@utexas.edu samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStoreMetrics.scala 15 4 4248 3297 4 4 2013-09-20 2016-04-28 criccomi@criccomi-mn.linkedin.biz jacob.maes@gmail.com samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala 128 14 2919 1738 16 12 2017-05-11 2020-08-04 jmehar2@illinois.edu 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStoreMetrics.scala 18 6 3955 2526 6 6 2014-07-10 2018-06-08 chinmay.cerebro@gmail.com boryas@apache.org samza-kv/src/main/scala/org/apache/samza/storage/kv/LargeMessageSafeStoreMetrics.scala 8 1 2108 2108 1 1 2019-07-31 2019-07-31 pchhokra@linkedin.com pchhokra@linkedin.com samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala 159 29 4248 1738 30 20 2013-09-20 2020-08-04 criccomi@criccomi-mn.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala 79 19 4248 1738 19 15 2013-09-20 2020-08-04 criccomi@criccomi-mn.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala 200 30 4272 1738 36 22 2013-08-27 2020-08-04 criccomi@criccomi-mn.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStoreMetrics.scala 21 14 4248 1877 15 9 2013-09-20 2020-03-18 criccomi@criccomi-mn.linkedin.biz bharath.kumarasubramanian@gmail.com samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLogMessage.scala 20 1 2919 2919 1 1 2017-05-11 2017-05-11 jmehar2@illinois.edu jmehar2@illinois.edu samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala 75 17 4167 1738 17 14 2013-12-10 2020-08-04 criccomi@criccomi-mn.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStoreMetrics.scala 23 5 4248 3297 5 5 2013-09-20 2016-04-28 criccomi@criccomi-mn.linkedin.biz jacob.maes@gmail.com samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala 192 39 4248 1315 42 28 2013-09-20 2021-10-01 criccomi@criccomi-mn.linkedin.biz dchen@apache.org samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java 179 16 2334 1204 18 5 2018-12-17 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-kv/src/main/java/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.java 166 8 1788 1367 8 6 2020-06-15 2021-08-10 calee@linkedin.com prateekm@utexas.edu samza-kv/src/main/java/org/apache/samza/storage/kv/RecordTooLargeException.java 7 2 1788 1738 2 2 2020-06-15 2020-08-04 calee@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java 106 7 2108 1738 7 5 2019-07-31 2020-08-04 pchhokra@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProviderFactory.java 9 5 2360 2348 8 3 2018-11-21 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProvider.java 29 14 2373 1204 17 4 2018-11-08 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/metrics/MetricsHelper.scala 17 10 4248 1877 11 9 2013-09-20 2020-03-18 criccomi@criccomi-mn.linkedin.biz bharath.kumarasubramanian@gmail.com samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala 40 18 3262 1598 18 14 2016-06-02 2020-12-22 jagadish1989@gmail.com pchhokra@linkedin.com samza-core/src/main/scala/org/apache/samza/metrics/reporter/JmxReporter.scala 91 9 3929 2177 9 6 2014-08-05 2019-05-23 yanfang724@gmail.com rmatharu@linkedin.com samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala 65 9 4082 759 9 7 2014-03-05 2023-04-10 jghoman@apache.org prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/metrics/MetricsRegistryMap.scala 55 8 4248 1353 8 6 2013-09-20 2021-08-24 criccomi@criccomi-mn.linkedin.biz calee@linkedin.com samza-core/src/main/scala/org/apache/samza/metrics/JvmMetrics.scala 131 10 4248 1128 10 9 2013-09-20 2022-04-06 criccomi@criccomi-mn.linkedin.biz calee@linkedin.com samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala 282 58 4279 875 61 32 2013-08-20 2022-12-15 criccomini.aux@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/system/SSPMetadataCache.java 73 2 2521 2471 2 2 2018-06-13 2018-08-02 calee@linkedin.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala 37 9 4248 2197 9 9 2013-09-20 2019-05-03 criccomi@criccomi-mn.linkedin.biz wsong@linkedin.com samza-core/src/main/scala/org/apache/samza/system/SystemProducers.scala 56 7 4271 1976 7 4 2013-08-28 2019-12-10 criccomi@criccomi-mn.linkedin.biz bharathkk@apache.org samza-core/src/main/scala/org/apache/samza/system/SystemProducersMetrics.scala 16 2 4248 3951 2 2 2013-09-20 2014-07-14 criccomi@criccomi-mn.linkedin.biz yanfang724@gmail.com samza-core/src/main/scala/org/apache/samza/system/RangeSystemStreamPartitionMatcher.scala 26 2 3243 2108 2 2 2016-06-21 2019-07-31 jose@stormpath.com calee@linkedin.com samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemConsumer.scala 84 5 4003 2526 5 4 2014-05-23 2018-06-08 yanfang724@gmail.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemAdmin.scala 86 7 4003 2960 7 5 2014-05-23 2017-03-31 yanfang724@gmail.com jvenkatr@linkedin.com samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemFactory.scala 18 1 4003 4003 1 1 2014-05-23 2014-05-23 yanfang724@gmail.com yanfang724@gmail.com samza-core/src/main/scala/org/apache/samza/system/RegexSystemStreamPartitionMatcher.scala 11 2 3243 2108 2 2 2016-06-21 2019-07-31 jose@stormpath.com calee@linkedin.com samza-core/src/main/scala/org/apache/samza/system/StreamMetadataCache.scala 61 18 4052 2165 20 15 2014-04-04 2019-06-04 mkleppmann@linkedin.com rmatharu@linkedin.com samza-core/src/main/scala/org/apache/samza/system/chooser/DefaultChooser.scala 94 10 4234 2163 12 8 2013-10-04 2019-06-06 criccomi@criccomi-mn.linkedin.biz calee@linkedin.com samza-core/src/main/scala/org/apache/samza/system/chooser/TieredPriorityChooser.scala 74 4 4234 3912 4 3 2013-10-04 2014-08-22 criccomi@criccomi-mn.linkedin.biz yanfang724@gmail.com samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala 143 20 4234 2470 23 14 2013-10-04 2018-08-03 criccomi@criccomi-mn.linkedin.biz wsong@linkedin.com samza-core/src/main/scala/org/apache/samza/system/chooser/RoundRobinChooser.scala 28 2 4234 3941 2 2 2013-10-04 2014-07-24 criccomi@criccomi-mn.linkedin.biz criccomi@criccomi-mn.(none) samza-core/src/main/scala/org/apache/samza/system/chooser/BatchingChooser.scala 66 3 4234 3912 3 2 2013-10-04 2014-08-22 criccomi@criccomi-mn.linkedin.biz yanfang724@gmail.com samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala 69 37 3934 1105 42 24 2014-07-31 2022-04-29 chinmay.cerebro@gmail.com xrchen@uwaterloo.ca samza-core/src/main/scala/org/apache/samza/job/local/ProcessJob.scala 100 12 3912 1885 12 11 2014-08-22 2020-03-10 yanfang724@gmail.com ericpan7412@gmail.com samza-core/src/main/scala/org/apache/samza/job/local/ThreadJob.scala 45 4 4066 2927 4 4 2014-03-21 2017-05-03 mkleppmann@linkedin.com navina@apache.org samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala 116 56 3934 1014 66 28 2014-07-31 2022-07-29 chinmay.cerebro@gmail.com ajthomas@linkedin.com samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala 71 38 4067 1920 42 27 2014-03-20 2020-02-04 mkleppmann@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2.java 44 4 2477 1547 4 4 2018-07-27 2021-02-11 rmatharu@linkedin.com stuart.m.perks@gmail.com samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala 105 13 4003 2190 14 12 2014-05-23 2019-05-10 mkleppmann@linkedin.com bshkolnik@linkedin.com samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2Factory.java 9 3 2477 2470 3 3 2018-07-27 2018-08-03 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/scala/org/apache/samza/serializers/JsonSerde.scala 30 5 3821 1547 5 5 2014-11-21 2021-02-11 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/scala/org/apache/samza/serializers/CheckpointV1Serde.scala 47 6 1463 1008 6 4 2021-05-06 2022-08-04 dchen1@linkedin.com mgaduputi@linkedin.com samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerde.scala 17 4 3821 1547 4 4 2014-11-21 2021-02-11 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/scala/org/apache/samza/config/RegExTopicGenerator.scala 61 7 2165 1617 7 4 2019-06-04 2020-12-03 rmatharu@linkedin.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/config/factories/PropertiesConfigFactory.scala 25 2 3912 2960 2 2 2014-08-22 2017-03-31 yanfang724@gmail.com jvenkatr@linkedin.com samza-core/src/main/scala/org/apache/samza/config/ScalaMapConfig.scala 21 4 3247 2309 4 3 2016-06-17 2019-01-11 boryas@apache.org bshkolnik@linkedin.com samza-core/src/main/scala/org/apache/samza/util/HttpUtil.scala 52 3 2577 1984 3 3 2018-04-18 2019-12-02 pmaheshw@linkedin.com calee@linkedin.com samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala 110 13 2577 1160 14 10 2018-04-18 2022-03-05 pmaheshw@linkedin.com xrchen@uwaterloo.ca samza-core/src/main/scala/org/apache/samza/util/ScalaJavaUtil.scala 43 7 2577 2291 7 6 2018-04-18 2019-01-29 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/scala/org/apache/samza/util/TimerUtil.scala 18 2 2577 2526 2 2 2018-04-18 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala 141 29 2577 990 30 18 2018-04-18 2022-08-22 pmaheshw@linkedin.com ajthomas@linkedin.com samza-core/src/main/scala/org/apache/samza/util/CommandLine.scala 23 8 4067 1898 8 7 2014-03-20 2020-02-26 mkleppmann@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/scala/org/apache/samza/util/Logging.scala 65 4 3912 759 4 4 2014-08-22 2023-04-10 yanfang724@gmail.com prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala 80 6 4082 2526 6 5 2014-03-05 2018-06-08 martin@rapportive.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/util/DefaultCoordinatorStreamConfigFactory.java 24 1 2052 2052 1 1 2019-09-25 2019-09-25 54013208+mabelyc@users.noreply.github.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamConfigFactory.java 5 1 2052 2052 1 1 2019-09-25 2019-09-25 54013208+mabelyc@users.noreply.github.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java 33 1 2144 2144 1 1 2019-06-25 2019-06-25 rmatharu@linkedin.com rmatharu@linkedin.com samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java 205 12 2177 953 12 7 2019-05-23 2022-09-28 rmatharu@linkedin.com 94939653+jia-gao@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java 53 7 2477 2177 8 3 2018-07-27 2019-05-23 rmatharu@linkedin.com rmatharu@linkedin.com samza-core/src/main/scala/org/apache/samza/diagnostics/BoundedList.java 67 1 2177 2177 1 1 2019-05-23 2019-05-23 rmatharu@linkedin.com rmatharu@linkedin.com samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java 200 7 2144 1248 7 5 2019-06-25 2021-12-07 rmatharu@linkedin.com calee@linkedin.com samza-core/src/main/scala/org/apache/samza/task/TaskInstanceCollector.scala 23 3 3915 3158 3 3 2014-08-19 2016-09-14 criccomi@criccomi-mn.linkedin.biz b.cogic@levi9.com samza-core/src/main/scala/org/apache/samza/task/ReadableCoordinator.scala 13 3 4024 2990 3 3 2014-05-02 2017-03-01 mkleppmann@linkedin.com boryas@apache.org samza-core/src/main/scala/org/apache/samza/container/SameThreadExecutor.scala 5 1 3244 3244 1 1 2016-06-20 2016-06-20 cpettitt@linkedin.com cpettitt@linkedin.com samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 892 216 4279 618 257 75 2013-08-20 2023-08-29 criccomini.aux@gmail.com bharathkk@apache.org samza-core/src/main/scala/org/apache/samza/container/TaskInstanceExceptionHandler.scala 44 2 3886 2163 2 2 2014-09-17 2019-06-06 dchen@linkedin.com calee@linkedin.com samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala 35 14 4248 164 14 12 2013-09-20 2024-11-25 criccomi@criccomi-mn.linkedin.biz yehaolan@gmail.com samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala 38 33 4248 650 33 21 2013-09-20 2023-07-28 criccomi@criccomi-mn.linkedin.biz boryas@apache.org samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala 506 102 4271 164 117 50 2013-08-28 2024-11-25 criccomi@criccomi-mn.linkedin.biz yehaolan@gmail.com samza-core/src/main/scala/org/apache/samza/coordinator/Latch.java 7 1 2962 2962 1 1 2017-03-29 2017-03-29 boryas@apache.org boryas@apache.org samza-core/src/main/scala/org/apache/samza/coordinator/stream/CoordinatorStreamWriterCommandLine.scala 42 2 3584 1925 3 3 2015-07-16 2020-01-30 abdolla2@illinois.edu ke.wu.cs@icloud.com samza-core/src/main/scala/org/apache/samza/coordinator/server/JobServlet.scala 14 5 3850 1702 5 4 2014-10-23 2020-09-09 criccomi@criccomi-mn.linkedin.biz prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/coordinator/server/HttpServer.scala 58 6 3850 3081 6 5 2014-10-23 2016-11-30 criccomi@criccomi-mn.linkedin.biz fji@linkedin.com samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala 63 67 3019 1317 75 28 2017-01-31 2021-09-29 navina@apache.org calee@linkedin.com samza-core/src/main/scala/org/apache/samza/storage/KafkaNonTransactionalStateTaskBackupManager.scala 50 2 1462 1367 2 2 2021-05-07 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java 381 6 793 398 8 4 2023-03-07 2024-04-05 pmaheshw@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java 318 5 793 398 6 3 2023-03-07 2024-04-05 pmaheshw@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java 284 2 637 629 2 1 2023-08-10 2023-08-18 72765053+shekhars-li@users.noreply.github.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java 304 65 2350 140 72 22 2018-12-01 2024-12-19 rmatharu@linkedin.com ajo.thomas24@gmail.com samza-core/src/main/scala/org/apache/samza/storage/KafkaTransactionalStateTaskBackupManager.scala 55 2 1462 1367 2 2 2021-05-07 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala 55 10 3937 1367 10 8 2014-07-28 2021-08-10 jghoman@apache.org prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala 406 52 4074 1008 60 30 2014-03-13 2022-08-04 criccomi@criccomi-ld.linkedin.biz mgaduputi@linkedin.com samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala 160 36 4067 1367 38 24 2014-03-20 2021-08-10 mkleppmann@linkedin.com prateekm@utexas.edu samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManagerMetrics.scala 10 1 3682 3682 1 1 2015-04-09 2015-04-09 renatoj.marroquin@gmail.com renatoj.marroquin@gmail.com samza-core/src/main/java/org/apache/samza/metrics/JmxMetricsAccessor.java 59 1 3327 3327 1 1 2016-03-29 2016-03-29 xiliu@linkedin.com xiliu@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/JmxUtil.java 28 1 3327 3327 1 1 2016-03-29 2016-03-29 xiliu@linkedin.com xiliu@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/BaseServerMetrics.java 11 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/MetricGroup.java 35 9 3578 1877 13 6 2015-07-22 2020-03-18 roger.hoover@gmail.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java 138 2 1255 1248 2 1 2021-11-30 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporter.java 84 3 1462 1368 3 3 2021-05-07 2021-08-09 calee@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java 179 2 1255 1248 2 1 2021-11-30 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.java 110 1 1255 1255 1 1 2021-11-30 2021-11-30 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporterConfig.java 21 3 1462 1368 3 3 2021-05-07 2021-08-09 calee@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporterFactory.java 19 3 1462 1368 3 3 2021-05-07 2021-08-09 calee@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java 50 2 1255 1248 2 1 2021-11-30 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java 47 2 1255 1248 2 1 2021-11-30 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/metrics/MetricsBase.java 23 1 3578 3578 1 1 2015-07-22 2015-07-22 roger.hoover@gmail.com roger.hoover@gmail.com samza-core/src/main/java/org/apache/samza/system/SystemAdmins.java 46 11 2659 1367 11 10 2018-01-26 2021-08-10 lindong28@gmail.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java 59 10 2578 1738 11 6 2018-04-17 2020-08-04 bkumaras@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java 58 11 2578 1861 13 9 2018-04-17 2020-04-03 bkumaras@linkedin.com tommykuaidlaa@gmail.com samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java 28 9 2578 2422 10 5 2018-04-17 2018-09-20 bkumaras@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java 137 24 2578 1367 26 14 2018-04-17 2021-08-10 bkumaras@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java 56 7 2578 1738 8 6 2018-04-17 2020-08-04 bkumaras@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/system/descriptors/DelegatingSystemDescriptor.java 24 7 2399 2284 8 6 2018-10-13 2019-02-05 pmaheshwari@apache.org wsong@linkedin.com samza-core/src/main/java/org/apache/samza/job/model/JobModelUtil.java 93 8 2177 1496 8 6 2019-05-23 2021-04-03 dnishimura@gmail.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/job/ShellCommandBuilder.java 29 6 1471 472 6 4 2021-04-28 2024-01-22 calee@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java 243 1 1353 1353 1 1 2021-08-24 2021-08-24 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java 91 28 2904 1354 32 16 2017-05-26 2021-08-23 boryas@apache.org calee@linkedin.com samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinatorFactory.java 13 5 2904 2116 5 5 2017-05-26 2019-07-23 boryas@apache.org dnishimura@gmail.com samza-core/src/main/java/org/apache/samza/standalone/PassthroughCoordinationUtilsFactory.java 10 2 2795 2774 2 1 2017-09-12 2017-10-03 xiliu@xiliu-ld1.linkedin.biz xiliu@xiliu-ld1.linkedin.biz samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunners.java 26 1 1700 1700 1 1 2020-09-11 2020-09-11 kwu@linkedin.com kwu@linkedin.com samza-core/src/main/java/org/apache/samza/runtime/UUIDGenerator.java 9 1 2953 2953 1 1 2017-04-07 2017-04-07 navina@apache.org navina@apache.org samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerUtil.java 25 5 2267 2017 5 5 2019-02-22 2019-10-30 atoomula@linkedin.com sanil.jain15@gmail.com samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java 389 63 2984 990 71 27 2017-03-07 2022-08-22 xiliu@xiliu-ld.linkedin.biz ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/runtime/DefaultLocationIdProviderFactory.java 9 3 2463 2457 3 3 2018-08-10 2018-08-16 spvenkat@usc.edu wsong@linkedin.com samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java 46 21 2974 1862 22 11 2017-03-17 2020-04-02 xiliu@xiliu-ld.linkedin.biz ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java 195 38 2304 605 38 18 2019-01-16 2023-09-11 xiliu@linkedin.com guanjun0215@gmail.com samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java 49 50 2967 1248 58 23 2017-03-24 2021-12-07 xiliu@xiliu-ld.linkedin.biz calee@linkedin.com samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java 122 42 2984 1105 45 18 2017-03-07 2022-04-29 xiliu@xiliu-ld.linkedin.biz xrchen@uwaterloo.ca samza-core/src/main/java/org/apache/samza/runtime/ClusterBasedProcessorLifecycleListener.java 101 1 2060 2060 1 1 2019-09-17 2019-09-17 ashivanna@linkedin.com ashivanna@linkedin.com samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerOperation.java 15 1 2957 2957 1 1 2017-04-03 2017-04-03 jmaes@linkedin.com jmaes@linkedin.com samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java 83 10 2886 1014 11 9 2017-06-13 2022-07-29 xiliu@xiliu-ld.linkedin.biz ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobModelMixIn.java 17 5 3845 1547 6 6 2014-10-28 2021-02-11 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java 237 27 3845 1008 30 20 2014-10-28 2022-08-04 criccomi@criccomi-mn.linkedin.biz mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/serializers/model/KafkaStateCheckpointMarkerMixin.java 20 2 1463 1367 2 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/serializers/model/JsonProcessorLocalityMixIn.java 19 2 1715 1547 2 2 2020-08-27 2021-02-11 bharath.kumarasubramanian@gmail.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/model/JsonCheckpointV2Mixin.java 22 3 1463 1367 3 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/serializers/model/JsonLocalityModelMixIn.java 14 2 1715 1547 2 2 2020-08-27 2021-02-11 bharath.kumarasubramanian@gmail.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/model/JsonContainerModelMixIn.java 14 5 3845 1547 6 6 2014-10-28 2021-02-11 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java 20 8 3845 1547 10 9 2014-10-28 2021-02-11 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobCoordinatorMetadataMixIn.java 17 2 1612 1547 2 2 2020-12-08 2021-02-11 bharath.kumarasubramanian@gmail.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/serializers/CheckpointV2Serde.java 25 3 1463 1367 3 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/serializers/JsonCheckpoint.java 24 2 1463 1367 2 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/logging/LoggingContextHolder.java 22 1 1317 1317 1 1 2021-09-29 2021-09-29 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkDistributedLock.java 81 3 2809 2178 3 3 2017-08-29 2019-05-22 boryas@apache.org mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java 553 84 2982 829 92 27 2017-03-09 2023-01-30 bshkolni@bshkolni-ld1.linkedin.biz katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ProcessorData.java 40 5 2933 2422 6 5 2017-04-27 2018-09-20 boryas@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java 127 16 3006 829 16 8 2017-02-13 2023-01-30 navina@apache.org katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkBarrierListener.java 6 1 2905 2905 1 1 2017-05-25 2017-05-25 navina@apache.org navina@apache.org samza-core/src/main/java/org/apache/samza/zk/ZkUtilsMetrics.java 19 4 2857 2526 4 4 2017-07-12 2018-06-08 svenkataraman@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorFactory.java 41 31 2982 829 34 16 2017-03-09 2023-01-30 bshkolni@bshkolni-ld1.linkedin.biz katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java 45 11 3006 1496 12 5 2017-02-13 2021-04-03 navina@apache.org bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java 48 11 2962 829 12 7 2017-03-29 2023-01-30 boryas@apache.org katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkStringSerializer.java 31 4 2241 829 4 4 2019-03-20 2023-01-30 svenkataraman@linkedin.com katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java 156 23 2990 1738 23 13 2017-03-01 2020-08-04 boryas@apache.org 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java 484 36 3006 829 38 15 2017-02-13 2023-01-30 navina@apache.org katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStore.java 120 6 2423 829 9 5 2018-09-19 2023-01-30 wsong@linkedin.com katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorMetrics.java 26 4 2873 2145 4 4 2017-06-26 2019-06-24 pawas2703@gmail.com dchen1@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkSessionMetrics.java 19 3 2298 2291 3 3 2019-01-22 2019-01-29 spvenkat@usc.edu bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java 46 10 2809 829 11 7 2017-08-29 2023-01-30 boryas@apache.org katiliu@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkClusterMembership.java 46 1 2178 2178 1 1 2019-05-22 2019-05-22 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStoreFactory.java 15 3 2423 2178 4 4 2018-09-19 2019-05-22 wsong@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java 35 7 2962 2795 7 5 2017-03-29 2017-09-12 boryas@apache.org xiliu@xiliu-ld1.linkedin.biz samza-core/src/main/java/org/apache/samza/zk/ScheduleAfterDebounceTime.java 103 14 3003 2526 14 7 2017-02-16 2018-06-08 boryas@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java 95 17 2411 695 20 9 2018-10-01 2023-06-13 calee@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/context/InternalTaskContext.java 32 6 2255 1368 6 6 2019-03-06 2021-08-09 cyril26pot@hotmail.fr prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/context/JobContextImpl.java 39 7 2411 1715 10 5 2018-10-01 2020-08-27 calee@linkedin.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/context/ContainerContextImpl.java 27 4 2411 695 5 5 2018-10-01 2023-06-13 calee@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/context/ContextImpl.java 72 8 2411 2309 11 4 2018-10-01 2019-01-11 calee@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/batching/CompactBatchProvider.java 7 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java 27 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/TableBatchHandler.java 111 4 2178 1204 4 4 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/BatchProcessor.java 125 5 2178 1204 5 5 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/AbstractBatch.java 39 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatchProvider.java 7 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/BatchingNotSupportedException.java 15 1 2178 2178 1 1 2019-05-22 2019-05-22 34698550+dengpanyin@users.noreply.github.com 34698550+dengpanyin@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/UpdateOperation.java 28 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/CompactBatch.java 42 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/BatchMetrics.java 18 1 2178 2178 1 1 2019-05-22 2019-05-22 34698550+dengpanyin@users.noreply.github.com 34698550+dengpanyin@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java 30 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatch.java 30 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java 40 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/BatchHandler.java 5 2 2178 1204 2 2 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/batching/AsyncBatchingTable.java 120 3 2178 1204 3 3 2019-05-22 2022-01-20 34698550+dengpanyin@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java 123 7 2303 1204 8 5 2019-01-17 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/retry/FailsafeAdapter.java 55 7 2425 1367 7 7 2018-09-17 2021-08-10 pdu@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/table/retry/RetryMetrics.java 16 5 2425 2183 5 4 2018-09-17 2019-05-17 pdu@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/TableManager.java 60 33 2711 1204 39 10 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/utils/TableMetricsUtil.java 52 8 2519 2178 11 7 2018-06-15 2019-05-22 wsong@wsong-mn2.linkedin.biz 34698550+dengpanyin@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/utils/TableMetrics.java 56 7 2334 1192 7 3 2018-12-17 2022-02-01 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java 152 7 2303 1204 8 5 2019-01-17 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/BaseTableProvider.java 21 9 2373 2348 14 3 2018-11-08 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/ReadWriteTableDelegate.java 76 1 1203 1203 1 1 2022-01-21 2022-01-21 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/BaseReadWriteUpdateTable.java 38 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java 58 25 2485 1738 28 9 2018-07-19 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/caching/SupplierGauge.java 16 2 2534 2526 2 2 2018-05-31 2018-06-08 pdu@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProviderFactory.java 9 11 2534 2348 14 5 2018-05-31 2018-12-03 pdu@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProvider.java 32 22 2534 1204 27 8 2018-05-31 2022-01-20 pdu@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java 175 23 2534 1204 27 9 2018-05-31 2022-01-20 pdu@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProviderFactory.java 9 11 2534 2348 14 5 2018-05-31 2018-12-03 pdu@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java 61 25 2534 1204 30 8 2018-05-31 2022-01-20 pdu@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java 271 26 2534 1204 31 10 2018-05-31 2022-01-20 pdu@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java 119 34 2617 1204 40 9 2018-03-09 2022-01-20 pdu@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProviderFactory.java 9 11 2617 2348 14 5 2018-03-09 2018-12-03 pdu@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java 344 14 2334 1204 15 9 2018-12-17 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/table/remote/NoOpTableReadFunction.java 13 1 2172 2172 1 1 2019-05-28 2019-05-28 wsong@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/table/remote/AsyncRemoteTable.java 98 6 2303 1204 7 4 2019-01-17 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java 166 43 3003 1204 47 14 2017-02-16 2022-01-20 nickpan47@gmail.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/OperatorSpecGraph.java 73 13 2540 2395 16 6 2018-05-25 2018-10-17 nickpan47@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java 77 38 3003 1204 39 14 2017-02-16 2022-01-20 nickpan47@gmail.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java 92 18 3003 2415 19 12 2017-02-16 2018-09-27 nickpan47@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java 21 5 2661 2415 6 6 2018-01-24 2018-09-27 xinyuliu.us@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/SinkOperatorSpec.java 22 13 3003 2415 14 10 2017-02-16 2018-09-27 nickpan47@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java 40 9 2779 2415 11 8 2017-09-28 2018-09-27 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/StatefulOperatorSpec.java 5 1 2773 2773 1 1 2017-10-04 2017-10-04 pmaheshw@linkedin.com pmaheshw@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/OutputStreamImpl.java 28 13 2892 2437 13 6 2017-06-07 2018-09-05 pmaheshw@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/WindowState.java 12 1 3003 3003 1 1 2017-02-16 2017-02-16 nickpan47@gmail.com nickpan47@gmail.com samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java 31 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java 45 23 2892 2395 25 11 2017-06-07 2018-10-17 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java 24 16 2711 1204 18 9 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/spec/JoinOperatorSpec.java 77 13 2892 2415 14 10 2017-06-07 2018-09-27 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java 66 29 3003 1204 32 14 2017-02-16 2022-01-20 nickpan47@gmail.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java 21 13 2892 2197 15 9 2017-06-07 2019-05-03 pmaheshw@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/StreamTableJoinOperatorSpec.java 34 11 2711 2180 13 6 2017-12-05 2019-05-20 wsong@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/MapOperatorSpec.java 43 6 2540 2401 9 6 2018-05-25 2018-10-11 nickpan47@gmail.com jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/StreamOperatorSpec.java 12 13 3003 2526 13 7 2017-02-16 2018-06-08 nickpan47@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/spec/FilterOperatorSpec.java 42 6 2540 2401 9 6 2018-05-25 2018-10-11 nickpan47@gmail.com jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/StoreDescriptor.java 48 4 2773 2190 4 4 2017-10-04 2019-05-10 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/FlatMapOperatorSpec.java 17 4 2540 2415 5 5 2018-05-25 2018-09-27 nickpan47@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/AsyncFlatMapOperatorSpec.java 22 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java 22 4 2540 2415 5 5 2018-05-25 2018-09-27 nickpan47@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/functions/PartialJoinFunction.java 8 6 3003 2471 6 5 2017-02-16 2018-08-02 nickpan47@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/util/InternalInMemoryStore.java 97 8 2977 2017 8 6 2017-03-14 2019-10-30 pmaheshw@linkedin.com sanil.jain15@gmail.com samza-core/src/main/java/org/apache/samza/operators/stream/IntermediateMessageStreamImpl.java 33 19 2892 2395 20 8 2017-06-07 2018-10-17 pmaheshw@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/AnyTriggerImpl.java 50 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTriggerImpl.java 47 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java 40 3 2972 1738 3 3 2017-03-19 2020-08-04 jvenkatr@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/triggers/Cancellable.java 4 3 2972 2526 3 3 2017-03-19 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/triggers/CountTriggerImpl.java 31 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/RepeatingTriggerImpl.java 36 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/TriggerImpl.java 7 3 2972 2526 3 3 2017-03-19 2018-06-08 jvenkatr@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/triggers/TriggerImpls.java 25 1 2972 2972 1 1 2017-03-19 2017-03-19 jvenkatr@linkedin.com jvenkatr@linkedin.com samza-core/src/main/java/org/apache/samza/operators/triggers/TimeTriggerImpl.java 40 3 2972 1738 3 3 2017-03-19 2020-08-04 jvenkatr@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableWithUpdateOperatorImpl.java 85 1 1204 1204 1 1 2022-01-20 2022-01-20 ajothomas@users.noreply.github.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java 81 21 2779 1014 24 13 2017-09-28 2022-07-29 pmaheshw@linkedin.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/TriggerKey.java 48 3 2972 2764 3 3 2017-03-19 2017-10-13 jvenkatr@linkedin.com jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java 52 9 2778 875 9 8 2017-09-29 2022-12-15 xinyuliu.us@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java 144 10 2778 260 11 7 2017-09-29 2024-08-21 xinyuliu.us@gmail.com xinyuliu.us@gmail.com samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.java 64 12 2661 1014 14 10 2018-01-24 2022-07-29 xinyuliu.us@gmail.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java 26 5 2417 260 6 6 2018-09-25 2024-08-21 wsong@linkedin.com xinyuliu.us@gmail.com samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java 43 19 2711 1204 22 8 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/FlatmapOperatorImpl.java 34 3 2227 2197 3 3 2019-04-03 2019-05-03 bharath.kumarasubramanian@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java 48 18 2892 2197 20 13 2017-06-07 2019-05-03 pmaheshw@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesKey.java 41 2 2775 2764 3 2 2017-10-02 2017-10-13 jvenkatraman@linkedin.com jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesKeySerde.java 50 2 2775 2764 2 2 2017-10-02 2017-10-13 jagadish@apache.org jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStoreImpl.java 143 9 2775 2375 11 7 2017-10-02 2018-11-06 jagadish@apache.org wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/store/TimestampedValueSerde.java 31 3 2773 2471 3 3 2017-10-04 2018-08-02 pmaheshw@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStore.java 13 5 2775 2471 5 5 2017-10-02 2018-08-02 jagadish@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java 44 19 2892 2197 22 10 2017-06-07 2019-05-03 pmaheshw@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/StreamTableJoinOperatorImpl.java 51 18 2711 1204 22 8 2017-12-05 2022-01-20 wsong@linkedin.com ajothomas@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/EndOfStreamStates.java 50 6 2778 1738 6 6 2017-09-29 2020-08-04 xinyuliu.us@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java 288 27 3003 2197 32 12 2017-02-16 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/TriggerScheduler.java 64 4 2972 2197 4 4 2017-03-19 2019-05-03 jvenkatr@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/DrainStates.java 60 1 1014 1014 1 1 2022-07-29 2022-07-29 ajthomas@linkedin.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/SinkOperatorImpl.java 36 10 3003 2197 12 8 2017-02-16 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/AsyncFlatmapOperatorImpl.java 34 4 2227 1876 4 4 2019-04-03 2020-03-19 bharath.kumarasubramanian@gmail.com tommykuaidlaa@gmail.com samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java 276 45 2955 265 53 20 2017-04-05 2024-08-16 pmaheshw@linkedin.com xinyuliu.us@gmail.com samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java 69 17 3003 2197 19 10 2017-02-16 2019-05-03 nickpan47@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java 412 54 3003 534 60 20 2017-02-16 2023-11-21 nickpan47@gmail.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/operators/TableImpl.java 16 8 2711 2348 9 5 2017-12-05 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/drain/DrainMonitor.java 158 2 1060 1014 2 1 2022-06-13 2022-07-29 ajthomas@linkedin.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/drain/DrainNotificationObjectMapper.java 60 4 1060 875 4 2 2022-06-13 2022-12-15 ajthomas@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java 95 5 1060 875 5 2 2022-06-13 2022-12-15 ajthomas@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/config/ShellCommandConfig.java 60 7 1884 535 7 6 2020-03-11 2023-11-20 calee@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/config/InMemorySystemConfig.java 11 2 2512 2471 2 2 2018-06-22 2018-08-02 sanil.jain15@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/config/TaskConfig.java 276 22 2163 164 22 13 2019-06-06 2024-11-25 calee@linkedin.com yehaolan@gmail.com samza-core/src/main/java/org/apache/samza/config/MetricsConfig.java 46 1 2158 2158 1 1 2019-06-11 2019-06-11 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/config/StreamConfig.java 174 5 1884 1014 5 4 2020-03-11 2022-07-29 calee@linkedin.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java 62 18 2953 618 20 15 2017-04-07 2023-08-29 navina@apache.org bharathkk@apache.org samza-core/src/main/java/org/apache/samza/config/BlobStoreConfig.java 45 7 1444 624 9 3 2021-05-25 2023-08-23 72765053+shekhars-li@users.noreply.github.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoaderFactory.java 16 4 1968 1946 7 2 2019-12-18 2020-01-09 kwu@kwu-ld2.linkedin.biz boryas@apache.org samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoader.java 36 4 1968 1946 6 2 2019-12-18 2020-01-09 kwu@kwu-ld2.linkedin.biz boryas@apache.org samza-core/src/main/java/org/apache/samza/config/ZkConfig.java 32 5 3006 1496 5 3 2017-02-13 2021-04-03 navina@apache.org bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/config/SerializerConfig.java 65 1 2159 2159 1 1 2019-06-10 2019-06-10 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/config/RunLoopConfig.java 50 1 618 618 2 1 2023-08-29 2023-08-29 bharathkk@apache.org bharathkk@apache.org samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java 164 15 3262 1368 19 14 2016-06-02 2021-08-09 jagadish1989@gmail.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/config/JobConfig.java 345 37 2108 534 43 17 2019-07-31 2023-11-21 calee@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/config/StorageConfig.java 238 27 2192 255 31 19 2019-05-08 2024-08-26 37879374+cameronlee314@users.noreply.github.com yehaolan@gmail.com samza-core/src/main/java/org/apache/samza/config/FileSystemCheckpointManagerConfig.java 11 3 2235 2197 3 3 2019-03-26 2019-05-03 37879374+cameronlee314@users.noreply.github.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java 55 17 3019 1129 20 11 2017-01-31 2022-04-05 navina@apache.org calee@linkedin.com samza-core/src/main/java/org/apache/samza/config/DefaultChooserConfig.java 41 5 3290 2051 7 4 2016-05-05 2019-09-26 jacob.maes@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/config/EnvironmentConfigRewriter.java 44 1 3669 3669 1 1 2015-04-22 2015-04-22 dan@state.com dan@state.com samza-core/src/main/java/org/apache/samza/config/SystemConfig.java 116 10 2235 1689 14 7 2019-03-26 2020-09-22 37879374+cameronlee314@users.noreply.github.com yuhcheng@linkedin.com samza-core/src/main/java/org/apache/samza/scheduler/CallbackSchedulerImpl.java 15 4 2411 2172 5 5 2018-10-01 2019-05-28 calee@linkedin.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java 122 5 2172 1738 5 3 2019-05-28 2020-08-04 bharath.kumarasubramanian@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/clustermanager/ContainerAllocator.java 223 25 3262 1596 28 13 2016-06-02 2020-12-24 jagadish1989@gmail.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManager.java 9 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java 97 9 3262 1598 9 8 2016-06-02 2020-12-22 jagadish1989@gmail.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java 399 14 2257 1596 14 11 2019-03-04 2020-12-24 rmatharu@linkedin.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java 42 20 3262 1598 20 13 2016-06-02 2020-12-22 jagadish1989@gmail.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceStatus.java 32 4 3262 2197 4 4 2016-06-02 2019-05-03 jagadish1989@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SingleFaultDomainManager.java 18 3 1470 1368 3 3 2021-04-29 2021-08-09 calee@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/clustermanager/ContainerManager.java 368 17 2050 1596 19 7 2019-09-27 2020-12-24 sanil.jain15@gmail.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/StandbyTaskUtil.java 63 3 2257 2197 3 3 2019-03-04 2019-05-03 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java 308 51 3262 1060 60 25 2016-06-02 2022-06-13 jagadish1989@gmail.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/ResourceManagerFactory.java 4 1 3262 3262 1 1 2016-06-02 2016-06-02 jagadish1989@gmail.com jagadish1989@gmail.com samza-core/src/main/java/org/apache/samza/clustermanager/ResourceRequestState.java 264 15 3262 1738 16 12 2016-06-02 2020-08-04 jagadish1989@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinatorRunner.java 93 5 1709 1368 5 5 2020-09-02 2021-08-09 ke.wu.cs@icloud.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManagerFactory.java 8 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java 455 52 3262 273 53 24 2016-06-02 2024-08-08 jagadish1989@gmail.com mikebarskiy@gmail.com samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorLaunchException.java 16 3 2227 2197 3 3 2019-04-03 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SingleFaultDomainManagerFactory.java 9 3 1470 1368 3 3 2021-04-29 2021-08-09 calee@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMessageObjectMapper.java 99 2 1934 1547 2 2 2020-01-21 2021-02-11 sanil.jain15@gmail.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadata.java 78 3 1906 1738 3 3 2020-02-18 2020-08-04 sanil.jain15@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementRequestAllocator.java 66 4 1934 1738 4 2 2020-01-21 2020-08-04 sanil.jain15@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java 176 5 1934 1352 5 4 2020-01-21 2021-08-25 sanil.jain15@gmail.com jon@bringhurst.org samza-core/src/main/java/org/apache/samza/clustermanager/DefaultApplicationMain.java 20 1 1700 1700 1 1 2020-09-11 2020-09-11 kwu@linkedin.com kwu@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/JobCoordinatorLaunchUtil.java 97 8 1877 1268 8 4 2020-03-18 2021-11-17 ke.wu.cs@icloud.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorFailure.java 22 4 2227 2094 4 4 2019-04-03 2019-08-14 pmaheshwari@apache.org dnishimura@gmail.com samza-core/src/main/java/org/apache/samza/clustermanager/ClusterResourceManager.java 27 12 3262 1738 14 11 2016-06-02 2020-08-04 jagadish1989@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java 41 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainType.java 4 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResource.java 62 8 3262 1889 10 9 2016-06-02 2020-03-06 jagadish1989@gmail.com fxie@linkedin.com samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java 50 2 2183 1547 3 3 2019-05-17 2021-02-11 bshkolnik@linkedin.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/startpoint/StartpointObjectMapper.java 42 2 2183 1547 3 3 2019-05-17 2021-02-11 bshkolnik@linkedin.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java 262 15 2330 1044 16 11 2018-12-21 2022-06-29 dnishimura@linkedin.com shuai.xyz@gmail.com samza-core/src/main/java/org/apache/samza/util/MetricsReporterLoader.java 28 9 3089 1277 9 6 2016-11-22 2021-11-08 santhoshvenkat1988@gmail.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/util/FutureUtil.java 116 7 1462 827 11 4 2021-05-07 2023-02-01 dchen1@linkedin.com shesharma@linkedin.com samza-core/src/main/java/org/apache/samza/util/ShutdownUtil.java 31 4 2526 2309 5 5 2018-06-08 2019-01-11 boryas@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/util/Util.java 29 5 1984 1738 5 3 2019-12-02 2020-08-04 calee@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/util/BoundedLinkedHashSet.java 24 1 1906 1906 1 1 2020-02-18 2020-02-18 sanil.jain15@gmail.com sanil.jain15@gmail.com samza-core/src/main/java/org/apache/samza/util/HighResolutionClock.java 4 3 3244 1022 3 3 2016-06-20 2022-07-21 cpettitt@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java 124 24 2177 1080 28 10 2019-05-23 2022-05-24 rmatharu@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/util/ThrottlingExecutor.java 63 7 3244 1022 7 6 2016-06-20 2022-07-21 cpettitt@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/util/SystemHighResolutionClock.java 12 3 3244 1022 3 3 2016-06-20 2022-07-21 cpettitt@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/util/StreamUtil.java 45 8 2477 2047 11 4 2018-07-27 2019-09-30 pmaheshwari@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/util/RetryPolicyConfig.java 42 1 827 827 3 2 2023-02-01 2023-02-01 prateekm@utexas.edu shesharma@linkedin.com samza-core/src/main/java/org/apache/samza/util/ReflectionUtil.java 58 4 2172 1738 4 2 2019-05-28 2020-08-04 calee@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/util/SystemClock.java 12 1 1022 1022 1 1 2022-07-21 2022-07-21 ke.wu.cs@icloud.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/util/MathUtil.java 36 2 2577 2526 2 2 2018-04-18 2018-06-08 pmaheshw@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java 88 3 2339 2309 3 3 2018-12-12 2019-01-11 pmaheshwari@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/util/ThrottlingScheduler.java 76 4 3123 1022 4 4 2016-10-19 2022-07-21 pmaheshwari@linkedin.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/util/SamzaUncaughtExceptionHandler.java 23 5 2535 2309 5 4 2018-05-30 2019-01-11 pmaheshwari@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/util/Throttleable.java 7 1 3123 3123 1 1 2016-10-19 2016-10-19 pmaheshwari@linkedin.com pmaheshwari@linkedin.com samza-core/src/main/java/org/apache/samza/util/EmbeddedTaggedRateLimiter.java 103 10 2627 1738 14 8 2018-02-27 2020-08-04 wsong@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/util/ConfigUtil.java 55 4 2019 1938 4 4 2019-10-28 2020-01-17 54013208+mabelyc@users.noreply.github.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/executors/KeyBasedExecutorService.java 106 2 2506 2471 2 2 2018-06-28 2018-08-02 calee@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java 372 61 3019 1014 71 23 2017-01-31 2022-07-29 navina@apache.org ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java 75 23 2973 695 26 13 2017-03-18 2023-06-13 nickpan47@gmail.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/task/TaskCallbackListener.java 5 2 3215 2172 2 2 2016-07-19 2019-05-28 xiliu@linkedin.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java 130 40 3003 695 47 19 2017-02-16 2023-06-13 nickpan47@gmail.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/task/AsyncStreamTaskAdapter.java 63 6 3215 2401 8 8 2016-07-19 2018-10-11 xiliu@linkedin.com jvenkatraman@linkedin.com samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java 92 8 3215 1687 9 6 2016-07-19 2020-09-24 xiliu@linkedin.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/task/TaskCallbackFactory.java 4 1 3215 3215 1 1 2016-07-19 2016-07-19 xiliu@linkedin.com xiliu@linkedin.com samza-core/src/main/java/org/apache/samza/task/CoordinatorRequests.java 45 2 3215 3102 2 2 2016-07-19 2016-11-09 xiliu@linkedin.com xiliu@xiliu-ld.linkedin.biz samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java 86 13 3215 618 14 13 2016-07-19 2023-08-29 xiliu@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java 40 4 1155 547 4 2 2022-03-10 2023-11-08 chris.zhang@berkeley.edu bharathkk@apache.org samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java 44 1 1619 1619 1 1 2020-12-01 2020-12-01 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/container/SamzaContainerStatus.java 8 1 2172 2172 1 1 2019-05-28 2019-05-28 bharath.kumarasubramanian@gmail.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatClient.java 72 8 2920 1547 8 7 2017-05-10 2021-02-11 ashivanna@linkedin.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/HashSystemStreamPartitionMapperFactory.java 9 2 2347 2346 3 3 2018-12-04 2018-12-05 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartition.java 41 11 3545 1008 15 9 2015-08-24 2022-08-04 yanfang724@gmail.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartition.java 44 12 3545 1008 16 10 2015-08-24 2022-08-04 yanfang724@gmail.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/HashSystemStreamPartitionMapper.java 17 2 2347 2346 3 3 2018-12-04 2018-12-05 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartitionFactory.java 8 1 3545 3545 1 1 2015-08-24 2015-08-24 yanfang724@gmail.com yanfang724@gmail.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/SSPGrouperProxy.java 152 13 2347 1738 15 8 2018-12-04 2020-08-04 wsong@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartitionFactory.java 8 2 3545 3161 2 2 2015-08-24 2016-09-11 yanfang724@gmail.com neilfordyce@hotmail.com samza-core/src/main/java/org/apache/samza/container/grouper/stream/AllSspToSingleTaskGrouperFactory.java 48 7 3019 1738 7 5 2017-01-31 2020-08-04 navina@apache.org 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GrouperMetadata.java 14 2 2346 2339 3 3 2018-12-05 2018-12-12 bshkolnik@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperProxy.java 68 6 2298 2197 6 3 2019-01-22 2019-05-03 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIdsFactory.java 9 1 3003 3003 1 1 2017-02-16 2017-02-16 boryas@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/container/grouper/task/BalancingTaskNameGrouper.java 11 3 3320 2339 4 4 2016-04-05 2018-12-12 jacob.maes@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java 91 31 3320 1738 38 14 2016-04-05 2020-08-04 jacob.maes@gmail.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/grouper/task/SingleContainerGrouperFactory.java 31 6 3019 2108 8 5 2017-01-31 2019-07-31 navina@apache.org calee@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCountFactory.java 9 5 3320 2339 8 5 2016-04-05 2018-12-12 jacob.maes@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperFactory.java 5 3 3572 2339 4 4 2015-07-28 2018-12-12 j.jung@levi9.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GrouperMetadataImpl.java 35 2 2346 2339 3 3 2018-12-05 2018-12-12 bshkolnik@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java 89 11 2344 1547 11 6 2018-12-07 2021-02-11 spvenkat@usc.edu stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java 149 16 3320 2190 21 11 2016-04-05 2019-05-10 jacob.maes@gmail.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIds.java 130 11 3003 1738 13 10 2017-02-16 2020-08-04 boryas@apache.org 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouper.java 18 5 3572 2339 6 6 2015-07-28 2018-12-12 j.jung@levi9.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskGroup.java 42 2 2346 2339 3 3 2018-12-05 2018-12-12 bshkolnik@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatResponse.java 11 2 2920 1547 2 2 2017-05-10 2021-02-11 ashivanna@linkedin.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java 27 29 3215 618 31 24 2016-07-19 2023-08-29 xiliu@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/container/RunLoopTask.java 23 3 1802 1014 3 3 2020-06-01 2022-07-29 bkonold@users.noreply.github.com ajthomas@linkedin.com samza-core/src/main/java/org/apache/samza/container/SecurityManager.java 5 1 3255 3255 1 1 2016-06-09 2016-06-09 chens_cs@hotmail.com chens_cs@hotmail.com samza-core/src/main/java/org/apache/samza/container/SamzaContainerListener.java 7 9 2927 2172 10 8 2017-05-03 2019-05-28 navina@apache.org bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/container/RunLoop.java 742 20 2172 618 26 11 2019-05-28 2023-08-29 bharath.kumarasubramanian@gmail.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java 53 9 3207 875 9 7 2016-07-27 2022-12-15 jagadish1989@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsMonitor.java 9 3 3207 875 3 3 2016-07-27 2022-12-15 jagadish1989@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java 35 2 913 875 2 2 2022-11-07 2022-12-15 shuai.xyz@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java 92 5 3207 875 5 5 2016-07-27 2022-12-15 jagadish1989@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsGetter.java 5 3 3207 875 3 3 2016-07-27 2022-12-15 jagadish1989@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java 30 2 913 875 2 2 2022-11-07 2022-12-15 shuai.xyz@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/DefaultSystemStatisticsGetter.java 23 2 913 875 2 2 2022-11-07 2022-12-15 shuai.xyz@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/OshiBasedStatisticsGetter.java 63 2 913 875 2 2 2022-11-07 2022-12-15 shuai.xyz@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/host/SystemMemoryStatistics.java 27 1 3207 3207 1 1 2016-07-27 2016-07-27 jagadish1989@gmail.com jagadish1989@gmail.com samza-core/src/main/java/org/apache/samza/container/SamzaContainerMonitorListener.java 48 3 917 875 3 2 2022-11-03 2022-12-15 shuai.xyz@gmail.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/container/SecurityManagerFactory.java 5 1 3255 3255 1 1 2016-06-09 2016-06-09 chens_cs@hotmail.com chens_cs@hotmail.com samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicy.java 126 2 3244 3123 2 2 2016-06-20 2016-10-19 cpettitt@linkedin.com pmaheshwari@linkedin.com samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicy.java 13 1 3244 3244 1 1 2016-06-20 2016-06-20 cpettitt@linkedin.com cpettitt@linkedin.com samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java 4 2 3244 3243 2 2 2016-06-20 2016-06-21 cpettitt@linkedin.com nickpan47@gmail.com samza-core/src/main/java/org/apache/samza/container/disk/PollingScanDiskSpaceMonitor.java 117 4 3315 2526 4 4 2016-04-10 2018-06-08 cpettitt@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java 27 2 3244 3243 2 2 2016-06-20 2016-06-21 cpettitt@linkedin.com nickpan47@gmail.com samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicyFactory.java 8 1 3244 3244 1 1 2016-06-20 2016-06-20 cpettitt@linkedin.com cpettitt@linkedin.com samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java 5 2 3244 3243 2 2 2016-06-20 2016-06-21 cpettitt@linkedin.com nickpan47@gmail.com samza-core/src/main/java/org/apache/samza/container/disk/DiskSpaceMonitor.java 9 2 3315 3244 2 1 2016-04-10 2016-06-20 cpettitt@linkedin.com cpettitt@linkedin.com samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java 212 15 2920 1582 15 12 2017-05-10 2021-01-07 ashivanna@linkedin.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/container/LocalityManager.java 52 33 3628 1715 38 19 2015-06-02 2020-08-27 navi.trinity@gmail.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/migration/MigrationPlan.java 5 1 3514 3514 1 1 2015-09-24 2015-09-24 yipan@linkedin.com yipan@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/NoProcessorJobCoordinatorListener.java 27 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitorFactory.java 49 1 1347 1347 1 1 2021-08-30 2021-08-30 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/JobModelHelper.java 151 1 1354 1354 1 1 2021-08-23 2021-08-23 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinatorFactory.java 87 3 1318 1248 3 1 2021-09-28 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java 199 5 1318 1248 5 1 2021-09-28 2021-12-07 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/NamespaceAwareCoordinatorStreamStore.java 73 6 2222 1738 6 6 2019-04-08 2020-08-04 svenkataraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java 185 22 2444 759 25 11 2018-08-29 2023-04-10 spvenkat@usc.edu prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamMetadataStoreFactory.java 11 6 2444 2197 6 5 2018-08-29 2019-05-03 spvenkat@usc.edu wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/InputStreamsDiscoveredException.java 7 3 2350 2347 4 3 2018-12-01 2018-12-04 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java 146 9 3289 1347 10 8 2016-05-06 2021-08-30 jacob.maes@gmail.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java 10 6 2962 2178 7 4 2017-03-29 2019-05-22 boryas@apache.org mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java 16 3 2178 1268 3 2 2019-05-22 2021-11-17 mgaduputi@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java 33 10 2200 1367 11 7 2019-04-30 2021-08-10 bshkolnik@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/coordinator/LeaderElectorListener.java 4 1 2962 2962 1 1 2017-03-29 2017-03-29 boryas@apache.org boryas@apache.org samza-core/src/main/java/org/apache/samza/coordinator/JobModelMonitors.java 32 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/RunIdGenerator.java 67 2 2178 1919 2 2 2019-05-22 2020-02-05 mgaduputi@linkedin.com 59407935+alnzng@users.noreply.github.com samza-core/src/main/java/org/apache/samza/coordinator/DistributedLock.java 6 1 2178 2178 1 1 2019-05-22 2019-05-22 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetMigrationMetaMessage.java 16 1 3514 3514 1 1 2015-09-24 2015-09-24 yipan@linkedin.com yipan@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskPartitionMapping.java 17 5 2344 2197 5 4 2018-12-07 2019-05-03 spvenkat@usc.edu wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java 151 7 3566 2197 7 6 2015-08-03 2019-05-03 j.jung@levi9.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/Delete.java 13 1 3566 3566 1 1 2015-08-03 2015-08-03 j.jung@levi9.com j.jung@levi9.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetJobCoordinatorMetadataMessage.java 17 1 1612 1612 1 1 2020-12-08 2020-12-08 bharath.kumarasubramanian@gmail.com bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetConfig.java 17 1 3566 3566 1 1 2015-08-03 2015-08-03 j.jung@levi9.com j.jung@levi9.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetContainerHostMapping.java 21 7 3566 2197 7 7 2015-08-03 2019-05-03 j.jung@levi9.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskModeMapping.java 17 2 2303 2291 3 3 2019-01-17 2019-01-29 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetExecutionEnvContainerIdMapping.java 17 1 1619 1619 1 1 2020-12-01 2020-12-01 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetChangelogMapping.java 22 4 3566 2197 4 4 2015-08-03 2019-05-03 j.jung@levi9.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskContainerMapping.java 17 6 3320 2197 6 6 2016-04-05 2019-05-03 jacob.maes@gmail.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamValueSerde.java 88 16 2444 1612 17 8 2018-08-29 2020-12-08 spvenkat@usc.edu bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java 51 12 3584 533 13 12 2015-07-16 2023-11-22 abdolla2@illinois.edu ajo.thomas24@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamKeySerde.java 25 7 2444 2197 7 5 2018-08-29 2019-05-03 spvenkat@usc.edu wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java 197 19 3662 1730 19 14 2015-04-29 2020-08-12 navgog8@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java 96 11 3662 533 11 10 2015-04-29 2023-11-22 navgog8@gmail.com ajo.thomas24@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java 82 3 2638 2526 3 3 2018-02-16 2018-06-08 dnishimura@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorCommunication.java 31 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/JobModelHttpServlet.java 46 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorToWorkerCommunicationFactory.java 17 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunication.java 5 2 1318 1289 2 1 2021-09-28 2021-10-27 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoProvider.java 5 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorToWorkerCommunicationFactory.java 4 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoServingContext.java 20 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunicationContext.java 23 1 1318 1318 1 1 2021-09-28 2021-09-28 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java 125 3 2350 2347 4 3 2018-12-01 2018-12-04 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitorFactory.java 26 1 1347 1347 1 1 2021-08-30 2021-08-30 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/server/LocalityServlet.java 33 2 1715 1547 2 2 2020-08-27 2021-02-11 bharath.kumarasubramanian@gmail.com stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtilsFactory.java 5 4 2809 2774 4 3 2017-08-29 2017-10-03 boryas@apache.org xiliu@xiliu-ld1.linkedin.biz samza-core/src/main/java/org/apache/samza/coordinator/lifecycle/NoOpJobRestartSignal.java 10 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/lifecycle/NoOpJobRestartSignalFactory.java 7 1 1289 1289 1 1 2021-10-27 2021-10-27 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/PartitionChangeException.java 7 3 2350 2347 4 3 2018-12-01 2018-12-04 rmatharu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorListener.java 8 2 2927 2871 2 1 2017-05-03 2017-06-28 navina@apache.org navina@apache.org samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorFactory.java 10 10 3019 2116 11 7 2017-01-31 2019-07-23 navina@apache.org dnishimura@gmail.com samza-core/src/main/java/org/apache/samza/coordinator/JobModelCalculator.java 160 1 1354 1354 1 1 2021-08-23 2021-08-23 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/ClusterMembership.java 8 1 2178 2178 1 1 2019-05-22 2019-05-22 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinator.java 12 7 3019 1318 7 5 2017-01-31 2021-09-28 navina@apache.org calee@linkedin.com samza-core/src/main/java/org/apache/samza/coordinator/LeaderElector.java 9 2 2962 2925 2 2 2017-03-29 2017-05-05 boryas@apache.org navina@apache.org samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java 94 27 2975 1738 33 14 2017-03-16 2020-08-04 xiliu@xiliu-ld.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/execution/JobNode.java 125 41 2956 1738 48 16 2017-04-04 2020-08-04 xiliu@xiliu-ld.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/execution/ExecutionPlan.java 13 5 2954 1547 5 4 2017-04-06 2021-02-11 xiliu@xiliu-ld.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/execution/OperatorSpecGraphAnalyzer.java 99 9 2416 2348 18 5 2018-09-26 2018-12-03 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java 183 47 2975 2051 57 16 2017-03-16 2019-09-26 xiliu@xiliu-ld.linkedin.biz bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/execution/JobGraph.java 265 33 2956 1738 39 12 2017-04-04 2020-08-04 xiliu@xiliu-ld.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java 58 12 2435 1715 15 8 2018-09-07 2020-08-27 boryas@apache.org bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java 250 29 2416 1738 39 11 2018-09-26 2020-08-04 wsong@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java 145 26 2435 759 36 13 2018-09-07 2023-04-10 boryas@apache.org prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/execution/JobGraphJsonGenerator.java 202 34 2954 1547 36 14 2017-04-06 2021-02-11 xiliu@xiliu-ld.linkedin.biz stuart.m.perks@gmail.com samza-core/src/main/java/org/apache/samza/execution/StreamManager.java 101 23 2957 1689 27 14 2017-04-03 2020-09-22 jmaes@linkedin.com boryas@apache.org samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java 146 18 2435 1715 21 11 2018-09-07 2020-08-27 boryas@apache.org bharath.kumarasubramanian@gmail.com samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java 107 6 2416 643 9 7 2018-09-26 2023-08-04 wsong@linkedin.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/testUtils/TestClock.java 16 3 2474 2470 3 3 2018-07-30 2018-08-03 halu@linkedin.com wsong@linkedin.com samza-core/src/main/java/org/apache/samza/testUtils/TestUtils.java 24 2 2303 2291 3 2 2019-01-17 2019-01-29 wsong@linkedin.com bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/application/LegacyTaskApplication.java 13 9 2435 2389 13 6 2018-09-07 2018-10-23 boryas@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java 32 9 2435 618 12 9 2018-09-07 2023-08-29 boryas@apache.org bharathkk@apache.org samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorImpl.java 223 12 2399 2197 14 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-core/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptorImpl.java 145 11 2399 2197 13 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorUtil.java 19 4 2399 2395 4 4 2018-10-13 2018-10-17 pmaheshwari@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptorImpl.java 45 11 2399 2348 14 4 2018-10-13 2018-12-03 pmaheshwari@apache.org bshkolnik@linkedin.com samza-core/src/main/java/org/apache/samza/environment/EnvironmentVariables.java 5 2 1353 1080 2 1 2021-08-24 2022-05-24 calee@linkedin.com calee@linkedin.com samza-core/src/main/java/org/apache/samza/storage/TaskStorageCommitManager.java 260 7 1462 637 8 4 2021-05-07 2023-08-10 dchen1@linkedin.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/storage/TaskSideInputStorageManager.java 131 26 2480 1367 28 13 2018-07-24 2021-08-10 bkumaras@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java 302 32 2480 779 34 14 2018-07-24 2023-03-21 bkumaras@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreBackupManagerMetrics.java 92 3 1444 794 4 3 2021-05-25 2023-03-06 72765053+shekhars-li@users.noreply.github.com pmaheshw@linkedin.com samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreRestoreManagerMetrics.java 54 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/diff/DirDiff.java 162 4 1444 1088 4 3 2021-05-25 2022-05-16 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java 264 17 1444 624 17 6 2021-05-25 2023-08-23 72765053+shekhars-li@users.noreply.github.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java 278 7 1444 474 7 4 2021-05-25 2024-01-20 72765053+shekhars-li@users.noreply.github.com xrchen@uwaterloo.ca samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java 473 13 1444 205 14 4 2021-05-25 2024-10-15 72765053+shekhars-li@users.noreply.github.com ajo.thomas24@gmail.com samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java 79 5 1444 892 6 4 2021-05-25 2022-11-28 72765053+shekhars-li@users.noreply.github.com shesharma@linkedin.com samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java 247 13 1444 474 14 6 2021-05-25 2024-01-20 72765053+shekhars-li@users.noreply.github.com xrchen@uwaterloo.ca samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileMetadataMixin.java 25 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonDirIndexMixin.java 27 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/SnapshotIndexSerde.java 53 5 1444 1189 5 3 2021-05-25 2022-02-04 72765053+shekhars-li@users.noreply.github.com 72765053+shekhars-li@users.noreply.github.com samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileBlobMixin.java 14 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonSnapshotMetadataMixin.java 23 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileIndexMixin.java 23 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonSnapshotIndexMixin.java 24 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileMetadata.java 97 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/DirIndex.java 180 6 1444 1088 9 4 2021-05-25 2022-05-16 72765053+shekhars-li@users.noreply.github.com pmaheshw@linkedin.com samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileIndex.java 67 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileBlob.java 46 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java 78 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotIndex.java 75 2 1444 1367 2 2 2021-05-25 2021-08-10 72765053+shekhars-li@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java 517 20 2033 779 21 11 2019-10-14 2023-03-21 prateekm@utexas.edu prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java 268 18 2039 779 19 10 2019-10-08 2023-03-21 prateekm@utexas.edu prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java 187 4 1794 1731 4 3 2020-06-09 2020-08-11 bkonold@users.noreply.github.com bkonold@users.noreply.github.com samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java 170 10 1462 892 11 5 2021-05-07 2022-11-28 dchen1@linkedin.com shesharma@linkedin.com samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java 106 3 1731 779 3 3 2020-08-11 2023-03-21 bkonold@users.noreply.github.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/storage/ChangelogStreamManager.java 105 17 2638 1617 17 11 2018-02-16 2020-12-03 dnishimura@gmail.com boryas@apache.org samza-core/src/main/java/org/apache/samza/storage/StateStorageTool.java 32 2 3584 1925 2 2 2015-07-16 2020-01-30 yanfang724@gmail.com ke.wu.cs@icloud.com samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java 175 54 3584 695 62 29 2015-07-16 2023-06-13 yanfang724@gmail.com bharathkk@apache.org samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java 88 2 1463 1367 2 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaChangelogSSPOffset.java 52 2 1463 1367 2 2 2021-05-06 2021-08-10 dchen1@linkedin.com prateekm@utexas.edu samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobBasicMetrics.java 43 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilderFactory.java 4 1 259 259 1 1 2024-08-22 2024-08-22 ayushkhandelwal93@gmail.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/CompressionFactory.java 15 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/GzipCompression.java 38 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/CompressionType.java 4 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/Compression.java 5 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/NoneCompression.java 11 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataGenerator.java 5 2 1819 1738 2 2 2020-05-15 2020-08-04 mgaduputi@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/NullBlobMetadataGeneratorFactory.java 8 2 1819 1738 2 2 2020-05-15 2020-08-04 mgaduputi@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataGeneratorFactory.java 5 2 1819 1738 2 2 2020-05-15 2020-08-04 mgaduputi@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/NullBlobMetadataGenerator.java 8 2 1819 1738 2 2 2020-05-15 2020-08-04 mgaduputi@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataContext.java 20 3 1819 1738 3 2 2020-05-15 2020-08-04 mgaduputi@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java 181 9 1939 259 9 6 2020-01-16 2024-08-22 mgaduputi@linkedin.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java 74 5 1409 259 5 4 2021-06-29 2024-08-22 mgaduputi@linkedin.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilder.java 5 1 259 259 1 1 2024-08-22 2024-08-22 ayushkhandelwal93@gmail.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobSystemAdmin.java 18 2 1939 1924 2 1 2020-01-16 2020-01-31 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobSystemFactory.java 26 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java 8 1 259 259 1 1 2024-08-22 2024-08-22 ayushkhandelwal93@gmail.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducerMetrics.java 74 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducer.java 343 11 1939 259 11 7 2020-01-16 2024-08-22 mgaduputi@linkedin.com ayushkhandelwal93@gmail.com samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterMetrics.java 33 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriter.java 8 1 1939 1939 1 1 2020-01-16 2020-01-16 mgaduputi@linkedin.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterFactory.java 14 4 1939 691 4 3 2020-01-16 2023-06-17 mgaduputi@linkedin.com ehoner@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriterFactory.java 22 4 1939 691 4 3 2020-01-16 2023-06-17 mgaduputi@linkedin.com ehoner@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java 284 8 1939 691 9 5 2020-01-16 2023-06-17 mgaduputi@linkedin.com ehoner@linkedin.com samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobOutputStream.java 225 13 1939 691 13 6 2020-01-16 2023-06-17 mgaduputi@linkedin.com ehoner@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/SamzaEventHubClientManager.java 86 9 2750 696 9 6 2017-10-27 2023-06-12 29577458+dxichen@users.noreply.github.com ehoner@gmail.com samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubSystemFactory.java 39 2 2750 2746 2 2 2017-10-27 2017-10-31 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/PassThroughInterceptor.java 8 2 2750 2746 2 2 2017-10-27 2017-10-31 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java 236 19 2750 1738 20 11 2017-10-27 2020-08-04 29577458+dxichen@users.noreply.github.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManager.java 8 5 2750 2197 5 5 2017-10-27 2019-05-03 29577458+dxichen@users.noreply.github.com wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java 392 27 2750 694 29 14 2017-10-27 2023-06-14 29577458+dxichen@users.noreply.github.com ehoner@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubIncomingMessageEnvelope.java 15 5 2750 2197 5 5 2017-10-27 2019-05-03 29577458+dxichen@users.noreply.github.com wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/Interceptor.java 4 2 2750 2746 2 2 2017-10-27 2017-10-31 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsOutputDescriptor.java 49 10 2399 2197 15 6 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsSystemDescriptor.java 87 10 2399 2197 15 6 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsInputDescriptor.java 56 10 2399 2197 15 6 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManagerFactory.java 11 4 2750 2526 4 3 2017-10-27 2018-06-08 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/AsyncSystemProducer.java 115 13 2595 1738 17 9 2018-03-31 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java 290 18 2750 1738 18 9 2017-10-27 2020-08-04 29577458+dxichen@users.noreply.github.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java 159 21 2750 696 26 11 2017-10-27 2023-06-12 29577458+dxichen@users.noreply.github.com ehoner@gmail.com samza-azure/src/main/java/org/apache/samza/config/AzureConfig.java 35 4 2820 2724 4 4 2017-08-18 2017-11-22 pawas2703@gmail.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/util/TableUtils.java 131 4 2820 2526 4 4 2017-08-18 2018-06-08 pawas2703@gmail.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/util/LeaseBlobManager.java 52 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/util/BlobUtils.java 175 5 2820 2197 5 5 2017-08-18 2019-05-03 pawas2703@gmail.com wsong@linkedin.com samza-azure/src/main/java/org/apache/samza/AzureClient.java 46 5 2834 2795 6 3 2017-08-04 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/AzureException.java 15 2 2831 2829 2 2 2017-08-07 2017-08-09 pawas2703@gmail.com nickpan47@gmail.com samza-azure/src/main/java/org/apache/samza/coordinator/data/JobModelBundle.java 27 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/data/ProcessorEntity.java 30 4 2820 2526 4 4 2017-08-18 2018-06-08 pawas2703@gmail.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/coordinator/data/BarrierState.java 4 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java 59 8 2819 2178 8 8 2017-08-19 2019-05-22 pawas2703@gmail.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/RenewLeaseScheduler.java 48 4 2820 1738 4 4 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/TaskScheduler.java 7 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderBarrierCompleteScheduler.java 83 4 2820 1738 4 4 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/SchedulerStateChangeListener.java 4 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/HeartbeatScheduler.java 48 4 2820 1738 4 4 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderLivenessCheckScheduler.java 72 7 2820 1738 7 7 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/JMVersionUpgradeScheduler.java 65 6 2820 1738 6 6 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LivenessCheckScheduler.java 71 4 2820 1738 4 4 2017-08-18 2020-08-04 pawas2703@gmail.com 54013208+mabelyc@users.noreply.github.com samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtilsFactory.java 8 2 2809 2795 2 2 2017-08-29 2017-09-12 boryas@apache.org xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinatorFactory.java 11 6 2819 2116 6 6 2017-08-19 2019-07-23 pawas2703@gmail.com dnishimura@gmail.com samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java 31 7 2819 2178 8 5 2017-08-19 2019-05-22 pawas2703@gmail.com mgaduputi@linkedin.com samza-azure/src/main/java/org/apache/samza/coordinator/AzureLeaderElector.java 58 2 2820 2795 2 2 2017-08-18 2017-09-12 pawas2703@gmail.com xiliu@xiliu-ld1.linkedin.biz samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java 352 19 2820 1354 20 14 2017-08-18 2021-08-23 pawas2703@gmail.com calee@linkedin.com samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManagerFactory.java 14 4 2738 2675 4 2 2017-11-08 2018-01-10 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManager.java 176 7 2738 1367 7 5 2017-11-08 2021-08-10 29577458+dxichen@users.noreply.github.com prateekm@utexas.edu samza-azure/src/main/java/org/apache/samza/checkpoint/azure/TaskCheckpointEntity.java 17 2 2738 2724 2 2 2017-11-08 2017-11-22 29577458+dxichen@users.noreply.github.com boryas@apache.org samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala 330 26 4216 941 27 22 2013-10-22 2022-10-10 criccomi@criccomi-mn.linkedin.biz james.demichele@redfin.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala 11 1 4049 4049 1 1 2014-04-07 2014-04-07 zshen@hortonworks.com zshen@hortonworks.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala 28 6 4215 2954 6 5 2013-10-23 2017-04-06 criccomi@criccomi-mn.linkedin.biz fji@linkedin.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala 60 1 3255 3255 1 1 2016-06-09 2016-06-09 chens_cs@hotmail.com chens_cs@hotmail.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala 78 4 3262 1613 4 3 2016-06-02 2020-12-07 jagadish1989@gmail.com mgaduputi@linkedin.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnSecurityManagerFactory.scala 10 1 3255 3255 1 1 2016-06-09 2016-06-09 chens_cs@hotmail.com chens_cs@hotmail.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala 71 3 3255 2526 3 3 2016-06-09 2018-06-08 chens_cs@hotmail.com boryas@apache.org samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala 58 4 3262 1633 4 3 2016-06-02 2020-11-17 jagadish1989@gmail.com mgaduputi@linkedin.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala 137 32 4216 1114 34 25 2013-10-22 2022-04-20 criccomi@criccomi-mn.linkedin.biz xinyuliu.us@gmail.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala 74 5 3255 2526 5 4 2016-06-09 2018-06-08 chens_cs@hotmail.com boryas@apache.org samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala 22 6 4024 2197 6 6 2014-05-02 2019-05-03 zshen@hortonworks.com wsong@linkedin.com samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala 41 23 4248 660 23 18 2013-09-20 2023-07-18 criccomi@criccomi-mn.linkedin.biz 94939653+jia-gao@users.noreply.github.com samza-yarn/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala 66 2 3912 3020 2 2 2014-08-22 2017-01-30 yanfang724@gmail.com jvenkatr@linkedin.com samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala 23 6 4216 1613 6 6 2013-10-22 2020-12-07 criccomi@criccomi-mn.linkedin.biz mgaduputi@linkedin.com samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala 84 21 4024 1547 21 17 2014-05-02 2021-02-11 zshen@hortonworks.com stuart.m.perks@gmail.com samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnAppState.java 51 10 3262 1738 10 9 2016-06-02 2020-08-04 jagadish1989@gmail.com 54013208+mabelyc@users.noreply.github.com samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java 15 1 2964 2964 1 1 2017-03-27 2017-03-27 fji@linkedin.com fji@linkedin.com samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java 64 1 2964 2964 1 1 2017-03-27 2017-03-27 fji@linkedin.com fji@linkedin.com samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java 509 43 3262 660 47 24 2016-06-02 2023-07-18 jagadish1989@gmail.com 94939653+jia-gao@users.noreply.github.com samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java 79 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java 11 1 1598 1598 1 1 2020-12-22 2020-12-22 pchhokra@linkedin.com pchhokra@linkedin.com samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java 19 2 3262 2964 2 2 2016-06-02 2017-03-27 jagadish1989@gmail.com fji@linkedin.com samza-yarn/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java 31 4 2964 1738 4 3 2017-03-27 2020-08-04 fji@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java 54 2 2964 941 2 2 2017-03-27 2022-10-10 fji@linkedin.com james.demichele@redfin.com samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java 113 13 3513 2017 14 12 2015-09-25 2019-10-30 navi.trinity@gmail.com sanil.jain15@gmail.com samza-yarn/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java 152 21 3327 1715 25 16 2016-03-29 2020-08-27 xiliu@linkedin.com bharath.kumarasubramanian@gmail.com samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java 58 6 2920 1547 6 6 2017-05-10 2021-02-11 ashivanna@linkedin.com stuart.m.perks@gmail.com samza-yarn/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java 61 5 2547 1547 5 5 2018-05-18 2021-02-11 jmakes@apache.org stuart.m.perks@gmail.com samza-yarn/src/main/resources/scalate/css/ropa-sans.css 6 1 4013 4013 1 1 2014-05-13 2014-05-13 dchen@linkedin.com dchen@linkedin.com samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml 224 20 4024 1347 21 15 2014-05-02 2021-08-30 zshen@hortonworks.com dchen1@linkedin.com samza-yarn/src/main/resources/scalate/WEB-INF/layouts/default.scaml 41 1 4013 4013 1 1 2014-05-13 2014-05-13 dchen@linkedin.com dchen@linkedin.com samza-yarn/src/main/less/main.less 118 2 4013 3611 2 2 2014-05-13 2015-06-19 dchen@linkedin.com a.bircakovic@levi9.com samza-yarn/src/main/less/variables.less 3 1 4013 4013 1 1 2014-05-13 2014-05-13 dchen@linkedin.com dchen@linkedin.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/SimpleDiagnosticsAppender.java 42 5 2477 2082 5 4 2018-07-27 2019-08-26 rmatharu@linkedin.com 40646191+rmatharu@users.noreply.github.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerdeFactory.java 13 1 3709 3709 1 1 2015-03-13 2015-03-13 criccomini@apache.org criccomini@apache.org samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java 35 3 3731 3653 3 2 2015-02-19 2015-05-08 yanfang724@gmail.com wangguoz@gmail.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerdeFactory.java 11 1 3731 3731 1 1 2015-02-19 2015-02-19 yanfang724@gmail.com yanfang724@gmail.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java 106 4 3709 3459 4 3 2015-03-13 2015-11-18 criccomini@apache.org a.bircakovic@levi9.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java 252 33 3816 1317 34 18 2014-11-26 2021-09-29 yanfang724@gmail.com calee@linkedin.com samza-log4j/src/main/java/org/apache/samza/logging/log4j/JmxAppender.java 53 2 3929 3926 3 1 2014-08-05 2014-08-08 criccomi@criccomi-mn.linkedin.biz criccomi@criccomi-mn.linkedin.biz samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppenderMetrics.java 16 2 2695 2675 2 2 2017-12-21 2018-01-10 jmakes@apache.org boryas@apache.org samza-log4j/src/main/java/org/apache/samza/config/Log4jSystemConfig.java 34 17 3816 2047 19 12 2014-11-26 2019-09-30 yanfang724@gmail.com boryas@apache.org samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala 58 11 4248 1527 13 8 2013-09-20 2021-03-03 criccomi@criccomi-mn.linkedin.biz stuart.m.perks@gmail.com samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala 73 45 4271 1022 58 30 2013-08-28 2022-07-21 criccomi@criccomi-mn.linkedin.biz ke.wu.cs@icloud.com samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala 148 27 4271 2526 27 19 2013-08-28 2018-06-08 criccomi@criccomi-mn.linkedin.biz boryas@apache.org samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducerMetrics.scala 13 5 4248 3158 5 4 2013-09-20 2016-09-14 criccomi@criccomi-mn.linkedin.biz b.cogic@levi9.com samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala 247 66 4271 941 78 36 2013-08-28 2022-10-10 criccomi@criccomi-mn.linkedin.biz james.demichele@redfin.com samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala 32 28 4164 1984 32 20 2013-12-13 2019-12-02 jghoman@gmail.com calee@linkedin.com samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala 291 62 4215 1008 70 30 2013-10-23 2022-08-04 criccomi@criccomi-mn.linkedin.biz mgaduputi@linkedin.com samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java 84 20 3002 1738 22 12 2017-02-17 2020-08-04 jmaes@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java 320 9 1912 1367 9 6 2020-02-12 2021-08-10 calee@linkedin.com prateekm@utexas.edu samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaOutputDescriptor.java 10 7 2399 2389 10 4 2018-10-13 2018-10-23 pmaheshwari@apache.org bshkolnik@linkedin.com samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java 38 10 2399 2197 13 5 2018-10-13 2019-05-03 pmaheshwari@apache.org wsong@linkedin.com samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaSystemDescriptor.java 99 12 2399 1738 15 7 2018-10-13 2020-08-04 pmaheshwari@apache.org 54013208+mabelyc@users.noreply.github.com samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxyFactory.java 4 3 1912 1738 3 2 2020-02-12 2020-08-04 calee@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java 224 24 2401 1527 28 10 2018-10-11 2021-03-03 jvenkatraman@linkedin.com stuart.m.perks@gmail.com samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java 670 40 2401 1689 53 18 2018-10-11 2020-09-22 jvenkatraman@linkedin.com boryas@apache.org samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java 130 19 2401 1738 22 9 2018-10-11 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-kafka/src/main/java/org/apache/samza/util/KafkaUtil.java 29 1 1912 1912 1 1 2020-02-12 2020-02-12 calee@linkedin.com calee@linkedin.com samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java 63 9 2729 1367 9 4 2017-11-17 2021-08-10 jagadish@apache.org prateekm@utexas.edu samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java 36 12 2729 1367 12 8 2017-11-17 2021-08-10 jagadish@apache.org prateekm@utexas.edu samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala 330 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala 11 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala 28 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala 60 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala 78 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnSecurityManagerFactory.scala 10 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala 71 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala 58 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala 137 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala 74 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala 22 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala 34 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala 66 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpInputStream.scala 20 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala 23 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala 84 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnAppState.java 51 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java 15 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java 64 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java 507 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java 79 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java 11 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java 19 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java 31 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java 54 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/config/YarnConfig.java 113 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java 152 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java 58 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java 61 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/resources/scalate/css/ropa-sans.css 6 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml 224 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml 41 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/less/main.less 118 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-yarn3/src/main/less/variables.less 3 1 941 941 1 1 2022-10-10 2022-10-10 james.demichele@redfin.com james.demichele@redfin.com samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/KinesisSystemConsumerMetrics.java 63 4 2718 1738 4 4 2017-11-28 2020-08-04 atoomula@atoomula-ld1.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/SamzaHistogram.java 35 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessorListener.java 8 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumerOffset.java 60 6 2718 1547 6 6 2017-11-28 2021-02-11 atoomula@atoomula-ld1.linkedin.biz stuart.m.perks@gmail.com samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/NoAvailablePartitionException.java 10 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessor.java 111 5 2718 2197 5 5 2017-11-28 2019-05-03 atoomula@atoomula-ld1.linkedin.biz wsong@linkedin.com samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisIncomingMessageEnvelope.java 30 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java 157 8 2718 1738 8 7 2017-11-28 2020-08-04 atoomula@atoomula-ld1.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/SSPAllocator.java 32 5 2718 2197 5 5 2017-11-28 2019-05-03 atoomula@atoomula-ld1.linkedin.biz wsong@linkedin.com samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemAdmin.java 73 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java 171 9 2718 1738 9 8 2017-11-28 2020-08-04 atoomula@atoomula-ld1.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisAWSCredentialsProvider.java 36 2 2718 2675 2 2 2017-11-28 2018-01-10 atoomula@atoomula-ld1.linkedin.biz boryas@apache.org samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisSystemDescriptor.java 60 8 2337 1738 8 6 2018-12-14 2020-08-04 halu@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisInputDescriptor.java 53 8 2337 1738 8 6 2018-12-14 2020-08-04 halu@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemFactory.java 53 8 2718 1738 10 5 2017-11-28 2020-08-04 atoomula@atoomula-ld1.linkedin.biz 54013208+mabelyc@users.noreply.github.com samza-sql-shell/conf/samza-sql-shell-log4j.xml 24 3 2390 2375 4 4 2018-10-22 2018-11-06 jvenkatraman@linkedin.com wsong@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/CommandHandler.java 12 3 2117 2002 3 2 2019-07-22 2019-11-14 sguirguis@linkedin.com 57301006+micpod@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/SqlFunction.java 8 5 2390 2248 7 4 2018-10-22 2019-03-13 jvenkatraman@linkedin.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/CommandType.java 12 4 2117 1738 4 3 2019-07-22 2020-08-04 sguirguis@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/SqlExecutor.java 23 11 2390 2117 14 7 2018-10-22 2019-07-22 jvenkatraman@linkedin.com sguirguis@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandler.java 9 5 2346 2248 5 4 2018-12-05 2019-03-13 yangweiqing001@gmail.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionContext.java 3 9 2390 1738 10 7 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandlerImpl.java 67 8 2346 1738 9 7 2018-12-05 2020-08-04 yangweiqing001@gmail.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableSpecs.java 35 7 2346 1738 7 6 2018-12-05 2020-08-04 yangweiqing001@gmail.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/NonQueryResult.java 24 6 2390 2248 8 5 2018-10-22 2019-03-13 jvenkatraman@linkedin.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionStatus.java 7 3 2390 2375 4 4 2018-10-22 2018-11-06 jvenkatraman@linkedin.com wsong@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/QueryResult.java 16 10 2390 2248 13 6 2018-10-22 2019-03-13 jvenkatraman@linkedin.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/ExecutorException.java 14 1 2117 2117 1 1 2019-07-22 2019-07-22 sguirguis@linkedin.com sguirguis@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/CliException.java 14 1 2117 2117 1 1 2019-07-22 2019-07-22 sguirguis@linkedin.com sguirguis@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/CommandHandlerException.java 14 3 2117 2002 3 2 2019-07-22 2019-11-14 sguirguis@linkedin.com 57301006+micpod@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/CliUtil.java 37 6 2390 2002 7 6 2018-10-22 2019-11-14 jvenkatraman@linkedin.com 57301006+micpod@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/Pair.java 21 6 2346 1738 6 6 2018-12-05 2020-08-04 yangweiqing001@gmail.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/RandomAccessQueue.java 60 6 2390 1738 7 7 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliConstants.java 28 10 2390 1738 12 8 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java 193 17 2390 1738 20 9 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/QueryResultLogView.java 209 9 2390 1738 11 8 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliCommand.java 25 6 2390 2002 7 6 2018-10-22 2019-11-14 jvenkatraman@linkedin.com 57301006+micpod@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/Main.java 77 10 2390 1738 12 8 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java 169 13 2390 1738 16 9 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliView.java 6 7 2390 2117 9 6 2018-10-22 2019-07-22 jvenkatraman@linkedin.com sguirguis@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliHighlighter.java 57 6 2390 1738 7 7 2018-10-22 2020-08-04 jvenkatraman@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShellEnvironmentVariableHandler.java 53 5 2346 2248 5 4 2018-12-05 2019-03-13 yangweiqing001@gmail.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java 578 6 2117 1738 6 4 2019-07-22 2020-08-04 sguirguis@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliLoggingSystemFactory.java 76 3 2390 2375 4 4 2018-10-22 2018-11-06 jvenkatraman@linkedin.com wsong@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaSqlUdfDisplayInfo.java 37 6 2390 2291 7 5 2018-10-22 2019-01-29 jvenkatraman@linkedin.com bshkolnik@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandType.java 52 2 2117 2114 2 1 2019-07-22 2019-07-25 sguirguis@linkedin.com sguirguis@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java 389 26 2390 829 31 14 2018-10-22 2023-01-30 jvenkatraman@linkedin.com katiliu@linkedin.com samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/FileSystemAvroRelSchemaProviderFactory.java 44 6 2390 2291 7 5 2018-10-22 2019-01-29 jvenkatraman@linkedin.com bshkolnik@linkedin.com samza-tools/src/main/java/org/apache/samza/tools/CommandLineHelper.java 14 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/src/main/java/org/apache/samza/tools/EventHubConsoleConsumer.java 85 5 2704 696 5 3 2017-12-12 2023-06-12 spunuru@linkedin.com ehoner@gmail.com samza-tools/src/main/java/org/apache/samza/tools/json/JsonRelConverterFactory.java 64 9 2704 1547 9 5 2017-12-12 2021-02-11 spunuru@linkedin.com stuart.m.perks@gmail.com samza-tools/src/main/java/org/apache/samza/tools/GenerateKafkaEvents.java 152 6 2704 1738 6 5 2017-12-12 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerBench.java 58 4 2578 1738 4 4 2018-04-17 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/benchmark/AbstractSamzaBench.java 103 8 2578 1738 9 7 2018-04-17 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/benchmark/ConfigBasedSspGrouperFactory.java 51 4 2578 1738 4 4 2018-04-17 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java 88 21 2578 1700 22 12 2018-04-17 2020-09-11 spunuru@linkedin.com kwu@linkedin.com samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemProducerBench.java 72 4 2578 1738 4 4 2018-04-17 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/RandomValueGenerator.java 45 4 2704 1738 4 4 2017-12-12 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java 102 8 2704 1547 8 5 2017-12-12 2021-02-11 spunuru@linkedin.com stuart.m.perks@gmail.com samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.java 29 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/src/main/java/org/apache/samza/tools/schemas/PageViewEvent.java 29 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/src/main/java/org/apache/samza/tools/schemas/PageViewEvent.avsc 50 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.avsc 50 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java 130 16 2704 1738 19 12 2017-12-12 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSchemaGenRelConverterFactory.java 16 4 2704 1738 4 4 2017-12-12 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSerDeFactory.java 62 5 2704 1738 5 5 2017-12-12 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSchemaGenRelConverter.java 58 7 2704 2375 8 6 2017-12-12 2018-11-06 spunuru@linkedin.com wsong@linkedin.com samza-tools/src/main/resources/log4j.xml 18 5 2704 2401 6 6 2017-12-12 2018-10-11 spunuru@linkedin.com jvenkatraman@linkedin.com samza-tools/src/main/resources/log4j2.xml 16 4 2403 1942 5 5 2018-10-09 2020-01-13 pchhokra@pchhokra-mn3.linkedin.biz boryas@apache.org samza-tools/config/eh-consumer-log4j.xml 15 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/config/generate-kafka-events-log4j.xml 15 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/config/samza-sql-console-log4j.xml 15 2 2704 2675 2 2 2017-12-12 2018-01-10 spunuru@linkedin.com boryas@apache.org samza-tools/config/bench-log4j.xml 15 2 2578 2526 2 2 2018-04-17 2018-06-08 spunuru@linkedin.com boryas@apache.org samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStorageEngineFactory.scala 46 23 3857 255 25 19 2014-10-16 2024-08-26 naveen.at.ceg@gmail.com yehaolan@gmail.com samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala 296 52 3857 1079 56 29 2014-10-16 2022-05-25 naveen.at.ceg@gmail.com xrchen@uwaterloo.ca samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbKeyValueReader.java 66 21 3482 255 23 13 2015-10-26 2024-08-26 yanfang724@gmail.com yehaolan@gmail.com samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbReadingTool.java 108 4 3482 1738 4 4 2015-10-26 2020-08-04 yanfang724@gmail.com 54013208+mabelyc@users.noreply.github.com samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java 175 26 3482 255 28 17 2015-10-26 2024-08-26 yanfang724@gmail.com yehaolan@gmail.com samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java 143 21 2399 1368 24 8 2018-10-13 2021-08-09 pmaheshwari@apache.org prateekm@utexas.edu samza-shell/src/main/resources/log4j-console.xml 14 2 3964 3321 2 2 2014-07-01 2016-04-04 yanfang724@gmail.com jacob.maes@gmail.com samza-shell/src/main/resources/log4j2-console.xml 13 4 2403 1942 5 5 2018-10-09 2020-01-13 pchhokra@pchhokra-mn3.linkedin.biz boryas@apache.org samza-shell/src/main/visualizer/js/planToDagre.js 60 4 2928 2675 4 4 2017-05-02 2018-01-10 xiliu@xiliu-ld.linkedin.biz boryas@apache.org samza-shell/src/main/visualizer/plan.html 79 2 2928 2919 2 1 2017-05-02 2017-05-11 xiliu@xiliu-ld.linkedin.biz xiliu@xiliu-ld.linkedin.biz samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java 74 15 2298 1519 15 10 2019-01-22 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/planner/Checker.java 139 9 2730 1507 9 7 2017-11-16 2021-03-23 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java 189 33 2730 1519 34 11 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java 273 14 2074 1738 16 6 2019-09-03 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java 159 2 1753 1738 2 2 2020-07-20 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidatorException.java 14 2 2074 1913 2 2 2019-09-03 2020-02-11 atoomula@linkedin.com svenkataraman@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlUdfOperatorTable.java 48 10 2730 1738 10 9 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlOperatorTable.java 109 13 2730 1519 13 9 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlScalarFunctionImpl.java 74 12 2730 1738 12 8 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/SamzaSqlInputMessage.java 20 7 2344 1738 8 7 2018-12-07 2020-08-04 sguirguis@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaSqlDriver.java 29 5 2422 1738 5 5 2018-09-20 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaSqlJavaTypeFactoryImpl.java 41 6 2422 2389 7 5 2018-09-20 2018-10-23 atoomula@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/RelSchemaProvider.java 5 5 2730 2291 5 4 2017-11-16 2019-01-29 spunuru@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelConverter.java 10 4 2730 2346 5 5 2017-11-16 2018-12-05 spunuru@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOConfig.java 101 23 2575 1738 27 10 2018-04-20 2020-08-04 pdu@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/DslConverterFactory.java 5 3 2422 2417 3 3 2018-09-20 2018-09-25 atoomula@linkedin.com boryas@apache.org samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfResolver.java 5 2 2730 2724 2 2 2017-11-16 2017-11-22 spunuru@linkedin.com boryas@apache.org samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOResolver.java 5 2 2575 2526 2 2 2018-04-20 2018-06-08 pdu@linkedin.com boryas@apache.org samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelConverterFactory.java 6 4 2730 2526 4 3 2017-11-16 2018-06-08 spunuru@linkedin.com boryas@apache.org samza-sql/src/main/java/org/apache/samza/sql/interfaces/DslConverter.java 6 6 2422 2389 7 5 2018-09-20 2018-10-23 atoomula@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelTableKeyConverterFactory.java 6 5 2372 2348 5 4 2018-11-09 2018-12-03 atoomula@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOResolverFactory.java 5 5 2575 2457 5 4 2018-04-20 2018-08-16 pdu@linkedin.com wsong@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelTableKeyConverter.java 5 5 2372 2348 5 4 2018-11-09 2018-12-03 atoomula@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/interfaces/RelSchemaProviderFactory.java 6 4 2730 2526 4 3 2017-11-16 2018-06-08 spunuru@linkedin.com boryas@apache.org samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfMetadata.java 63 12 2730 1738 12 9 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java 80 13 2345 1547 13 7 2018-12-06 2021-02-11 sguirguis@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/data/Expression.java 6 3 2730 2163 3 3 2017-11-16 2019-06-06 spunuru@linkedin.com srinipunuru@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/data/RexToJavaCompiler.java 116 9 2730 1738 9 6 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java 44 15 2730 1738 16 10 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java 107 31 2730 1547 33 12 2017-11-16 2021-02-11 spunuru@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/SamzaSqlInputTransformer.java 16 9 2344 2073 10 5 2018-12-07 2019-09-04 sguirguis@linkedin.com sguirguis@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/FilterTranslator.java 102 25 2730 1519 28 14 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlTableJoinFunction.java 72 15 2372 1519 15 7 2018-11-09 2021-03-11 atoomula@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/JoinInputNode.java 65 9 2372 1519 9 6 2018-11-09 2021-03-11 atoomula@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java 229 58 2730 1738 72 16 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorOutputMetricsMapFunction.java 35 8 2344 1738 8 6 2018-12-07 2020-08-04 sguirguis@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java 299 41 2604 1519 47 13 2018-03-22 2021-03-11 atoomula@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorContext.java 131 23 2730 1519 27 11 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorConstants.java 12 6 2345 2073 6 4 2018-12-06 2019-09-04 sguirguis@linkedin.com sguirguis@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java 158 46 2730 1519 54 16 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/LogicalAggregateTranslator.java 71 22 2578 1738 22 10 2018-04-17 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorInputMetricsMapFunction.java 29 8 2344 1738 8 6 2018-12-07 2020-08-04 sguirguis@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlRemoteTableJoinFunction.java 50 11 2372 1519 11 6 2018-11-09 2021-03-11 atoomula@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlLocalTableJoinFunction.java 24 5 2372 2348 5 4 2018-11-09 2018-12-03 atoomula@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/translator/ProjectTranslator.java 143 34 2730 1519 37 15 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelMessageSerdeFactory.java 35 7 2579 1547 7 5 2018-04-16 2021-02-11 atoomula@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelRecordSerdeFactory.java 35 7 2565 1547 7 5 2018-04-30 2021-02-11 atoomula@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/fn/ConvertToStringUdf.java 17 10 2382 2163 11 6 2018-10-30 2019-06-06 atoomula@linkedin.com srinipunuru@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/fn/FlattenUdf.java 18 12 2730 2151 12 5 2017-11-16 2019-06-18 spunuru@linkedin.com srinipunuru@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/fn/GetSqlFieldUdf.java 60 13 2382 1738 14 8 2018-10-30 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/fn/RegexMatchUdf.java 18 11 2675 1738 11 7 2018-01-10 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/fn/GetNestedFieldUdf.java 19 2 2107 1519 2 1 2019-08-01 2021-03-11 atoomula@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/fn/BuildOutputRecordUdf.java 28 12 2318 1738 12 6 2019-01-02 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/util/JsonUtil.java 44 5 2296 1547 6 6 2019-01-24 2021-02-11 wsong@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/util/SamzaSqlQueryParser.java 158 9 2296 1738 10 7 2019-01-24 2020-08-04 wsong@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/util/SqlFileParser.java 47 4 2296 1738 5 5 2019-01-24 2020-08-04 wsong@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/udf/ReflectionBasedUdfResolver.java 79 4 2030 1994 4 2 2019-10-17 2019-11-22 spvenkat@usc.edu spvenkat@usc.edu samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationContext.java 19 5 2402 2394 8 5 2018-10-10 2018-10-18 calee@linkedin.com wsong@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplication.java 59 25 2730 2037 31 11 2017-11-16 2019-10-10 spunuru@linkedin.com sanil.jain15@gmail.com samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java 247 48 2730 1547 54 15 2017-11-16 2021-02-11 spunuru@linkedin.com stuart.m.perks@gmail.com samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationRunner.java 95 32 2730 1519 36 15 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedIOResolverFactory.java 84 23 2575 1738 26 10 2018-04-20 2020-08-04 pdu@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedUdfResolver.java 80 14 2730 1738 14 8 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelSchemaProvider.java 6 5 2730 2375 6 6 2017-11-16 2018-11-06 spunuru@linkedin.com wsong@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java 249 44 2730 1262 46 13 2017-11-16 2021-11-23 spunuru@linkedin.com hengyuj34@gmail.com samza-sql/src/main/java/org/apache/samza/sql/avro/AvroTypeFactoryImpl.java 95 22 2730 1519 25 10 2017-11-16 2021-03-11 spunuru@linkedin.com atoomula@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/avro/ConfigBasedAvroRelSchemaProviderFactory.java 31 5 2730 2291 5 4 2017-11-16 2019-01-29 spunuru@linkedin.com bshkolnik@linkedin.com samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverterFactory.java 15 4 2730 1738 4 4 2017-11-16 2020-08-04 spunuru@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverter.java 71 14 2422 1738 17 7 2018-09-20 2020-08-04 atoomula@linkedin.com 54013208+mabelyc@users.noreply.github.com samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverterFactory.java 10 3 2422 2417 3 3 2018-09-20 2018-09-25 atoomula@linkedin.com boryas@apache.org