Path	Lines of Code
regression_report.py	123
regression_report_v2.py	73
save_jmh_result.py	85
src/main/java/org/apache/flink/benchmark/AsyncWaitOperatorBenchmark.java	74
src/main/java/org/apache/flink/benchmark/BackpressureUtils.java	69
src/main/java/org/apache/flink/benchmark/BenchmarkBase.java	25
src/main/java/org/apache/flink/benchmark/BlockingPartitionBenchmark.java	76
src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java	58
src/main/java/org/apache/flink/benchmark/CheckpointEnvironmentContext.java	125
src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java	84
src/main/java/org/apache/flink/benchmark/CollectSink.java	11
src/main/java/org/apache/flink/benchmark/ContinuousFileReaderOperatorBenchmark.java	114
src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java	78
src/main/java/org/apache/flink/benchmark/HighAvailabilityServiceBenchmark.java	96
src/main/java/org/apache/flink/benchmark/InputBenchmark.java	50
src/main/java/org/apache/flink/benchmark/KeyByBenchmarks.java	67
src/main/java/org/apache/flink/benchmark/MemoryStateBackendBenchmark.java	41
src/main/java/org/apache/flink/benchmark/MultiInputCheckpointingTimeBenchmark.java	96
src/main/java/org/apache/flink/benchmark/MultipleInputBenchmark.java	149
src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java	85
src/main/java/org/apache/flink/benchmark/RemoteBenchmarkBase.java	17
src/main/java/org/apache/flink/benchmark/RemoteChannelThroughputBenchmark.java	69
src/main/java/org/apache/flink/benchmark/RocksStateBackendBenchmark.java	51
src/main/java/org/apache/flink/benchmark/SerializationFrameworkMiniBenchmarks.java	434
src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java	313
src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java	73
src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java	24
src/main/java/org/apache/flink/benchmark/TwoInputBenchmark.java	64
src/main/java/org/apache/flink/benchmark/WatermarkAggregationBenchmark.java	43
src/main/java/org/apache/flink/benchmark/WindowBenchmarks.java	61
src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java	120
src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java	256
src/main/java/org/apache/flink/benchmark/full/StringSerializationBenchmark.java	97
src/main/java/org/apache/flink/benchmark/full/package-info.java	1
src/main/java/org/apache/flink/benchmark/functions/BaseSourceWithKeyRange.java	32
src/main/java/org/apache/flink/benchmark/functions/IntLongApplications.java	16
src/main/java/org/apache/flink/benchmark/functions/IntegerLongSource.java	48
src/main/java/org/apache/flink/benchmark/functions/LongNewSource.java	32
src/main/java/org/apache/flink/benchmark/functions/LongSource.java	26
src/main/java/org/apache/flink/benchmark/functions/LongSourceType.java	33
src/main/java/org/apache/flink/benchmark/functions/MultiplyByTwo.java	8
src/main/java/org/apache/flink/benchmark/functions/MultiplyIntLongByTwo.java	9
src/main/java/org/apache/flink/benchmark/functions/QueuingLongSource.java	26
src/main/java/org/apache/flink/benchmark/functions/SuccessException.java	2
src/main/java/org/apache/flink/benchmark/functions/SumReduce.java	8
src/main/java/org/apache/flink/benchmark/functions/SumReduceIntLong.java	9
src/main/java/org/apache/flink/benchmark/functions/TestUtils.java	26
src/main/java/org/apache/flink/benchmark/functions/ValidatingCounter.java	17
src/main/java/org/apache/flink/benchmark/operators/MultiplyByTwoCoStreamMap.java	15
src/main/java/org/apache/flink/benchmark/operators/MultiplyByTwoOperatorFactory.java	44
src/main/java/org/apache/flink/benchmark/operators/RecordSource.java	161
src/main/java/org/apache/flink/benchmark/thrift/MyOperation.java	418
src/main/java/org/apache/flink/benchmark/thrift/MyPojo.java	1123
src/main/java/org/apache/flink/config/ConfigUtil.java	59
src/main/java/org/apache/flink/config/StateBenchmarkOptions.java	10
src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java	35
src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingDownstreamTasksInBatchJobBenchmarkExecutor.java	36
src/main/java/org/apache/flink/scheduler/benchmark/deploying/DeployingTasksInStreamingJobBenchmarkExecutor.java	35
src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInBatchJobBenchmarkExecutor.java	35
src/main/java/org/apache/flink/scheduler/benchmark/failover/RegionToRestartInStreamingJobBenchmarkExecutor.java	35
src/main/java/org/apache/flink/scheduler/benchmark/partitionrelease/PartitionReleaseInBatchJobBenchmarkExecutor.java	34
src/main/java/org/apache/flink/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkExecutor.java	35
src/main/java/org/apache/flink/scheduler/benchmark/scheduling/SchedulingDownstreamTasksInBatchJobBenchmarkExecutor.java	35
src/main/java/org/apache/flink/scheduler/benchmark/topology/BuildExecutionGraphBenchmarkExecutor.java	34
src/main/java/org/apache/flink/state/benchmark/HashMapStateBackendRescalingBenchmarkExecutor.java	57
src/main/java/org/apache/flink/state/benchmark/ListStateBenchmark.java	101
src/main/java/org/apache/flink/state/benchmark/MapStateBenchmark.java	125
src/main/java/org/apache/flink/state/benchmark/RescalingBenchmarkBase.java	131
src/main/java/org/apache/flink/state/benchmark/RocksdbStateBackendRescalingBenchmarkExecutor.java	57
src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java	91
src/main/java/org/apache/flink/state/benchmark/StateBenchmarkConstants.java	50
src/main/java/org/apache/flink/state/benchmark/ValueStateBenchmark.java	51
src/main/java/org/apache/flink/state/benchmark/ttl/TtlListStateBenchmark.java	104
src/main/java/org/apache/flink/state/benchmark/ttl/TtlMapStateBenchmark.java	94
src/main/java/org/apache/flink/state/benchmark/ttl/TtlStateBenchmarkBase.java	62
src/main/java/org/apache/flink/state/benchmark/ttl/TtlValueStateBenchmark.java	57
src/main/resources/avro/mypojo.avsc	74
src/main/resources/benchmark-conf.yaml	1
src/main/resources/protobuf/MyPojo.proto	33
src/main/resources/thrift/mypojo.thrift	16