apache / doris-flink-connector

Duplication

Places in code with 6 or more lines that are exactly the same.

Longest Duplicates

The list of 50 longest duplicates.

See data for all 56 duplicates...

Size	#	Folders	Files	Lines	Code
18	x 2	flink-doris-connector/sr...doris/flink/sink/writer flink-doris-connector/sr...doris/flink/sink/writer	RowDataSerializer.java RowSerializer.java	115:144 (21%) 61:90 (40%)	view
14	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataAsyncLookupFunction.java DorisRowDataJdbcLookupFunction.java	55:70 (20%) 56:71 (25%)	view
12	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...apache/doris/flink/rest	RestService.java RestService.java	462:473 (3%) 544:555 (3%)	view
11	x 2	flink-doris-connector/sr...che/doris/flink/catalog flink-doris-connector/sr...pache/doris/flink/table	DorisCatalogFactory.java DorisDynamicTableFactory.java	88:98 (18%) 111:121 (7%)	view
11	x 2	flink-doris-connector/sr.../apache/doris/flink/cfg flink-doris-connector/sr.../apache/doris/flink/cfg	DorisReadOptions.java DorisReadOptions.java	29:39 (9%) 128:138 (9%)	view
10	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr.../doris/flink/sink/batch	ExecutionPool.java DorisBatchStreamLoad.java	199:211 (8%) 277:289 (6%)	view
9	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataJdbcLookupFunction.java DorisRowDataLookupFunction.java	69:77 (16%) 75:83 (10%)	view
9	x 2	flink-doris-connector/sr...ris/flink/serialization flink-doris-connector/sr.../flink/tools/cdc/oracle	RowBatch.java OracleDateConverter.java	340:351 (3%) 121:132 (13%)	view
8	x 2	flink-doris-connector/sr...che/doris/flink/catalog flink-doris-connector/sr...pache/doris/flink/table	DorisCatalogFactory.java DorisDynamicTableFactory.java	100:107 (13%) 130:137 (5%)	view
8	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataAsyncLookupFunction.java DorisRowDataJdbcLookupFunction.java	121:131 (11%) 111:121 (14%)	view
8	x 2	flink-doris-connector/sr...apache/doris/flink/sink flink-doris-connector/sr.../doris/flink/sink/batch	DorisSink.java DorisBatchSink.java	52:61 (13%) 37:46 (18%)	view
7	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataAsyncLookupFunction.java DorisRowDataJdbcLookupFunction.java	46:52 (10%) 47:53 (12%)	view
7	x 2	flink-doris-connector/sr...doris/flink/sink/writer flink-doris-connector/sr...doris/flink/sink/writer	JsonDebeziumSchemaSerializer.java JsonDebeziumSchemaSerializer.java	211:218 (2%) 291:298 (2%)	view
7	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataJdbcLookupFunction.java DorisRowDataLookupFunction.java	87:94 (12%) 92:99 (8%)	view
7	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataAsyncLookupFunction.java DorisRowDataJdbcLookupFunction.java	73:79 (10%) 72:78 (12%)	view
6	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataAsyncLookupFunction.java DorisRowDataLookupFunction.java	73:78 (8%) 78:83 (7%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...oris/flink/source/split	Field.java DorisSourceSplit.java	90:96 (9%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...apache/doris/flink/sink	RecordKey.java DorisCommittable.java	31:37 (7%) 48:54 (17%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...apache/doris/flink/sink	Schema.java DorisCommittable.java	80:86 (12%) 48:54 (17%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/sink/writer	Field.java DorisWriterState.java	90:96 (9%) 35:41 (27%)	view
6	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisDynamicTableSource.java DorisDynamicTableSource.java	139:144 (7%) 148:153 (7%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...doris/flink/rest/models	PartitionDefinition.java Field.java	104:110 (7%) 90:96 (9%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/sink/writer	Tablet.java DorisWriterState.java	61:67 (17%) 35:41 (27%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...oris/flink/source/split	QueryPlan.java DorisSourceSplit.java	52:58 (20%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...doris/flink/rest/models	RecordKey.java QueryPlan.java	31:37 (7%) 52:58 (20%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...doris/flink/rest/models	PartitionDefinition.java QueryPlan.java	104:110 (7%) 52:58 (20%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...doris/flink/rest/models	RecordKey.java Schema.java	31:37 (7%) 80:86 (12%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	Field.java QueryPlan.java	90:96 (9%) 52:58 (20%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...apache/doris/flink/sink	Tablet.java DorisCommittable.java	61:67 (17%) 48:54 (17%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...doris/flink/rest/models	PartitionDefinition.java Schema.java	104:110 (7%) 80:86 (12%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/sink flink-doris-connector/sr...oris/flink/source/split	DorisCommittable.java DorisSourceSplit.java	48:54 (17%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	Field.java Tablet.java	90:96 (9%) 61:67 (17%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...oris/flink/source/split	PartitionDefinition.java DorisSourceSplit.java	104:110 (7%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...apache/doris/flink/sink	PartitionDefinition.java DorisCommittable.java	104:110 (7%) 48:54 (17%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...apache/doris/flink/sink	Field.java DorisCommittable.java	90:96 (9%) 48:54 (17%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	QueryPlan.java Schema.java	52:58 (20%) 80:86 (12%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...doris/flink/rest/models	RecordKey.java Field.java	31:37 (7%) 90:96 (9%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...doris/flink/sink/writer	RecordKey.java DorisWriterState.java	31:37 (7%) 35:41 (27%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/sink/writer	QueryPlan.java DorisWriterState.java	52:58 (20%) 35:41 (27%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...oris/flink/source/split	RecordKey.java DorisSourceSplit.java	31:37 (7%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...oris/flink/source/split	Tablet.java DorisSourceSplit.java	61:67 (17%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...ache/doris/flink/lookup flink-doris-connector/sr...apache/doris/flink/rest	RecordKey.java PartitionDefinition.java	31:37 (7%) 104:110 (7%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	Field.java Schema.java	90:96 (9%) 80:86 (12%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	QueryPlan.java Tablet.java	52:58 (20%) 61:67 (17%)	view
6	x 2	flink-doris-connector/sr...s/flink/tools/cdc/mysql flink-doris-connector/sr.../flink/tools/cdc/oracle	MysqlDatabaseSync.java OracleDatabaseSync.java	78:84 (4%) 92:98 (5%)	view
6	x 2	flink-doris-connector/sr...che/doris/flink/catalog flink-doris-connector/sr...pache/doris/flink/table	DorisCatalogFactory.java DorisDynamicTableFactory.java	63:70 (10%) 89:96 (4%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/sink flink-doris-connector/sr...doris/flink/sink/writer	DorisCommittable.java DorisWriterState.java	48:54 (17%) 35:41 (27%)	view
6	x 2	flink-doris-connector/sr...doris/flink/sink/writer flink-doris-connector/sr...oris/flink/source/split	DorisWriterState.java DorisSourceSplit.java	35:41 (27%) 61:67 (23%)	view
6	x 2	flink-doris-connector/sr...doris/flink/rest/models flink-doris-connector/sr...doris/flink/rest/models	Schema.java Tablet.java	80:86 (12%) 61:67 (17%)	view
6	x 2	flink-doris-connector/sr...apache/doris/flink/rest flink-doris-connector/sr...doris/flink/sink/writer	PartitionDefinition.java DorisWriterState.java	104:110 (7%) 35:41 (27%)	view

Duplicated Units

The list of top 4 duplicated units.

See data for all 4 unit duplicates...

Size	#	Folders	Files	Lines	Code
11	x 2	flink-doris-connector/sr.../flink/tools/cdc/oracle flink-doris-connector/sr...ris/flink/serialization	OracleDateConverter.java RowBatch.java	121:133  340:352	view
11	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisRowDataJdbcLookupFunction.java DorisRowDataAsyncLookupFunction.java	55:67  54:66	view
8	x 2	flink-doris-connector/sr...pache/doris/flink/table flink-doris-connector/sr...pache/doris/flink/table	DorisConfigOptions.java DorisDynamicTableFactory.java	240:250  224:234	view
7	x 2	flink-doris-connector/sr...apache/doris/flink/sink flink-doris-connector/sr.../doris/flink/sink/batch	DorisSink.java DorisBatchSink.java	51:59  36:44	view