id: 1 unit: setup_credentials file: lib/fluent/plugin/kinesis_helper/client.rb start line: 130 end line: 206 size: 74 LOC McCabe index: 34 number of parameters: 0 id: 2 unit: give_up_retries file: lib/fluent/plugin/kinesis_helper/api.rb start line: 171 end line: 209 size: 29 LOC McCabe index: 7 number of parameters: 1 id: 3 unit: data_formatter_create file: lib/fluent/plugin/kinesis.rb start line: 93 end line: 119 size: 23 LOC McCabe index: 5 number of parameters: 1 id: 4 unit: batch_request_with_retry file: lib/fluent/plugin/kinesis_helper/api.rb start line: 91 end line: 110 size: 18 LOC McCabe index: 6 number of parameters: 4 id: 5 unit: create_driver file: benchmark/task.rake start line: 77 end line: 96 size: 18 LOC McCabe index: 6 number of parameters: 2 id: 6 unit: collect_failed_records file: lib/fluent/plugin/kinesis_helper/api.rb start line: 127 end line: 143 size: 16 LOC McCabe index: 4 number of parameters: 2 id: 7 unit: split_to_batches file: lib/fluent/plugin/kinesis_helper/api.rb start line: 75 end line: 90 size: 15 LOC McCabe index: 3 number of parameters: 2 id: 8 unit: client_options file: lib/fluent/plugin/kinesis_helper/client.rb start line: 114 end line: 129 size: 15 LOC McCabe index: 6 number of parameters: 0 id: 9 unit: write file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 44 end line: 58 size: 14 LOC McCabe index: 1 number of parameters: 1 id: 10 unit: default_config file: benchmark/task.rake start line: 62 end line: 76 size: 14 LOC McCabe index: 2 number of parameters: 0 id: 11 unit: deaggregate file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 57 end line: 70 size: 13 LOC McCabe index: 3 number of parameters: 1 id: 12 unit: configure file: lib/fluent/plugin/kinesis_helper/api.rb start line: 55 end line: 68 size: 13 LOC McCabe index: 5 number of parameters: 1 id: 13 unit: setup file: benchmark/task.rake start line: 42 end line: 55 size: 13 LOC McCabe index: 2 number of parameters: 0 id: 14 unit: write file: lib/fluent/plugin/out_kinesis_streams.rb start line: 42 end line: 54 size: 12 LOC McCabe index: 1 number of parameters: 1 id: 15 unit: key_formatter_create file: lib/fluent/plugin/out_kinesis_streams.rb start line: 57 end line: 69 size: 12 LOC McCabe index: 3 number of parameters: 0 id: 16 unit: write file: lib/fluent/plugin/out_kinesis_firehose.rb start line: 45 end line: 57 size: 12 LOC McCabe index: 1 number of parameters: 1 id: 17 unit: format_for_api file: lib/fluent/plugin/kinesis.rb start line: 131 end line: 142 size: 11 LOC McCabe index: 3 number of parameters: 1 id: 18 unit: increment_num_errors file: lib/fluent/plugin/kinesis_helper/api.rb start line: 210 end line: 223 size: 10 LOC McCabe index: 5 number of parameters: 0 id: 19 unit: client_class file: lib/fluent/plugin/kinesis_helper/client.rb start line: 103 end line: 113 size: 10 LOC McCabe index: 3 number of parameters: 0 id: 20 unit: compressor_create file: lib/fluent/plugin/kinesis.rb start line: 120 end line: 130 size: 10 LOC McCabe index: 3 number of parameters: 0 id: 21 unit: aggregate file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 47 end line: 56 size: 9 LOC McCabe index: 1 number of parameters: 2 id: 22 unit: write_records_batch file: lib/fluent/plugin/kinesis.rb start line: 151 end line: 160 size: 9 LOC McCabe index: 1 number of parameters: 3 id: 23 unit: configure file: lib/fluent/plugin/out_kinesis_firehose.rb start line: 29 end line: 38 size: 9 LOC McCabe index: 2 number of parameters: 1 id: 24 unit: reliable_sleep file: lib/fluent/plugin/kinesis_helper/api.rb start line: 114 end line: 122 size: 8 LOC McCabe index: 2 number of parameters: 1 id: 25 unit: retry_records file: lib/fluent/plugin/kinesis_helper/api.rb start line: 144 end line: 152 size: 8 LOC McCabe index: 3 number of parameters: 1 id: 26 unit: failed_count file: lib/fluent/plugin/kinesis_helper/api.rb start line: 153 end line: 161 size: 8 LOC McCabe index: 4 number of parameters: 1 id: 27 unit: results file: lib/fluent/plugin/kinesis_helper/api.rb start line: 162 end line: 170 size: 8 LOC McCabe index: 4 number of parameters: 1 id: 28 unit: initialize file: lib/fluent/plugin/kinesis.rb start line: 29 end line: 37 size: 8 LOC McCabe index: 2 number of parameters: 2 id: 29 unit: benchmark file: benchmark/task.rake start line: 97 end line: 105 size: 8 LOC McCabe index: 1 number of parameters: 2 id: 30 unit: create_partition_key_generator file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 69 end line: 76 size: 7 LOC McCabe index: 2 number of parameters: 0 id: 31 unit: format file: lib/fluent/plugin/out_kinesis_streams.rb start line: 34 end line: 41 size: 7 LOC McCabe index: 1 number of parameters: 3 id: 32 unit: self.compress file: lib/fluent/plugin/kinesis_helper/compression.rb start line: 15 end line: 22 size: 7 LOC McCabe index: 1 number of parameters: 3 id: 33 unit: truncate file: lib/fluent/plugin/kinesis.rb start line: 165 end line: 172 size: 7 LOC McCabe index: 2 number of parameters: 1 id: 34 unit: configure file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 31 end line: 37 size: 6 LOC McCabe index: 1 number of parameters: 1 id: 35 unit: configure file: lib/fluent/plugin/kinesis_helper/api.rb start line: 33 end line: 39 size: 6 LOC McCabe index: 2 number of parameters: 1 id: 36 unit: format file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 38 end line: 43 size: 5 LOC McCabe index: 1 number of parameters: 3 id: 37 unit: aggregated_size_offset file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 75 end line: 80 size: 5 LOC McCabe index: 1 number of parameters: 1 id: 38 unit: next file: lib/fluent/plugin/kinesis_helper/api.rb start line: 229 end line: 234 size: 5 LOC McCabe index: 1 number of parameters: 0 id: 39 unit: format file: lib/fluent/plugin/out_kinesis_firehose.rb start line: 39 end line: 44 size: 5 LOC McCabe index: 1 number of parameters: 3 id: 40 unit: run file: benchmark/task.rake start line: 36 end line: 41 size: 5 LOC McCabe index: 3 number of parameters: 0 id: 41 unit: teardown file: benchmark/task.rake start line: 56 end line: 61 size: 5 LOC McCabe index: 2 number of parameters: 0 id: 42 unit: configure file: lib/fluent/plugin/out_kinesis_streams.rb start line: 29 end line: 33 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 43 unit: initialize file: lib/fluent/plugin/kinesis_helper/compression.rb start line: 4 end line: 8 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 44 unit: configure file: lib/fluent/plugin/kinesis_helper/client.rb start line: 92 end line: 96 size: 4 LOC McCabe index: 2 number of parameters: 1 id: 45 unit: configure file: lib/fluent/plugin/kinesis.rb start line: 78 end line: 82 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 46 unit: initialize file: benchmark/task.rake start line: 31 end line: 35 size: 4 LOC McCabe index: 1 number of parameters: 1 id: 47 unit: offset file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 59 end line: 62 size: 3 LOC McCabe index: 2 number of parameters: 0 id: 48 unit: size_of_values file: lib/fluent/plugin/out_kinesis_streams_aggregated.rb start line: 65 end line: 68 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 49 unit: close file: lib/fluent/plugin/kinesis_helper/compression.rb start line: 9 end line: 12 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 50 unit: self.decompress file: lib/fluent/plugin/kinesis_helper/compression.rb start line: 23 end line: 26 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 51 unit: aggregated? file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 71 end line: 74 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 52 unit: self.included file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 89 end line: 92 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 53 unit: aggregator file: lib/fluent/plugin/kinesis_helper/aggregator.rb start line: 93 end line: 96 size: 3 LOC McCabe index: 2 number of parameters: 0 id: 54 unit: self.included file: lib/fluent/plugin/kinesis_helper/api.rb start line: 29 end line: 32 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 55 unit: self.included file: lib/fluent/plugin/kinesis_helper/api.rb start line: 51 end line: 54 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 56 unit: size_of_values file: lib/fluent/plugin/kinesis_helper/api.rb start line: 69 end line: 72 size: 3 LOC McCabe index: 2 number of parameters: 1 id: 57 unit: any_records_shipped? file: lib/fluent/plugin/kinesis_helper/api.rb start line: 123 end line: 126 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 58 unit: initialize file: lib/fluent/plugin/kinesis_helper/api.rb start line: 225 end line: 228 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 59 unit: reset file: lib/fluent/plugin/kinesis_helper/api.rb start line: 235 end line: 238 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 60 unit: calc file: lib/fluent/plugin/kinesis_helper/api.rb start line: 241 end line: 244 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 61 unit: scaling_factor file: lib/fluent/plugin/kinesis_helper/api.rb start line: 245 end line: 248 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 62 unit: self.included file: lib/fluent/plugin/kinesis_helper/client.rb start line: 88 end line: 91 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 63 unit: client file: lib/fluent/plugin/kinesis_helper/client.rb start line: 97 end line: 100 size: 3 LOC McCabe index: 2 number of parameters: 0 id: 64 unit: to_s file: lib/fluent/plugin/kinesis.rb start line: 38 end line: 41 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 65 unit: initialize file: lib/fluent/plugin/kinesis.rb start line: 43 end line: 46 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 66 unit: initialize file: lib/fluent/plugin/kinesis.rb start line: 48 end line: 51 size: 3 LOC McCabe index: 1 number of parameters: 2 id: 67 unit: initialize file: lib/fluent/plugin/kinesis.rb start line: 53 end line: 56 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 68 unit: multi_workers_ready? file: lib/fluent/plugin/kinesis.rb start line: 83 end line: 86 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 69 unit: formatted_to_msgpack_binary? file: lib/fluent/plugin/kinesis.rb start line: 87 end line: 90 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 70 unit: msgpack_unpacker file: lib/fluent/plugin/kinesis.rb start line: 144 end line: 147 size: 3 LOC McCabe index: 1 number of parameters: 1 id: 71 unit: request_type file: lib/fluent/plugin/kinesis.rb start line: 161 end line: 164 size: 3 LOC McCabe index: 1 number of parameters: 0