public class CassandraPathTrackingDataStore extends BatchPathTrackingDataStore implements PathTrackingDataStore, CollectorPathTrackingDataStore
org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer
Modifier and Type | Field and Description |
---|---|
protected static ExecutorService |
EXECUTORSERVICE |
scheduledTask
Constructor and Description |
---|
CassandraPathTrackingDataStore() |
Modifier and Type | Method and Description |
---|---|
protected String |
getFamily() |
protected me.prettyprint.hector.api.Keyspace |
getKeyspace() |
protected String |
id(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry) |
protected void |
pushEntriesByBatch(Map<String,List<org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer>> pathTrackingEntries) |
Collection<org.apache.sirona.pathtracking.PathTrackingEntry> |
retrieve(String trackingId)
ordered by level!
|
Collection<org.apache.sirona.pathtracking.PathTrackingEntry> |
retrieve(String trackingId,
int number) |
Collection<org.apache.sirona.pathtracking.PathTrackingEntry> |
retrieve(String trackingId,
String start,
String end) |
Map<String,Set<org.apache.sirona.pathtracking.PathTrackingEntry>> |
retrieveAll()
use with CAUTION as can return a lot of data
This method is use for testing purpose
|
Collection<org.apache.sirona.pathtracking.PathCallInformation> |
retrieveTrackingIds(Date startTime,
Date endTime) |
void |
store(Collection<org.apache.sirona.pathtracking.PathTrackingEntry> pathTrackingEntries) |
void |
store(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry) |
getPeriod, initBatch
clearEntries, getPathTrackingEntries, getPointers, readBytes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearEntries
protected static ExecutorService EXECUTORSERVICE
public void store(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry)
store
in interface PathTrackingDataStore
store
in class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore
public void store(Collection<org.apache.sirona.pathtracking.PathTrackingEntry> pathTrackingEntries)
store
in interface PathTrackingDataStore
store
in class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore
protected String id(org.apache.sirona.pathtracking.PathTrackingEntry pathTrackingEntry)
public Collection<org.apache.sirona.pathtracking.PathTrackingEntry> retrieve(String trackingId)
retrieve
in interface PathTrackingDataStore
retrieve
in class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore
trackingId
- public Collection<org.apache.sirona.pathtracking.PathTrackingEntry> retrieve(String trackingId, int number)
retrieve
in interface PathTrackingDataStore
retrieve
in class AbstractPathTrackingDataStore
public Collection<org.apache.sirona.pathtracking.PathTrackingEntry> retrieve(String trackingId, String start, String end)
retrieve
in interface PathTrackingDataStore
retrieve
in class AbstractPathTrackingDataStore
public Collection<org.apache.sirona.pathtracking.PathCallInformation> retrieveTrackingIds(Date startTime, Date endTime)
retrieveTrackingIds
in interface PathTrackingDataStore
retrieveTrackingIds
in class org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore
public Map<String,Set<org.apache.sirona.pathtracking.PathTrackingEntry>> retrieveAll()
This method is use for testing purpose
List
containing all PathTrackingEntry
protected void pushEntriesByBatch(Map<String,List<org.apache.sirona.store.memory.tracking.InMemoryPathTrackingDataStore.Pointer>> pathTrackingEntries)
pushEntriesByBatch
in class BatchPathTrackingDataStore
protected me.prettyprint.hector.api.Keyspace getKeyspace()
protected String getFamily()
Copyright © 2008–2016 The Apache Software Foundation. All rights reserved.