[GitHub] MrDLontheway edited a comment on issue #739: accumulo 1.9.2 TabletClientService:sendBaseOneway method not found

[GitBox <gi...@apache.org>]

MrDLontheway edited a comment on issue #739: accumulo 1.9.2  TabletClientService:sendBaseOneway method not found
URL: https://github.com/apache/accumulo/issues/739#issuecomment-434892412
 
 
   i use spark 1.6 and hadoop 2.6 accumulo 1.9.2
   
   @milleruntime 
   ```
   package com.wxstc.dl;
   
   import com.boozallen.cognition.spark.accumulo.AccumuloSpark;
   import com.wxstc.dl.accumulo.AccumuloConnector;
   import org.apache.accumulo.core.client.ClientConfiguration;
   import org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat;
   import org.apache.accumulo.core.client.security.tokens.PasswordToken;
   import org.apache.accumulo.core.data.Key;
   import org.apache.accumulo.core.data.Value;
   import org.apache.accumulo.core.security.Authorizations;
   import org.apache.accumulo.core.util.PeekingIterator;
   import org.apache.hadoop.conf.Configuration;
   import org.apache.hadoop.io.Text;
   import org.apache.hadoop.mapreduce.Job;
   import org.apache.spark.SparkConf;
   import org.apache.spark.api.java.JavaPairRDD;
   import org.apache.spark.api.java.JavaSparkContext;
   import scala.Tuple2;
   
   import java.io.IOException;
   import java.util.List;
   import java.util.Map;
   
   
   public class MyAccumuloSpark {
       public static void main(String[] args) throws Exception {
   //        SparkSession spark = SparkSession.builder().master("local[*]").appName("Test").getOrCreate();
   //        final JavaSparkContext ctx = JavaSparkContext.fromSparkContext(spark.sparkContext());
   
           SparkConf conf = new SparkConf().setAppName("Test").setMaster("local[*]");
   //		conf.set("spark.driver.extraClassPath", "/data/ojdbc14-10.2.0.3.0.jar");
   //        conf.set("spark.executor.extraClassPath", "/data/ojdbc14-10.2.0.3.0.jar");
           JavaSparkContext sparkContext = new JavaSparkContext(conf);
   
           Job job = new Job(sparkContext.hadoopConfiguration());
           AccumuloInputFormat.setScanAuthorizations(job, new Authorizations("vis22","vis1"));
           AccumuloInputFormat.setConnectorInfo(job, "root", new PasswordToken("123456"));
           AccumuloInputFormat.setZooKeeperInstance(job,
                   ClientConfiguration.loadDefault().withInstance(AccumuloConnector.instanceName).withZkHosts(AccumuloConnector.zooServers));
           AccumuloInputFormat.setInputTableName(job,"table1");
   
   //        JavaPairRDD<Text, PeekingIterator<java.util.Map.Entry<Key, Value>>> accrdd = sparkContext.newAPIHadoopRDD(sparkContext.hadoopConfiguration(),
   //                AccumuloInputFormat.class, Text.class,PeekingIterator<java.util.Map.Entry<Key, Value>>);
   
           JavaPairRDD<Key, Value> keyValueJavaPairRDD = sparkContext.newAPIHadoopRDD(job.getConfiguration(),
                   AccumuloInputFormat.class, Key.class, Value.class);
           List<Tuple2<Key, Value>> collect = keyValueJavaPairRDD.collect();
   
           for (Tuple2<Key, Value> t2:
           collect) {
               Key k = t2._1;
               Value b = t2._2;
               System.out.println("key:"+k.toString());
               System.out.println("Value:"+b.toString());
           }
           sparkContext.stop();
       }
   
   }
   
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services