id: 1
unit: public Configuration()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 77
end line: 144
size: 58 LOC
McCabe index: 1
number of parameters: 2

id: 2
unit: public void run()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/InitConfig.java
start line: 68
end line: 115
size: 41 LOC
McCabe index: 2
number of parameters: 0

id: 3
unit: private ListenableFuture publishAsync()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java
start line: 90
end line: 127
size: 35 LOC
McCabe index: 3
number of parameters: 3

id: 4
unit: public void setAllShardsToBeginning()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/CheckpointResetter.java
start line: 58
end line: 97
size: 35 LOC
McCabe index: 5
number of parameters: 1

id: 5
unit: protected void configure()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Module.java
start line: 66
end line: 91
size: 26 LOC
McCabe index: 2
number of parameters: 0

id: 6
unit: public KinesisProducer get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisProducerProvider.java
start line: 38
end line: 66
size: 26 LOC
McCabe index: 1
number of parameters: 0

id: 7
unit: public void processRecords()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java
start line: 61
end line: 85
size: 25 LOC
McCabe index: 3
number of parameters: 1

id: 8
unit: private Set getAllShards()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/CheckpointResetter.java
start line: 99
end line: 123
size: 24 LOC
McCabe index: 4
number of parameters: 1

id: 9
unit: SchedulerProvider create()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/SchedulerProvider.java
start line: 35
end line: 56
size: 20 LOC
McCabe index: 1
number of parameters: 3

id: 10
unit: private ListenableFuture publishSync()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java
start line: 71
end line: 88
size: 17 LOC
McCabe index: 2
number of parameters: 3

id: 11
unit: private RetrievalConfig getRetrievalConfig()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/SchedulerProvider.java
start line: 72
end line: 85
size: 14 LOC
McCabe index: 2
number of parameters: 0

id: 12
unit: public void shutdown()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 69
end line: 81
size: 13 LOC
McCabe index: 2
number of parameters: 0

id: 13
unit: public KinesisConsumer()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 44
end line: 53
size: 10 LOC
McCabe index: 1
number of parameters: 4

id: 14
unit: public KinesisPublisher()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java
start line: 48
end line: 57
size: 10 LOC
McCabe index: 1
number of parameters: 4

id: 15
unit: public Scheduler get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/SchedulerProvider.java
start line: 88
end line: 97
size: 10 LOC
McCabe index: 1
number of parameters: 0

id: 16
unit: public void shutdownRequested()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java
start line: 103
end line: 111
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 17
unit: public ExecutorService get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/ProducerCallbackExecutorProvider.java
start line: 26
end line: 35
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 18
unit: public void shardEnded()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java
start line: 93
end line: 100
size: 8 LOC
McCabe index: 2
number of parameters: 1

id: 19
unit: public CloudWatchAsyncClient get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/CloudWatchAsyncClientProvider.java
start line: 33
end line: 39
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 20
unit: public KinesisAsyncClient get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisAsyncClientProvider.java
start line: 34
end line: 40
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 21
unit: public void subscribe()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 55
end line: 61
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 22
unit: ListenableFuture publish()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java
start line: 64
end line: 69
size: 6 LOC
McCabe index: 2
number of parameters: 2

id: 23
unit: public KinesisBrokerApi()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 35
end line: 40
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 24
unit: public DynamoDbAsyncClient get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/DynamoDbAsyncClientProvider.java
start line: 33
end line: 39
size: 6 LOC
McCabe index: 1
number of parameters: 0

id: 25
unit: private static String getStringParam()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 186
end line: 191
size: 6 LOC
McCabe index: 2
number of parameters: 3

id: 26
unit: public void setPreviousBrokerApi()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Module.java
start line: 59
end line: 63
size: 5 LOC
McCabe index: 3
number of parameters: 1

id: 27
unit: private void runReceiver()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 63
end line: 67
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 28
unit: public void start()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerLifeCycleManager.java
start line: 36
end line: 40
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 29
unit: public void receiveAsync()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 48
end line: 52
size: 5 LOC
McCabe index: 1
number of parameters: 2

id: 30
unit: public Set topicSubscribers()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 55
end line: 59
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 31
unit: public void replayAllEvents()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 68
end line: 72
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 32
unit: public void start()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/AWSLogLevelListener.java
start line: 32
end line: 35
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 33
unit: public void resetOffset()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 91
end line: 100
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 34
unit: public KinesisBrokerLifeCycleManager()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerLifeCycleManager.java
start line: 30
end line: 33
size: 4 LOC
McCabe index: 1
number of parameters: 2

id: 35
unit: public void disconnect()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 62
end line: 65
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 36
unit: public void initialize()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java
start line: 55
end line: 58
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 37
unit: public String getStreamName()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisConsumer.java
start line: 87
end line: 89
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 38
unit: public void stop()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerLifeCycleManager.java
start line: 43
end line: 45
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 39
unit: public void onEvent()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisPublisher.java
start line: 60
end line: 62
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 40
unit: public ListenableFuture send()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisBrokerApi.java
start line: 43
end line: 45
size: 3 LOC
McCabe index: 1
number of parameters: 2

id: 41
unit: public ShardRecordProcessor shardRecordProcessor()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessorFactory.java
start line: 39
end line: 41
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 42
unit: public String getStreamEventsTopic()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 146
end line: 148
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 43
unit: public int getNumberOfSubscribers()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 150
end line: 152
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 44
unit: public String getApplicationName()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 154
end line: 156
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 45
unit: public Long getPublishTimeoutMs()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 158
end line: 160
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 46
unit: public Optional getRegion()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 162
end line: 164
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 47
unit: public Optional getEndpoint()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 166
end line: 168
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 48
unit: public Long getPublishSingleRequestTimeoutMs()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 170
end line: 172
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 49
unit: public Long getPollingIntervalMs()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 174
end line: 176
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 50
unit: public Integer getMaxRecords()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 178
end line: 180
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 51
unit: public InitialPositionInStream getInitialPosition()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 182
end line: 184
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 52
unit: public static String cosumerLeaseName()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 193
end line: 195
size: 3 LOC
McCabe index: 1
number of parameters: 2

id: 53
unit: public Long getShutdownTimeoutMs()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 197
end line: 199
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 54
unit: public Level getAwsLibLogLevel()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 201
end line: 203
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 55
unit: public Boolean isSendAsync()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 205
end line: 207
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 56
unit: public Boolean isSendStreamEvents()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/Configuration.java
start line: 209
end line: 211
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 57
unit: public void leaseLost()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/KinesisRecordProcessor.java
start line: 88
end line: 90
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 58
unit: public ExecutorService get()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/ConsumerExecutorProvider.java
start line: 33
end line: 35
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 59
unit: public void stop()
file: src/main/java/com/googlesource/gerrit/plugins/kinesis/AWSLogLevelListener.java
start line: 38
end line: 38
size: 1 LOC
McCabe index: 1
number of parameters: 0