Class AvroJobInitialiser

    • Constructor Detail

      • AvroJobInitialiser

        public AvroJobInitialiser()
      • AvroJobInitialiser

        public AvroJobInitialiser​(String avroSchemaFilePath)
    • Method Detail

      • initialiseJob

        public void initialiseJob​(org.apache.hadoop.mapreduce.Job job,
                                  MapReduce operation,
                                  Store store)
                           throws IOException
        Description copied from interface: JobInitialiser
        Initialises a job. This will probably involve setting up the job configuration.
        Specified by:
        initialiseJob in interface JobInitialiser
        Parameters:
        job - the Job to be initialised
        operation - the MapReduce containing configuration.
        store - the Store that will handle the Operation
        Throws:
        IOException - if IO issues occur
      • getAvroSchemaFilePath

        public String getAvroSchemaFilePath()
      • setAvroSchemaFilePath

        public void setAvroSchemaFilePath​(String avroSchemaFilePath)