id: 1
unit: public List emit()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 246
end line: 312
size: 58 LOC
McCabe index: 12
number of parameters: 1

id: 2
unit: public Worker createWorker()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/CommandLineInterface.java
start line: 147
end line: 231
size: 53 LOC
McCabe index: 2
number of parameters: 0

id: 3
unit: private AsyncHandler getHandler()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 314
end line: 377
size: 50 LOC
McCabe index: 11
number of parameters: 5

id: 4
unit: protected synchronized void emitCloudWatchMetrics()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 387
end line: 424
size: 37 LOC
McCabe index: 8
number of parameters: 3

id: 5
unit: public static String getTaskName()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBConnectorUtilities.java
start line: 48
end line: 77
size: 27 LOC
McCabe index: 6
number of parameters: 5

id: 6
unit: private AmazonWebServiceRequest createRequest()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 215
end line: 239
size: 22 LOC
McCabe index: 5
number of parameters: 1

id: 7
unit: public void fail()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 430
end line: 451
size: 21 LOC
McCabe index: 5
number of parameters: 1

id: 8
unit: public static void main()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/CommandLineInterface.java
start line: 60
end line: 77
size: 18 LOC
McCabe index: 4
number of parameters: 1

id: 9
unit: public DynamoDBReplicationEmitter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 190
end line: 206
size: 16 LOC
McCabe index: 6
number of parameters: 6

id: 10
unit: public static boolean isStreamsEnabled()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBConnectorUtilities.java
start line: 90
end line: 101
size: 11 LOC
McCabe index: 3
number of parameters: 3

id: 11
unit: static Optional mainUnsafe()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/CommandLineInterface.java
start line: 79
end line: 96
size: 11 LOC
McCabe index: 2
number of parameters: 1

id: 12
unit: public void consumeRecord()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 95
end line: 105
size: 9 LOC
McCabe index: 2
number of parameters: 3

id: 13
unit: public void clear()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 81
end line: 89
size: 8 LOC
McCabe index: 1
number of parameters: 0

id: 14
unit: private static MessageDigest getMessageDigestInstance()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBConnectorConstants.java
start line: 63
end line: 70
size: 8 LOC
McCabe index: 2
number of parameters: 1

id: 15
unit: public Record toClass()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBStreamsRecordTransformer.java
start line: 45
end line: 51
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 16
unit: public IEmitter getEmitter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBMasterToReplicasPipeline.java
start line: 38
end line: 45
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 17
unit: public IBuffer getBuffer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBMasterToReplicasPipeline.java
start line: 48
end line: 54
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 18
unit: public void shutdown()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 457
end line: 463
size: 7 LOC
McCabe index: 2
number of parameters: 0

id: 19
unit: protected void emitCloudWatchMetrics()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 110
end line: 117
size: 7 LOC
McCabe index: 2
number of parameters: 0

id: 20
unit: public DynamoDBReplicationEmitter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 153
end line: 158
size: 6 LOC
McCabe index: 1
number of parameters: 6

id: 21
unit: public DynamoDBReplicationEmitter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 169
end line: 173
size: 5 LOC
McCabe index: 1
number of parameters: 3

id: 22
unit: public String toString()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 181
end line: 185
size: 5 LOC
McCabe index: 1
number of parameters: 0

id: 23
unit: public DynamoDBReplicationEmitter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 132
end line: 135
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 24
unit: public DynamoDBStreamsConnectorConfiguration()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBStreamsConnectorConfiguration.java
start line: 47
end line: 51
size: 4 LOC
McCabe index: 1
number of parameters: 2

id: 25
unit: EndpointConfiguration createKclDynamoDbEndpointConfiguration()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/CommandLineInterface.java
start line: 234
end line: 237
size: 4 LOC
McCabe index: 2
number of parameters: 0

id: 26
unit: public Record fromClass()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBStreamsRecordTransformer.java
start line: 36
end line: 39
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 27
unit: public ITransformer getTransformer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBMasterToReplicasPipeline.java
start line: 57
end line: 59
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 28
unit: public IFilter getFilter()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBMasterToReplicasPipeline.java
start line: 62
end line: 64
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 29
unit: public String toString()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 469
end line: 471
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 30
unit: public String getTableName()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 476
end line: 478
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 31
unit: public AmazonDynamoDBAsync getDynamodb()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 483
end line: 485
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 32
unit: public String getEndpoint()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 490
end line: 492
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 33
unit: public String getRegion()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBReplicationEmitter.java
start line: 497
end line: 499
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 34
unit: public DynamoDBBuffer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 72
end line: 75
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 35
unit: public long getBytesToBuffer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 123
end line: 125
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 36
unit: public String getFirstSequenceNumber()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 131
end line: 133
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 37
unit: public String getLastSequenceNumber()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 139
end line: 141
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 38
unit: public long getMillisecondsToBuffer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 147
end line: 149
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 39
unit: public long getNumRecordsToBuffer()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 155
end line: 157
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 40
unit: public List getRecords()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 163
end line: 166
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 41
unit: public boolean shouldFlush()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 172
end line: 175
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 42
unit: public void setLastSequenceNumber()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 198
end line: 200
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 43
unit: public void setFirstSequenceNumber()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 206
end line: 208
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 44
unit: public double getProcessedRecords()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 213
end line: 215
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 45
unit: public void setProcessedRecords()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 221
end line: 223
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 46
unit: public AmazonCloudWatch getCloudwatch()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBBuffer.java
start line: 228
end line: 230
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 47
unit: public static ObjectMapper getInstance()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBStreamsRecordObjectMapper.java
start line: 39
end line: 41
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 48
unit: public DeleteAlarmsResult deleteAlarms()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 47
end line: 49
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 49
unit: public DescribeAlarmHistoryResult describeAlarmHistory()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 52
end line: 54
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 50
unit: public DescribeAlarmHistoryResult describeAlarmHistory()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 57
end line: 59
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 51
unit: public DescribeAlarmsResult describeAlarms()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 62
end line: 64
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 52
unit: public DescribeAlarmsResult describeAlarms()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 67
end line: 69
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 53
unit: public DescribeAlarmsForMetricResult describeAlarmsForMetric()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 72
end line: 74
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 54
unit: public DisableAlarmActionsResult disableAlarmActions()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 77
end line: 79
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 55
unit: public EnableAlarmActionsResult enableAlarmActions()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 82
end line: 84
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 56
unit: public GetMetricStatisticsResult getMetricStatistics()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 87
end line: 89
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 57
unit: public ListMetricsResult listMetrics()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 92
end line: 94
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 58
unit: public ListMetricsResult listMetrics()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 97
end line: 99
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 59
unit: public PutMetricAlarmResult putMetricAlarm()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 102
end line: 104
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 60
unit: public PutMetricDataResult putMetricData()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 107
end line: 109
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 61
unit: public SetAlarmStateResult setAlarmState()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 112
end line: 114
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 62
unit: public ResponseMetadata getCachedResponseMetadata()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 122
end line: 124
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 63
unit: public AmazonCloudWatchWaiters waiters()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 127
end line: 129
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 64
unit: public void setEndpoint()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 37
end line: 39
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 65
unit: public void setRegion()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 42
end line: 44
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 66
unit: public void shutdown()
file: src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/NoopCloudWatch.java
start line: 117
end line: 119
size: 2 LOC
McCabe index: 1
number of parameters: 0