Package uk.gov.gchq.gaffer.sparkaccumulo.operation.javardd

Class ImportKeyValueJavaPairRDDToAccumulo

  • All Implemented Interfaces:
    Closeable, AutoCloseable, Input<org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>, Operation
    public class ImportKeyValueJavaPairRDDToAccumulo
extends Object
implements Input<org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>

    • Constructor Detail

      • ImportKeyValueJavaPairRDDToAccumulo

        public ImportKeyValueJavaPairRDDToAccumulo()

    • Method Detail

      • getOutputPath

        public String getOutputPath()

      • setOutputPath

        public void setOutputPath​(String outputPath)

      • getFailurePath

        public String getFailurePath()

      • setFailurePath

        public void setFailurePath​(String failurePath)

      • getInput

        public org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> getInput()
        Specified by:
        getInput in interface Input<org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>

      • setInput

        public void setInput​(org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> input)
        Specified by:
        setInput in interface Input<org.apache.spark.api.java.JavaPairRDD<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>

      • getOptions

        public Map<String,​String> getOptions()
        Specified by:
        getOptions in interface Operation
        Returns:
        the operation options. This may contain store specific options such as authorisation strings or and other properties required for the operation to be executed. Note these options will probably not be interpreted in the same way by every store implementation.

      • setOptions

        public void setOptions​(Map<String,​String> options)
        Specified by:
        setOptions in interface Operation
        Parameters:
        options - the operation options. This may contain store specific options such as authorisation strings or and other properties required for the operation to be executed. Note these options will probably not be interpreted in the same way by every store implementation.

      • shallowClone

        public ImportKeyValueJavaPairRDDToAccumulo shallowClone()
        Description copied from interface: Operation
        Operation implementations should ensure a ShallowClone method is implemented. Performs a shallow clone. Creates a new instance and copies the fields across. It does not clone the fields. If the operation contains nested operations, these must also be cloned.
        Specified by:
        shallowClone in interface Operation
        Returns:
        shallow clone