Advertisement
Guest User

Untitled

a guest
Feb 27th, 2017
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.93 KB | None | 0 0
  1. SparkSession spark = SparkSession.builder().appName("Test").getOrCreate();
  2. Encoder<cR> cREncoder = Encoders.bean(cR.class);
  3.  
  4. cR cR1 = new cR (4.5, new c("abc"));
  5. cR cR2 = new cR(5.5, new c("xyz"));
  6. List<cR > listcR = Arrays.asList (cR1,cR2);
  7.  
  8. Dataset<cR > cRData= spark.createDataset(listcR,cREncoder);
  9. System.out.println ("Duration in Main " + cR1.getDuration());
  10. System.out.println ("Duration in Main " + cR2.getDuration());
  11. cRData.printSchema();
  12. cRData.show();
  13.  
  14. public class cR implements java.io.Serializable {
  15. public double duration;
  16. // public Boolean version;
  17. public c _c;
  18.  
  19. public cR (double v, c cu) {
  20. this.duration = v;
  21. this._c = cu;
  22. // this.version = ver;
  23. System.out.println("Duration : " + this.duration);
  24. }
  25.  
  26. // getter setter methods for data member
  27. }
  28.  
  29. public class c implements java.io.Serializable {
  30. public String id;
  31.  
  32. public c (String s) {
  33. id= s;
  34. }
  35.  
  36. //getter and setters
  37.  
  38. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement