Modifier and Type | Method and Description |
---|---|
NullValue |
NullValueSerializer.copy(NullValue from) |
NullValue |
NullValueSerializer.copy(NullValue from,
NullValue reuse) |
NullValue |
NullValueSerializer.createInstance() |
NullValue |
NullValueSerializer.deserialize(DataInputView source) |
NullValue |
NullValueSerializer.deserialize(NullValue reuse,
DataInputView source) |
NullValue |
NullValueComparator.readWithKeyDenormalization(NullValue reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<NullValue> |
NullValueComparator.duplicate() |
Modifier and Type | Method and Description |
---|---|
int |
NullValueComparator.compare(NullValue first,
NullValue second) |
NullValue |
NullValueSerializer.copy(NullValue from) |
NullValue |
NullValueSerializer.copy(NullValue from,
NullValue reuse) |
NullValue |
NullValueSerializer.deserialize(NullValue reuse,
DataInputView source) |
boolean |
NullValueComparator.equalToReference(NullValue candidate) |
int |
NullValueComparator.hash(NullValue record) |
void |
NullValueComparator.putNormalizedKey(NullValue record,
MemorySegment target,
int offset,
int numBytes) |
NullValue |
NullValueComparator.readWithKeyDenormalization(NullValue reuse,
DataInputView source) |
void |
NullValueSerializer.serialize(NullValue record,
DataOutputView target) |
void |
NullValueComparator.setReference(NullValue toCompare) |
void |
NullValueComparator.writeWithKeyNormalization(NullValue record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
int |
NullValueComparator.compareToReference(TypeComparator<NullValue> referencedComparator) |
Modifier and Type | Field and Description |
---|---|
static ValueTypeInfo<NullValue> |
ValueTypeInfo.NULL_VALUE_TYPE_INFO |
Modifier and Type | Method and Description |
---|---|
<K,EV> Graph<K,NullValue,EV> |
GraphCsvReader.edgeTypes(Class<K> vertexKey,
Class<EV> edgeValue)
Creates a Graph from CSV input with edge values, but without vertex values.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromCollection(Collection<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a Collection of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<Tuple2<K,K>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<Tuple2<K,K>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for edges.
|
static <K,VV> Graph<K,VV,NullValue> |
Graph.fromTuple2DataSet(DataSet<Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromTupleDataSet(DataSet<Tuple3<K,K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple3 objects for edges.
|
Graph<K,NullValue,EV> |
Graph.intersect(Graph<K,VV,EV> graph,
boolean distinctEdges)
Performs intersect on the edge sets of the input graphs.
|
<K> Graph<K,NullValue,NullValue> |
GraphCsvReader.keyType(Class<K> vertexKey)
Creates a Graph from CSV input without vertex values or edge values.
|
<K> Graph<K,NullValue,NullValue> |
GraphCsvReader.keyType(Class<K> vertexKey)
Creates a Graph from CSV input without vertex values or edge values.
|
<K,VV> Graph<K,VV,NullValue> |
GraphCsvReader.vertexTypes(Class<K> vertexKey,
Class<VV> vertexValue)
Creates a Graph from CSV input without edge values.
|
Modifier and Type | Method and Description |
---|---|
void |
MusicProfiles.GetTopSongPerUser.iterateEdges(Vertex<String,NullValue> vertex,
Iterable<Edge<String,Integer>> edges,
Collector<Tuple2<String,String>> out) |
void |
MusicProfiles.CreateSimilarUserEdges.reduce(Iterable<Edge<String,Integer>> edges,
Collector<Edge<String,NullValue>> out) |
Modifier and Type | Method and Description |
---|---|
static DataSet<Edge<Long,NullValue>> |
ConnectedComponentsDefaultData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Edge<Long,NullValue>> |
TriangleCountData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Edge<Long,NullValue>> |
LabelPropagationData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Edge<Long,NullValue>> |
HITSData.getEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Edge<Long,NullValue>> |
SummarizationData.getEdgesWithAbsentValues(ExecutionEnvironment env)
Creates a set of edges with
NullValue as edge value. |
static DataSet<Edge<Long,NullValue>> |
LabelPropagationData.getTieEdgeDataSet(ExecutionEnvironment env) |
Modifier and Type | Method and Description |
---|---|
static DataSet<Edge<Long,NullValue>> |
ExampleUtils.getRandomEdges(ExecutionEnvironment env,
long numVertices) |
static DataSet<Vertex<Long,NullValue>> |
ExampleUtils.getVertexIds(ExecutionEnvironment env,
long numVertices) |
Modifier and Type | Method and Description |
---|---|
void |
StarGraph.LinkVertexToCenter.flatMap(LongValue leaf,
Collector<Edge<LongValue,NullValue>> out) |
void |
GridGraph.LinkVertexToNeighbors.flatMap(LongValue source,
Collector<Edge<LongValue,NullValue>> out) |
void |
CompleteGraph.LinkVertexToAll.flatMap(LongValue source,
Collector<Edge<LongValue,NullValue>> out) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple2<K,Either<NullValue,Message>>> |
VertexCentricIteration.MessageCombinerUdf.getProducedType() |
Modifier and Type | Method and Description |
---|---|
void |
VertexCentricIteration.MessageCombinerUdf.combine(Iterable<Tuple2<K,Either<NullValue,Message>>> values,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.combine(Iterable<Tuple2<K,Either<NullValue,Message>>> values,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.reduce(Iterable<Tuple2<K,Either<NullValue,Message>>> messages,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
void |
VertexCentricIteration.MessageCombinerUdf.reduce(Iterable<Tuple2<K,Either<NullValue,Message>>> messages,
Collector<Tuple2<K,Either<NullValue,Message>>> out) |
Modifier and Type | Method and Description |
---|---|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$23,
scala.reflect.ClassTag<K> evidence$24,
TypeInformation<EV> evidence$25,
scala.reflect.ClassTag<EV> evidence$26)
Creates a Graph from a Seq of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$23,
scala.reflect.ClassTag<K> evidence$24,
TypeInformation<EV> evidence$25,
scala.reflect.ClassTag<EV> evidence$26)
Creates a Graph from a Seq of edges.
|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$7,
scala.reflect.ClassTag<K> evidence$8,
TypeInformation<EV> evidence$9,
scala.reflect.ClassTag<EV> evidence$10)
Creates a Graph from a DataSet of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$7,
scala.reflect.ClassTag<K> evidence$8,
TypeInformation<EV> evidence$9,
scala.reflect.ClassTag<EV> evidence$10)
Creates a Graph from a DataSet of edges.
|
<K> Graph<K,NullValue,NullValue> |
Graph$.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
<K> Graph<K,NullValue,NullValue> |
Graph$.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
<K,VV> Graph<K,VV,NullValue> |
Graph$.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$51,
scala.reflect.ClassTag<K> evidence$52,
TypeInformation<VV> evidence$53,
scala.reflect.ClassTag<VV> evidence$54)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
static <K,VV> Graph<K,VV,NullValue> |
Graph.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$51,
scala.reflect.ClassTag<K> evidence$52,
TypeInformation<VV> evidence$53,
scala.reflect.ClassTag<VV> evidence$54)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$39,
scala.reflect.ClassTag<K> evidence$40,
TypeInformation<EV> evidence$41,
scala.reflect.ClassTag<EV> evidence$42)
Creates a Graph from a DataSet of Tuples representing the edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$39,
scala.reflect.ClassTag<K> evidence$40,
TypeInformation<EV> evidence$41,
scala.reflect.ClassTag<EV> evidence$42)
Creates a Graph from a DataSet of Tuples representing the edges.
|
Graph<K,NullValue,EV> |
Graph.intersect(Graph<K,VV,EV> graph,
boolean distinctEdges)
Performs intersect on the edge sets of the input graphs.
|
Modifier and Type | Method and Description |
---|---|
NullValue |
NullValueEdgeMapper.map(Edge<K,EV> edge) |
Modifier and Type | Method and Description |
---|---|
NullValue |
NullValue.copy() |
static NullValue |
NullValue.getInstance()
Returns the NullValue singleton instance.
|
Modifier and Type | Method and Description |
---|---|
int |
NullValue.compareTo(NullValue o) |
void |
NullValue.copyTo(NullValue target) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.