Package com.basho.riak.client.bucket

Examples of com.basho.riak.client.bucket.Bucket.store()

54
55
56
57
58
59
60
61
62
63
64
                storedMetricHour = new BasicMetricHour(guiPath, accountName, hoursSince1970, valueType.toString(), unitType.toString());
            }

            storedMetricHour.addStatistic(new BasicLiveStatistics(guiPath, accountName, timeperiod, valueDouble, valueType.value(), unitType.value(), count));

            myBucket.store("" + guiPath, storedMetricHour).execute();
        } catch (RiakRetryFailedException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
    }
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
  @Override
  public void persistGroupInstrumentation(GroupedStatistics groupedStatistics) {
    Bucket myBucket = null;
        try {
            myBucket = riakClient.fetchBucket("Grouped Statistics;" + groupedStatistics.getAccountName()).execute();
            myBucket.store(groupedStatistics.getName(), groupedStatistics).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }

  }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
 
  public static <E> void persistObjectInBucket(IRiakClient riakClient, String bucketName, String key, E type) {
    Bucket bucket = null;
    try {
      bucket = riakClient.fetchBucket(bucketName).execute();
      bucket.store(key, type).execute();
    } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
  }
 
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
    @Override
    public void persistAlert(Alert alert) {
        Bucket myBucket = null;
        try {
            myBucket = riakClient.fetchBucket("Alert;" + alert.getAccountName()).execute();
            myBucket.store(alert.getAlertName(), alert).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
    }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
    @Override
    public void persistTriggeredAlert(TriggeredAlert triggeredAlert) {
        Bucket myBucket = null;
        try {
            myBucket = riakClient.fetchBucket("Triggered_Alert;" + triggeredAlert.getAccountName()).execute();
            myBucket.store(triggeredAlert.getAlertName() + ";" + triggeredAlert.getTimeperiod(), triggeredAlert).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
    }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
  @Override
  public void persistAccount(Account account) {
    Bucket myBucket = null;
        try {
            myBucket = riakClient.fetchBucket("Account").execute();
            myBucket.store(this.encodeUri(account.getId()), account).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
  }
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
  @Override
  public void persistUser(User user) {
    Bucket myBucket = null;
        try {
            myBucket = riakClient.fetchBucket("User;" + this.encodeUri(user.getUserName())).execute();
            myBucket.store(this.encodeUri(user.getAccountName()), new BasicUser(user)).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }   
  }
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
  public void persistSession(Session session) {
    logger.info("persisting session: " + session.getUuid());
    Bucket myBucket = null;
        try {
          myBucket = riakClient.fetchBucket("Session").execute();
          myBucket.store(this.encodeUri(session.getUuid()), new BasicSession(session)).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
  }
 
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
  @Override
  public void persistAccessToken(AccessToken accessToken) {
    Bucket myBucket = null;
        try {
          myBucket = riakClient.fetchBucket("AccessToken").execute();
          myBucket.store(this.encodeUri(accessToken.getId()), new BasicAccessToken(accessToken)).execute();
        } catch (RiakRetryFailedException rrfe) {
            rrfe.printStackTrace();
        }
  }
 
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
    public void run() {
        for (BasicMetricHour metricHour : metricHourList) {
            Bucket mhBucket = null;
            try {
                mhBucket = riakClient.fetchBucket(metricHour.getAccountName() + ";" + metricHour.getHoursSince1970()).execute();
                mhBucket.store("" + metricHour.getGuiPath(), metricHour).execute();
            } catch (RiakRetryFailedException rrfe) {
                rrfe.printStackTrace();
            }
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.