本文整理汇总了Java中org.md2k.datakitapi.datatype.DataTypeDoubleArray类的典型用法代码示例。如果您正苦于以下问题：Java DataTypeDoubleArray类的具体用法？Java DataTypeDoubleArray怎么用？Java DataTypeDoubleArray使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DataTypeDoubleArray类属于org.md2k.datakitapi.datatype包，在下文中一共展示了DataTypeDoubleArray类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: subscribe
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public void subscribe(String platformType, final String dataSourceType) throws DataKitException {
DataSourceClient dataSourceClient = findDataSourceClient(platformType, dataSourceType);
dataKitAPI.subscribe(dataSourceClient, new OnReceiveListener() {
@Override
public void onReceived(DataType dataType) {
try {
DataTypeDoubleArray dataTypeDoubleArray = (DataTypeDoubleArray) dataType;
CSVDataPoint csvDataPoint = new CSVDataPoint(dataSourceTypeTOChannel.get(dataSourceType), dataTypeDoubleArray.getDateTime(), dataTypeDoubleArray.getSample()[0]);
streamProcessorWrapper.addDataPoint(csvDataPoint);
} catch (Exception ignored) {
}
}
});
}
开发者ID:MD2Korg，项目名称:mCerebrum-StreamProcessor，代码行数:17，代码来源:DataKitManager.java
示例2: onSensorChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onSensorChanged(SensorEvent event) {
long curTime = DateTime.getDateTime();
if ((double)(curTime - lastSaved) > FILTER_DATA_MIN_TIME) {
lastSaved = curTime;
double[] samples = new double[3];
samples[DataFormat.Gyroscope.X] = event.values[0];
samples[DataFormat.Gyroscope.Y] = event.values[1];
samples[DataFormat.Gyroscope.Z] = event.values[2];
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(curTime, samples);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:20，代码来源:Gyroscope.java
示例3: saveData
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public void saveData(Location location) {
double samples[] = new double[6];
samples[DataFormat.Location.Latitude] = location.getLatitude();
samples[DataFormat.Location.Longitude] = location.getLongitude();
samples[DataFormat.Location.Altitude] = location.getAltitude();
samples[DataFormat.Location.Speed] = location.getSpeed();
samples[DataFormat.Location.Bearing] = location.getBearing();
samples[DataFormat.Location.Accuracy] = location.getAccuracy();
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(DateTime.getDateTime(), samples);
try {
dataKitAPI.insert(dataSourceClient, dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:17，代码来源:LocationFused.java
示例4: onSensorChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onSensorChanged(SensorEvent event) {
long curTime = DateTime.getDateTime();
if ((double)(curTime - lastSaved) > FILTER_DATA_MIN_TIME) {
lastSaved = curTime;
double[] samples = new double[3];
samples[DataFormat.Accelerometer.X] = event.values[0]/9.81;
samples[DataFormat.Accelerometer.Y] = event.values[1]/9.81;
samples[DataFormat.Accelerometer.Z] = event.values[2]/9.81;
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(curTime, samples);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:19，代码来源:Accelerometer.java
示例5: run
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void run() {
long values[] = new long[2];
readUsage(values);
double[] sample = new double[1];
sample[0] = (float) (values[1] - curValues[1]) / (float) ((values[1] + values[0]) - (curValues[1] + curValues[0]));
curValues = values;
DataTypeDoubleArray dataTypeDouble = new DataTypeDoubleArray(DateTime.getDateTime(), sample);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDouble);
callBack.onReceivedData(dataTypeDouble);
scheduler.postDelayed(statusCPU, 1000);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:19，代码来源:CPU.java
示例6: onSensorChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onSensorChanged(SensorEvent event) {
long curTime = DateTime.getDateTime();
if ((double)(curTime - lastSaved) > FILTER_DATA_MIN_TIME) {
lastSaved = curTime;
double[] samples = new double[3];
samples[DataFormat.Compass.X] = event.values[0];
samples[DataFormat.Compass.Y] = event.values[1];
samples[DataFormat.Compass.Z] = event.values[2];
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(curTime, samples);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:19，代码来源:Compass.java
示例7: onSensorChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onSensorChanged(SensorEvent event) {
int curTotalSteps = (int) event.values[0];
int curSteps=0;
if(prevTotalStep ==0){
prevTotalStep =curTotalSteps;
return;
}else{
curSteps = curTotalSteps- prevTotalStep;
prevTotalStep =curTotalSteps;
}
Log.d("abc", "total steps = "+ curTotalSteps+ " steps=" + curSteps);
long curTime = DateTime.getDateTime();
double[] samples = new double[]{curSteps};
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(curTime, samples);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDoubleArray);
dataKitAPI.setSummary(dataSourceClient, new DataTypeIntArray(curTime, new int[]{curSteps}));
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:25，代码来源:StepCount.java
示例8: onSensorChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onSensorChanged(SensorEvent event) {
long curTime = DateTime.getDateTime();
if ((double)(curTime - lastSaved) > FILTER_DATA_MIN_TIME) {
lastSaved = curTime;
double[] sample = new double[1];
sample[DataFormat.AmbientLight] = event.values[0];
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(DateTime.getDateTime(), sample);
try {
dataKitAPI.insertHighFrequency(dataSourceClient, dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
} catch (DataKitException e) {
LocalBroadcastManager.getInstance(context).sendBroadcast(new Intent(ServicePhoneSensor.INTENT_STOP));
}
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:17，代码来源:AmbientLight.java
示例9: notifyAllObservers
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public Status notifyAllObservers(DataType[] dataTypes, boolean highFrequency, boolean isUpdate) {
Status status = new Status(Status.SUCCESS);
if (databaseSubscriber != null) {
if (highFrequency) {
status = databaseSubscriber.insertHF(ds_id, (DataTypeDoubleArray[]) dataTypes);
} else {
status = databaseSubscriber.insert(ds_id, dataTypes, isUpdate);
}
}
for (Iterator<MessageSubscriber> iterator = messageSubscribers.iterator(); iterator.hasNext(); ) {
MessageSubscriber subscriber = iterator.next();
if (!subscriber.update(ds_id, dataTypes))
iterator.remove();
}
return status;
}
开发者ID:MD2Korg，项目名称:mCerebrum-DataKit，代码行数:18，代码来源:Publisher.java
示例10: onBandAltimeterChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onBandAltimeterChanged(BandAltimeterEvent bandAltimeterEvent) {
double samples[] = new double[9];
samples[0] = bandAltimeterEvent.getFlightsAscended();
samples[1] = bandAltimeterEvent.getFlightsDescended();
samples[2] = bandAltimeterEvent.getRate();
samples[3] = bandAltimeterEvent.getSteppingGain();
samples[4] = bandAltimeterEvent.getSteppingLoss();
samples[5] = bandAltimeterEvent.getStepsAscended();
samples[6] = bandAltimeterEvent.getStepsDescended();
samples[7] = bandAltimeterEvent.getTotalGain();
samples[8] = bandAltimeterEvent.getTotalLoss();
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(DateTime.getDateTime(), samples);
sendData(dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
}
开发者ID:MD2Korg，项目名称:mCerebrum-MicrosoftBand，代码行数:17，代码来源:Altimeter.java
示例11: onBandDistanceChanged
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
@Override
public void onBandDistanceChanged(final BandDistanceEvent event) {
double motionType = 0;
if (event.getMotionType().equals(com.microsoft.band.sensors.MotionType.IDLE))
motionType = 0;
else if (event.getMotionType().equals(com.microsoft.band.sensors.MotionType.UNKNOWN))
motionType = 1;
else if (event.getMotionType().equals(com.microsoft.band.sensors.MotionType.JOGGING))
motionType = 2;
else if (event.getMotionType().equals(com.microsoft.band.sensors.MotionType.WALKING))
motionType = 3;
else if (event.getMotionType().equals(com.microsoft.band.sensors.MotionType.RUNNING))
motionType = 4;
DataTypeDoubleArray dataTypeDoubleArray = new DataTypeDoubleArray(DateTime.getDateTime(), motionType);
sendData(dataTypeDoubleArray);
callBack.onReceivedData(dataTypeDoubleArray);
}
开发者ID:MD2Korg，项目名称:mCerebrum-MicrosoftBand，代码行数:18，代码来源:MotionType.java
示例12: createDataSourceBuilder
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public DataSourceBuilder createDataSourceBuilder() {
DataSourceBuilder dataSourceBuilder = super.createDataSourceBuilder();
if (dataSourceBuilder == null) return null;
dataSourceBuilder = dataSourceBuilder.setDataDescriptors(createDataDescriptor());
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.FREQUENCY, "0.0167 Hz");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.NAME, "cStress Feature Vector");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DESCRIPTION, "Represents the 37 features used by the cStress algorithm");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DATA_TYPE, DataTypeDoubleArray.class.getName());
return dataSourceBuilder;
}
开发者ID:MD2Korg，项目名称:mCerebrum-StreamProcessor，代码行数:11，代码来源:cStressFeatureVector.java
示例13: createDataSourceBuilder
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public DataSourceBuilder createDataSourceBuilder() {
DataSourceBuilder dataSourceBuilder = super.createDataSourceBuilder();
if (dataSourceBuilder == null) return null;
dataSourceBuilder = dataSourceBuilder.setDataDescriptors(createDataDescriptor());
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.FREQUENCY, "0.0167 Hz");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.NAME, "puffMarker Feature Vector");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DESCRIPTION, "Represents the 36 features used by the puffMarker algorithm");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DATA_TYPE, DataTypeDoubleArray.class.getName());
return dataSourceBuilder;
}
开发者ID:MD2Korg，项目名称:mCerebrum-StreamProcessor，代码行数:11，代码来源:puffMarkerFeatureVector.java
示例14: createDataSourceBuilder
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public DataSourceBuilder createDataSourceBuilder() {
DataSourceBuilder dataSourceBuilder = super.createDataSourceBuilder();
if (dataSourceBuilder == null) return null;
dataSourceBuilder = dataSourceBuilder.setDataDescriptors(createDataDescriptor());
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.FREQUENCY, "0.0167 Hz");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.NAME, "cStress Feature Vector (RIP)");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DESCRIPTION, "Represents the RIP-only features used by the cStress algorithm");
dataSourceBuilder = dataSourceBuilder.setMetadata(METADATA.DATA_TYPE, DataTypeDoubleArray.class.getName());
return dataSourceBuilder;
}
开发者ID:MD2Korg，项目名称:mCerebrum-StreamProcessor，代码行数:11，代码来源:cStressRIPFeatureVector.java
示例15: subscribeForThreeTuple
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
private void subscribeForThreeTuple(DataSourceClient dataSourceClient, final String platformId, final String dataSourceId, final int[] convertedAxis, final int[] convertedSign) throws DataKitException {
dataKitAPI.subscribe(dataSourceClient, new OnReceiveListener() {
@Override
public void onReceived(DataType dataType) {
try {
DataTypeDoubleArray dataTypeDoubleArray = (DataTypeDoubleArray) dataType;
CSVDataPoint csvDataPointx = null;
CSVDataPoint csvDataPointy = null;
CSVDataPoint csvDataPointz = null;
if (DataSourceType.ACCELEROMETER.equals(dataSourceId)) {
csvDataPointx = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.ACCELEROMETER_X), dataTypeDoubleArray.getDateTime(), convertedSign[0] * dataTypeDoubleArray.getSample()[convertedAxis[0]]);
csvDataPointy = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.ACCELEROMETER_Y), dataTypeDoubleArray.getDateTime(), convertedSign[1] * dataTypeDoubleArray.getSample()[convertedAxis[1]]);
csvDataPointz = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.ACCELEROMETER_Z), dataTypeDoubleArray.getDateTime(), convertedSign[2] * dataTypeDoubleArray.getSample()[convertedAxis[2]]);
} else if (DataSourceType.GYROSCOPE.equals(dataSourceId)) {
csvDataPointx = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.GYROSCOPE_X), dataTypeDoubleArray.getDateTime(), convertedSign[0] * dataTypeDoubleArray.getSample()[convertedAxis[0]]);
csvDataPointy = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.GYROSCOPE_Y), dataTypeDoubleArray.getDateTime(), convertedSign[1] * dataTypeDoubleArray.getSample()[convertedAxis[1]]);
csvDataPointz = new CSVDataPoint(dataSourceTypeTOChannel.get(platformId + "_" + DataSourceType.GYROSCOPE_Z), dataTypeDoubleArray.getDateTime(), convertedSign[2] * dataTypeDoubleArray.getSample()[convertedAxis[2]]);
}
streamProcessorWrapper.addDataPoint(csvDataPointx);
streamProcessorWrapper.addDataPoint(csvDataPointy);
streamProcessorWrapper.addDataPoint(csvDataPointz);
} catch (Exception ignored) {
}
}
});
}
开发者ID:MD2Korg，项目名称:mCerebrum-StreamProcessor，代码行数:29，代码来源:DataKitManager.java
示例16: insertHighFrequency
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public synchronized void insertHighFrequency(final DataSourceClient dataSourceClient, final DataTypeDoubleArray[] dataType) throws DataKitException {
if (!dataKitAPIExecute.isConnected())
throw new DataKitNotFoundException(new Status(Status.ERROR_BOUND));
if (dataSourceClient == null || dataType == null)
throw new DataKitException(new Status(Status.DATA_INVALID).getStatusMessage());
else {
for (DataTypeDoubleArray aDataType : dataType)
addToBuffer(dataSourceClient.getDs_id(), aDataType);
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-DataKitAPI，代码行数:11，代码来源:DataKitAPI.java
示例17: addToBuffer
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
synchronized void addToBuffer(int ds_id, DataTypeDoubleArray dataTypeDoubleArray) {
HFBuffer hfBuffer;
if (hmHFBuffer.containsKey(ds_id))
hfBuffer = hmHFBuffer.get(ds_id);
else
hfBuffer = new HFBuffer();
if(hfBuffer.size+dataTypeDoubleArray.getSample().length*8>=BUFFER_SIZE){
syncHFData(ds_id);
hfBuffer=hmHFBuffer.get(ds_id);
}
hfBuffer.data.add(dataTypeDoubleArray);
hfBuffer.size += dataTypeDoubleArray.getSample().length * 8;
hmHFBuffer.put(ds_id, hfBuffer);
}
开发者ID:MD2Korg，项目名称:mCerebrum-DataKitAPI，代码行数:16，代码来源:DataKitAPI.java
示例18: syncHFData
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
synchronized void syncHFData(int ds_id) {
HFBuffer hfBuffer = hmHFBuffer.get(ds_id);
if (hfBuffer.size == 0) return;
DataTypeDoubleArray[] dataTypeDoubleArrays = new DataTypeDoubleArray[hfBuffer.data.size()];
for (int i = 0; i < hfBuffer.data.size(); i++)
dataTypeDoubleArrays[i] = hfBuffer.data.get(i);
hfBuffer.data.clear();
hfBuffer.size = 0;
hmHFBuffer.put(ds_id, hfBuffer);
try {
dataKitAPIExecute.insertHighFrequency(ds_id, dataTypeDoubleArrays);
} catch (DataKitException ignored) {
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-DataKitAPI，代码行数:15，代码来源:DataKitAPI.java
示例19: insertHighFrequency
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
public void insertHighFrequency(int ds_id, final DataTypeDoubleArray[] dataTypes) throws DataKitException {
try {
lock();
Bundle bundle = new Bundle();
bundle.putParcelableArray(DataTypeDoubleArray.class.getSimpleName(), dataTypes);
bundle.putInt(Constants.RC_DSID, ds_id);
prepareAndSend(bundle, MessageType.INSERT_HIGH_FREQUENCY);
} catch (Exception e) {
throw new DataKitException(e.getCause());
} finally {
unlock();
}
}
开发者ID:MD2Korg，项目名称:mCerebrum-DataKitAPI，代码行数:14，代码来源:DataKitAPIExecute.java
示例20: updatePlot
import org.md2k.datakitapi.datatype.DataTypeDoubleArray; //导入依赖的package包/类
void updatePlot(Intent intent) {
float[] sample=new float[1];
String[] legends;
DataSource dataSource= intent.getParcelableExtra("datasource");
ArrayList<HashMap<String, String>> hm = dataSource.getDataDescriptors();
getmChart().getDescription().setText(dataSourceType);
getmChart().getDescription().setPosition(1f,1f);
getmChart().getDescription().setEnabled(true);
getmChart().getDescription().setTextColor(Color.WHITE);
legends=new String[hm.size()];
for(int i=0;i<hm.size();i++){
legends[i] = hm.get(i).get(METADATA.NAME);
}
String curDataSourceType = dataSource.getType();
if(!curDataSourceType.equals(dataSourceType)) return;
DataType data = intent.getParcelableExtra("data");
if (data instanceof DataTypeFloat) {
sample = new float[]{((DataTypeFloat) data).getSample()};
} else if (data instanceof DataTypeFloatArray) {
sample = ((DataTypeFloatArray) data).getSample();
} else if (data instanceof DataTypeDoubleArray) {
double[] samples = ((DataTypeDoubleArray) data).getSample();
sample=new float[samples.length];
for (int i = 0; i < samples.length; i++) {
sample[i]= (float) samples[i];
}
}
addEntry(sample, legends,600);
}
开发者ID:MD2Korg，项目名称:mCerebrum-PhoneSensor，代码行数:30，代码来源:ActivityPlot.java
注：本文中的org.md2k.datakitapi.datatype.DataTypeDoubleArray类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论