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

Class ImportKeyValuePairRDDToAccumulo

  • All Implemented Interfaces:
    Closeable, AutoCloseable, Input<org.apache.spark.rdd.RDD<scala.Tuple2<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>>, Operation
    public class ImportKeyValuePairRDDToAccumulo
extends Object
implements Input<org.apache.spark.rdd.RDD<scala.Tuple2<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>>

    • Constructor Detail

      • ImportKeyValuePairRDDToAccumulo

        public ImportKeyValuePairRDDToAccumulo()

    • Method Detail

      • getOutputPath

        public String getOutputPath()

      • setOutputPath

        public void setOutputPath​(String outputPath)

      • setFailurePath

        public void setFailurePath​(String failurePath)

      • getFailurePath

        public String getFailurePath()

      • getInput

        public org.apache.spark.rdd.RDD<scala.Tuple2<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>> getInput()
        Specified by:
        getInput in interface Input<org.apache.spark.rdd.RDD<scala.Tuple2<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>>>

      • setInput

        public void setInput​(org.apache.spark.rdd.RDD<scala.Tuple2<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>> input)
        Specified by:
        setInput in interface Input<org.apache.spark.rdd.RDD<scala.Tuple2<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 ImportKeyValuePairRDDToAccumulo 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