360Science for Spark - DedupeTextFile

The DedupeTextFile application demonstrates using the matchIT Hub for Spark ‘String’ classes to work with text files, delimited record strings, and Spark RDDs.



The command line argument to DedupeTextFile is the name of a configuration file. This is an xml file in the following format:

<?xml version="1.0" encoding="utf-8" ?>


<input table="0" columns="|UniqueRef|FullName|Company|Address1|Address2|City|State|Zip" />

The <dedupeTextFile> section is specific to this application.

mainFile The file to deduplicate, or the main file for an overlap.
overlapFile The file to overlap with the main file. Do not specify this to perform an internal dedupe of a single file.
delimiter The delimiter used in the input file and used in the delimited Strings in the RDDs.
inputHeader Indicates that the input file contains a header row, also triggers the use of DataFrames rather than RDDs.
outputPath The output folder for the matching output.
coalesceOutput If true the output is coalesced to a single partition so that only one file is created.

See DedupeConfiguration for a description of the configuration options: licenceFile, logLevel, groupingAlgorithm, idField, and maxIterations.

The <hub> section configures the underlying matching engine. Refer to the matchIT Hub documentation for details. The <hub> section must contain the following sub-sections: data, matching, threads, advanced.

Running the sample

cd samples/DedupeTextFile
chmod 777 DedupeTextFile-jar-with-dependencies.jar run.sh

Was this article helpful?
0 out of 0 found this helpful

have a question or not finding what you're looking for?

Submit a ticket to get some help