Потоковая передача данных в R

#r #cluster-analysis

#r #кластерный анализ

Вопрос:

Может ли кто-нибудь детализировать и устранить проблему с потоковой передачей данных в R. следующий код состоит из пакета, установленного с помощью stream, streamMOA, ff, devtools. я получаю нулевые микрокластеры и нулевой макрокластер, который показан. может ли кто-нибудь помочь мне?

 k <- read.table("three hours from 11am 16_08_2016_data.txt",col.names=c("H", "T"))
myffdf <- as.ffdf(k) 
myffdf <- myffdf[c("H","T")] 
mydatastream <- DSD_FFDFstream(x = myffdf, k = 100, loop=TRUE) 
mydatastream 
FF Data Stream 
Class: DSD_FFDFstream, DSD_R, DSD 
With 100 clusters in 2 dimensions Contains 5400 data points - currently at position 1 - loop is TRUE 

#### Cluster (first part) > myclusteringmodel <- DSC_CluStream(k = 10) 
myclusteringmodel 
CluStream   k-Means (weighted) 
Class: DSC_TwoStage, DSC_Macro, DSC Number of micro-clusters: 0 Number of macro-clusters: 0 

kmeans <- DSC_Kmeans(3) > recluster(kmeans, myclusteringmodel) 
myclusteringmodel 

CluStream   k-Means (weighted) 
Class: DSC_TwoStage, DSC_Macro, DSC Number of micro-clusters: 0 Number of macro-clusters: 0
  

Комментарии:

1. примечание: микро- и макрокластеры равны нулю

2. Мне кажется, это вопрос программирования, поэтому он лучше подходит для stackoverflow. Также, в качестве совета: попробуйте расширить то, что вы пробовали при решении этой проблемы. Что вы хотите, чтобы этот код делал? Являются ли промежуточные значения в этом коде такими, какими вы их ожидаете видеть? Можете ли вы найти меньший пример кода, который показывает проблему?

3. поток <- DSD_ReadCSV(«test.csv», заголовок = TRUE,sep=»,») кластерный поток <- DSC_CluStream(m=50) обновление (кластерный поток, stream, 500)

4. предыдущий — это код, а следующий — ошибка из-за ошибки обновления в .jcall(«StreamMOA», «V», «update», object $ javaObj,.jarray(как.matrix(d), :

5. Хорошо, это намного лучше. 3 строки кода и сообщения об ошибках. Не могли бы вы добавить это к вашему первоначальному вопросу? И это все сообщение об ошибке, которое вы получили? Было ли указано что-нибудь о том, что это была за ошибка?