Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- SparkSession spark = SparkSession.builder().appName("Test").getOrCreate();
- Encoder<cR> cREncoder = Encoders.bean(cR.class);
- cR cR1 = new cR (4.5, new c("abc"));
- cR cR2 = new cR(5.5, new c("xyz"));
- List<cR > listcR = Arrays.asList (cR1,cR2);
- Dataset<cR > cRData= spark.createDataset(listcR,cREncoder);
- System.out.println ("Duration in Main " + cR1.getDuration());
- System.out.println ("Duration in Main " + cR2.getDuration());
- cRData.printSchema();
- cRData.show();
- public class cR implements java.io.Serializable {
- public double duration;
- // public Boolean version;
- public c _c;
- public cR (double v, c cu) {
- this.duration = v;
- this._c = cu;
- // this.version = ver;
- System.out.println("Duration : " + this.duration);
- }
- // getter setter methods for data member
- }
- public class c implements java.io.Serializable {
- public String id;
- public c (String s) {
- id= s;
- }
- //getter and setters
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement