빅 데이터 시스템 과 대규모 데이터 분석의 작업 3
빅 데이터 시스템 과 대규모 데이터 분석의 작업 3
문제 설명
작업 3: 동기 화 그림 연산 프로 그래 밍
SSSP 프로 그래 밍
function Dijkstra(Graph, source):
dist[source] = 0 //Distance from source to source
prev[source] = undefined
for each vertex v in Graph:
if v != source:
dist[v] = inf
prev[v] = undefined
add v to Q // Q = unvisited nodes
while Q is not empty:
u = vertex in Q with min dist[u] // source node in first case
remove u from Q
for each neighbor v of u:
alt = dist[u] + length(u, v)
if alt < dist[v]:
dist[v] = alt
prev[v] = u
return dist[], prev[]struct edge { int to, length; };
int dijkstra(const vector< vector프로그램 소스 코드
#include
#include "GraphLite.h"
#define VERTEX_CLASS_NAME(name) SSSP##name
#define EPS 1e-6
#include::max())
#define INF INT_MAX
int v0_id; // source_id
class VERTEX_CLASS_NAME(InputFormatter): public InputFormatter {
public:
int64_t getVertexNum() {
unsigned long long n;
sscanf(m_ptotal_vertex_line, "%lld", &n);
m_total_vertex= n;
return m_total_vertex;
}
int64_t getEdgeNum() {
unsigned long long n;
sscanf(m_ptotal_edge_line, "%lld", &n);
m_total_edge= n;
return m_total_edge;
}
int getVertexValueSize() {
m_n_value_size = sizeof(double);
return m_n_value_size;
}
int getEdgeValueSize() {
m_e_value_size = sizeof(double);
return m_e_value_size;
}
int getMessageValueSize() {
m_m_value_size = sizeof(double);
return m_m_value_size;
}
void loadGraph() {
unsigned long long last_vertex;
unsigned long long from;
unsigned long long to;
double weight = 0;
double value = 1;
int outdegree = 0;
const char *line= getEdgeLine();
// Note: modify this if an edge weight is to be read
// modify the 'weight' variable
sscanf(line, "%lld %lld %lf", &from, &to, &weight);
addEdge(from, to, &weight);
last_vertex = from;
++outdegree;
for (int64_t i = 1; i < m_total_edge; ++i) {
line= getEdgeLine();
// Note: modify this if an edge weight is to be read
// modify the 'weight' variable
sscanf(line, "%lld %lld %lf", &from, &to, &weight);
if (last_vertex != from) {
addVertex(last_vertex, &value, outdegree);
last_vertex = from;
outdegree = 1;
} else {
++outdegree;
}
addEdge(from, to, &weight);
}
addVertex(last_vertex, &value, outdegree);
}
};
class VERTEX_CLASS_NAME(OutputFormatter): public OutputFormatter {
public:
void writeResult() {
int64_t vid;
double value;
char s[1024];
for (ResultIterator r_iter; ! r_iter.done(); r_iter.next() ) {
r_iter.getIdValue(vid, &value);
int n = sprintf(s, "%lld: %d
", (unsigned long long)vid, (int)value);
writeNextResLine(s, n);
}
}
};
// An aggregator that records a double value tom compute sum
class VERTEX_CLASS_NAME(Aggregator): public Aggregator<double> {
public:
void init() {
m_global = 0;
m_local = 0;
}
void* getGlobal() {
return &m_global;
}
void setGlobal(const void* p) {
m_global = * (double *)p;
}
void* getLocal() {
return &m_local;
}
void merge(const void* p) {
m_global += * (double *)p;
}
void accumulate(const void* p) {
m_local += * (double *)p;
}
};
class VERTEX_CLASS_NAME(): public Vertex <double, double, double> {
public:
void compute(MessageIterator* pmsgs) {
int val;
int source_id = (int)v0_id;
//if(getSuperstep() == 0){
if ((double)getVertexId() == source_id){
val = 0;
//printf("12312312312312111111111111");
} else {
val = INF;
}
//printf(" 12 %lf", (double)getVertexId());
//if (getSuperstep() == 0) {
//val= 10000;
// sendMessageToAllNeighbors(val);
//} else {
if (getSuperstep() >= 50) {
double global_val = * (double *)getAggrGlobal(0);
if (global_val < EPS) {
voteToHalt(); return;
}
}
//printf("!!!!!!!msg value %f
", (double)pmsgs->getValue());
for ( ; ! pmsgs->done(); pmsgs->next() ) {
//sum += pmsgs->getValue();
if (pmsgs->getValue() < val){
val = pmsgs->getValue();
/*if (1 == getVertexId()){
printf("this %lf",(double)pmsgs->getValue());} */
}
/* if(1==getVertexId()){
printf("testttttt %f",(double)val);}*/
}
// if(1==getVertexId()){printf("%f
",(double)val);}
//printf("the getValue()= %f
",(double)getValue());
if((val < getValue())|| getSuperstep() == 0)
{
if(1==getVertexId()){printf("%f
",(double)val);}
printf("getValue() = %f
",(double)getValue());
* mutableValue() = val;
//double acc = fabs(getValue() - val);
//accumulateAggr(0, &acc);
OutEdgeIterator otherEdge = getOutEdgeIterator();
for (; ! otherEdge.done(); otherEdge.next()){
double vertex_id = otherEdge.target();
double edge_value = otherEdge.getValue();
//sendMessageTo(vertex_id, val + edge_value);
//printf("the edge_value: %f
", (double)edge_value);
/*if ( getVertexId() == 0){
printf("the vertex_id:%f
", (double)vertex_id);
}*/
//if (vertex_id == source_id) {
// val = 0;
// //* mutableValue() = val;
// sendMessageTo(vertex_id, val + edge_value);
// //printf("111: %lf", (double)val);
//} else {
sendMessageTo(vertex_id, val + edge_value);
//}
}
}
// * mutableValue() = val;
//if(getVertexId() < 4){printf("
%lf here is %lf
",(double)getVertexId(),(double)val);}
//const int64_t n = getOutEdgeIterator().size();
//sendMessageToAllNeighbors(val / n);
//printf("the end msg value %d", (int)pmsgs->getValue());
voteToHalt();
}
};
class VERTEX_CLASS_NAME(Graph): public Graph {
public:
VERTEX_CLASS_NAME(Aggregator)* aggregator;
public:
// argv[0]: PageRankVertex.so
// argv[1]:
// argv[2]:
// argv[3]: 이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Spark 의 -- Spark Submit 제출 프로그램 상세 설명이 스 크 립 트 는 Spark 류 경로 (classpath) 와 응용 프로그램 의존 패 키 지 를 설정 할 수 있 고 서로 다른 Spark 가 지원 하 는 클 러 스 터 관리 와 배치 모드 를 설정 할 수 있 습 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
