elastic / elasticsearch-hadoop

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 3,423 units with 30,962 lines of code in units (72.5% of code).

6 very long units (807 lines of code)
47 long units (3,162 lines of code)
284 medium size units (8,540 lines of code)
494 small units (7,294 lines of code)
2,592 very small units (11,159 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
public BulkResponse tryFlush() in mr/src/main/java/org/elasticsearch/hadoop/rest/bulk/BulkProcessor.java	176	28	0
private static void configureBuildTasks() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/BuildPlugin.groovy	173	7	1
private def translateFilter() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/DefaultSource.scala	135	48	3
public void testProxyKerberosAuth() in qa/kerberos/src/itest/java/org/elasticsearch/hadoop/qa/kerberos/AbstractKerberosClientTest.java	114	1	0
public Response execute() in mr/src/main/java/org/elasticsearch/hadoop/rest/commonshttp/CommonsHttpTransport.java	108	28	1
private void initExtractorsFromSettings() in mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/AbstractBulkFactory.java	101	22	1
protected Result doWrite() in mr/src/main/java/org/elasticsearch/hadoop/serialization/builder/JdkValueWriter.java	98	27	3
private def doWriteScala() in spark/core/src/main/scala/org/elasticsearch/spark/serialization/ScalaValueWriter.scala	93	32	3
public int run() in mr/src/main/java/org/elasticsearch/hadoop/cli/Keytool.java	91	21	3
private Scroll read() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ScrollReader.java	91	16	2
static List setup() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/fixture/hadoop/HadoopClusterFormationTasks.groovy	87	12	2
public void run() in qa/kerberos/src/main/java/org/elasticsearch/hadoop/qa/kerberos/setup/SetupKerberosUsers.java	87	4	1
public static Writable toWritable() in mr/src/main/java/org/elasticsearch/hadoop/util/WritableUtils.java	80	23	1
public Result write() in mr/src/main/java/org/elasticsearch/hadoop/mr/WritableValueWriter.java	79	24	2
public void test3WriteWithUpsertScript() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java	78	4	0
private def convertField() in spark/sql-30/src/main/scala/org/elasticsearch/spark/sql/SchemaUtils.scala	78	45	7
public void delete() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestRepository.java	78	10	0
private void addHttpAuth() in mr/src/main/java/org/elasticsearch/hadoop/rest/commonshttp/CommonsHttpTransport.java	77	19	3
public BytesRef writeBulkEntry() in mr/src/main/java/org/elasticsearch/hadoop/serialization/bulk/BulkEntryWriter.java	76	17	1
public BytesArray generateMessage() in mr/src/main/java/org/elasticsearch/hadoop/util/ecs/MessageTemplate.java	75	12	5
public Resource() in mr/src/main/java/org/elasticsearch/hadoop/rest/Resource.java	75	23	2
public void testEsRDDWriteWithUpsertScriptUsingBothObjectAndRegularString() in spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkStreamingTest.java	74	6	0
def testEsRDDWriteJoinField() in spark/core/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSpark.scala	74	3	0
private void configureMaven() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/BuildPlugin.groovy	72	1	1
def testJoinField() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala	70	3	0
static in mr/src/main/java/org/elasticsearch/hadoop/rest/HttpStatus.java	70	1	0
private String assemble() in mr/src/main/java/org/elasticsearch/hadoop/rest/SearchRequestBuilder.java	69	19	0
public void testSuccessfulNegotiateWithRealmName() in mr/src/itest/java/org/elasticsearch/hadoop/rest/commonshttp/auth/spnego/AbstractSpnegoNegotiatorTest.java	67	9	0
public void testSuccessfulNegotiate() in mr/src/itest/java/org/elasticsearch/hadoop/rest/commonshttp/auth/spnego/AbstractSpnegoNegotiatorTest.java	65	9	0
public static Object fromWritable() in mr/src/main/java/org/elasticsearch/hadoop/util/WritableUtils.java	65	20	1
static TaskPair configureNode() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/fixture/hadoop/HadoopClusterFormationTasks.groovy	64	11	5
protected void runAnt() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/buildtools/AntFixture.groovy	64	12	1
public static PartitionReader createReader() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestService.java	62	14	3
private Result write() in hive/src/main/java/org/elasticsearch/hadoop/hive/HiveValueWriter.java	62	16	3
private static RestRepository initSingleIndex() in mr/src/main/java/org/elasticsearch/hadoop/rest/RestService.java	61	14	4
private static void doFind() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ParsingUtils.java	60	19	4
public static GitInfo gitInfo() in buildSrc/src/main/java/org/elasticsearch/hadoop/gradle/buildtools/info/GlobalBuildInfoPlugin.java	58	10	1
protected Object map() in mr/src/main/java/org/elasticsearch/hadoop/serialization/ScrollReader.java	58	13	2
def testEsRDDWriteWithUpsertScriptUsingBothObjectAndRegularString() in spark/core/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSpark.scala	57	4	0
def testParams() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala	55	1	0
def testEsDataFrame52OverwriteExistingDataSourceWithJoinField() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkSQL.scala	55	2	0
def testUpdate() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsSparkStructuredStreaming.scala	54	5	0
private static void configureConfigurations() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/BuildPlugin.groovy	54	3	1
public CommonsHttpTransport() in mr/src/main/java/org/elasticsearch/hadoop/rest/commonshttp/CommonsHttpTransport.java	54	7	3
static Object hiveFromWritable() in hive/src/main/java/org/elasticsearch/hadoop/hive/EsSerDe.java	54	13	3
def testEsRDDWriteWithUpsertScriptUsingBothObjectAndRegularString() in spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractScalaEsScalaSparkStreaming.scala	53	4	0
private static void configurePom() in buildSrc/src/main/groovy/org/elasticsearch/hadoop/gradle/BuildPlugin.groovy	53	5	2
public static int levenshteinDistance() in mr/src/main/java/org/elasticsearch/hadoop/util/StringUtils.java	53	14	3
static in mr/src/main/java/org/elasticsearch/hadoop/util/Version.java	53	13	0
public void init() in mr/src/main/java/org/elasticsearch/hadoop/handler/impl/elasticsearch/ElasticsearchHandler.java	53	8	1