Path	Lines of Code
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	118
src/main/java/org/apache/flink/benchmark/BlockingPartitionRemoteChannelBenchmark.java	81
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	116
src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java	81
src/main/java/org/apache/flink/benchmark/InputBenchmark.java	50
src/main/java/org/apache/flink/benchmark/KeyByBenchmarks.java	65
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	430
src/main/java/org/apache/flink/benchmark/SortingBoundedInputBenchmarks.java	313
src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java	70
src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java	20
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	63
src/main/java/org/apache/flink/benchmark/full/PojoSerializationBenchmark.java	120
src/main/java/org/apache/flink/benchmark/full/SerializationFrameworkAllBenchmarks.java	264
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	33
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	59
src/main/java/org/apache/flink/state/benchmark/ListStateBenchmark.java	110
src/main/java/org/apache/flink/state/benchmark/MapStateBenchmark.java	125
src/main/java/org/apache/flink/state/benchmark/RescalingBenchmarkBase.java	120
src/main/java/org/apache/flink/state/benchmark/RocksdbStateBackendRescalingBenchmarkExecutor.java	59
src/main/java/org/apache/flink/state/benchmark/StateBenchmarkBase.java	84
src/main/java/org/apache/flink/state/benchmark/StateBenchmarkConstants.java	50
src/main/java/org/apache/flink/state/benchmark/ValueStateBenchmark.java	51
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
src/main/scala/org/apache/flink/benchmark/functions/ScalaADTSource.scala	15