This project has retired. For details please refer to its
Attic page.
MappingInputSplitsCallableFactory xref
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.giraph.worker;
20
21 import org.apache.giraph.conf.ImmutableClassesGiraphConfiguration;
22 import org.apache.giraph.graph.VertexEdgeCount;
23 import org.apache.giraph.io.MappingInputFormat;
24 import org.apache.giraph.utils.CallableFactory;
25 import org.apache.hadoop.io.Writable;
26 import org.apache.hadoop.io.WritableComparable;
27 import org.apache.hadoop.mapreduce.Mapper;
28
29
30
31
32
33
34
35
36
37 public class MappingInputSplitsCallableFactory<I extends WritableComparable,
38 V extends Writable, E extends Writable, B extends Writable>
39 implements CallableFactory<VertexEdgeCount> {
40
41 private final MappingInputFormat<I, V, E, B> mappingInputFormat;
42
43 private final Mapper<?, ?, ?, ?>.Context context;
44
45 private final ImmutableClassesGiraphConfiguration<I, V, E> configuration;
46
47 private final BspServiceWorker<I, V, E> bspServiceWorker;
48
49 private final WorkerInputSplitsHandler splitsHandler;
50
51
52
53
54
55
56
57
58
59
60 public MappingInputSplitsCallableFactory(
61 MappingInputFormat<I, V, E, B> mappingInputFormat,
62 Mapper<?, ?, ?, ?>.Context context,
63 ImmutableClassesGiraphConfiguration<I, V, E> configuration,
64 BspServiceWorker<I, V, E> bspServiceWorker,
65 WorkerInputSplitsHandler splitsHandler) {
66 this.mappingInputFormat = mappingInputFormat;
67 this.context = context;
68 this.configuration = configuration;
69 this.bspServiceWorker = bspServiceWorker;
70 this.splitsHandler = splitsHandler;
71 }
72
73 @Override
74 public InputSplitsCallable<I, V, E> newCallable(int threadId) {
75 return new MappingInputSplitsCallable<>(
76 mappingInputFormat,
77 context,
78 configuration,
79 bspServiceWorker,
80 splitsHandler);
81 }
82 }