Modifier and Type | Class and Description |
---|---|
class |
RichMapFunction<IN,OUT>
Rich variant of the
MapFunction . |
Modifier and Type | Class and Description |
---|---|
class |
MapOperatorBase<IN,OUT,FT extends MapFunction<IN,OUT>> |
Modifier and Type | Method and Description |
---|---|
<R> MapOperator<T,R> |
DataSet.map(MapFunction<T,R> mapper)
Applies a Map transformation on this DataSet.
The transformation calls a MapFunction for each element of the DataSet. |
Modifier and Type | Class and Description |
---|---|
class |
FormattingMapper<T> |
Modifier and Type | Field and Description |
---|---|
protected MapFunction<IN,OUT> |
MapOperator.function |
Modifier and Type | Method and Description |
---|---|
protected MapFunction<IN,OUT> |
MapOperator.getFunction() |
Modifier and Type | Method and Description |
---|---|
protected MapOperatorBase<IN,OUT,MapFunction<IN,OUT>> |
ProjectOperator.translateToDataFlow(Operator<IN> input) |
protected MapOperatorBase<IN,OUT,MapFunction<IN,OUT>> |
MapOperator.translateToDataFlow(Operator<IN> input) |
Constructor and Description |
---|
MapOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
MapFunction<IN,OUT> function,
String defaultName) |
Modifier and Type | Class and Description |
---|---|
class |
KeyExtractingMapper<T,K> |
class |
KeyRemovingMapper<T,K> |
static class |
PlanProjectOperator.MapProjector<T extends Tuple,R extends Tuple> |
class |
TwoKeyExtractingMapper<T,K1,K2> |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getMapReturnTypes(MapFunction<IN,OUT> mapInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
Modifier and Type | Method and Description |
---|---|
<R> DataSet<R> |
DataSet.map(MapFunction<T,R> mapper,
TypeInformation<R> evidence$2,
scala.reflect.ClassTag<R> evidence$3)
Creates a new DataSet by applying the given function to every element of this DataSet.
|
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.CentroidAverager
Computes new centroid from coordinate sum and count of points.
|
static class |
KMeans.CountAppender
Appends a count variable to the tuple.
|
static class |
KMeans.SelectNearestCenter
Determines the closest cluster center for a data point.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.DuplicateValue<T>
Function that turns a value into a 2-tuple where both fields are that value.
|
static class |
EnumTriangles.TupleEdgeConverter
Converts a Tuple2 into an Edge
|
static class |
PageRank.Dampener
The function that applies the page rank dampening formula
|
static class |
PageRank.RankAssigner
A map function that assigns an initial rank to all pages.
|
Modifier and Type | Class and Description |
---|---|
static class |
PiEstimation.Sampler
Sampler randomly emits points that fall within a square of edge x * y.
|
Modifier and Type | Class and Description |
---|---|
static class |
LinearRegression.SubUpdate
Compute a single BGD type update for every parameters.
|
static class |
LinearRegression.Update
Compute the final update by average them.
|
Modifier and Type | Field and Description |
---|---|
protected MapFunction<?,?> |
GraphCsvReader.mapper |
Modifier and Type | Method and Description |
---|---|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(Collection<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a Collection of edges.
|
static <K,VV> GraphCsvReader |
Graph.fromCsvReader(String edgesPath,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a CSV file of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of 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,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple3 objects for edges.
|
<NV> Graph<K,VV,NV> |
Graph.mapEdges(MapFunction<Edge<K,EV>,NV> mapper)
Apply a function to the attribute of each edge in the graph.
|
<NV> Graph<K,VV,NV> |
Graph.mapEdges(MapFunction<Edge<K,EV>,NV> mapper,
TypeInformation<Edge<K,NV>> returnType)
Apply a function to the attribute of each edge in the graph.
|
<NV> Graph<K,NV,EV> |
Graph.mapVertices(MapFunction<Vertex<K,VV>,NV> mapper)
Apply a function to the attribute of each vertex in the graph.
|
<NV> Graph<K,NV,EV> |
Graph.mapVertices(MapFunction<Vertex<K,VV>,NV> mapper,
TypeInformation<Vertex<K,NV>> returnType)
Apply a function to the attribute of each vertex in the graph.
|
Constructor and Description |
---|
GraphCsvReader(Path edgePath,
MapFunction<K,VV> mapper,
ExecutionEnvironment context) |
GraphCsvReader(String edgePath,
MapFunction<K,VV> mapper,
ExecutionEnvironment context) |
Modifier and Type | Class and Description |
---|---|
static class |
DegreeAnnotationFunctions.MapEdgeToSourceId<K,EV>
Emits the source vertex ID along with an initial count.
|
static class |
DegreeAnnotationFunctions.MapEdgeToTargetId<K,EV>
Emits the target vertex ID along with an initial count.
|
Modifier and Type | Class and Description |
---|---|
static class |
MusicProfiles.ExtractMismatchSongIds |
Modifier and Type | Class and Description |
---|---|
static class |
CommunityDetection.AddScoreToVertexValuesMapper<K> |
static class |
CommunityDetection.RemoveScoreFromVertexValuesMapper<K> |
static class |
GSASingleSourceShortestPaths.InitVerticesMapper<K,VV> |
static class |
SingleSourceShortestPaths.InitVerticesMapper<K,VV> |
Modifier and Type | Method and Description |
---|---|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$27,
scala.reflect.ClassTag<K> evidence$28,
TypeInformation<VV> evidence$29,
scala.reflect.ClassTag<VV> evidence$30,
TypeInformation<EV> evidence$31,
scala.reflect.ClassTag<EV> evidence$32)
Creates a graph from a Seq of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$27,
scala.reflect.ClassTag<K> evidence$28,
TypeInformation<VV> evidence$29,
scala.reflect.ClassTag<VV> evidence$30,
TypeInformation<EV> evidence$31,
scala.reflect.ClassTag<EV> evidence$32)
Creates a graph from a Seq of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromCsvReader(ExecutionEnvironment env,
String pathEdges,
String pathVertices,
String lineDelimiterVertices,
String fieldDelimiterVertices,
Character quoteCharacterVertices,
boolean ignoreFirstLineVertices,
String ignoreCommentsVertices,
boolean lenientVertices,
int[] includedFieldsVertices,
String lineDelimiterEdges,
String fieldDelimiterEdges,
Character quoteCharacterEdges,
boolean ignoreFirstLineEdges,
String ignoreCommentsEdges,
boolean lenientEdges,
int[] includedFieldsEdges,
MapFunction<K,VV> vertexValueInitializer,
TypeInformation<K> evidence$55,
scala.reflect.ClassTag<K> evidence$56,
TypeInformation<VV> evidence$57,
scala.reflect.ClassTag<VV> evidence$58,
TypeInformation<EV> evidence$59,
scala.reflect.ClassTag<EV> evidence$60)
Creates a Graph from a CSV file of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCsvReader(ExecutionEnvironment env,
String pathEdges,
String pathVertices,
String lineDelimiterVertices,
String fieldDelimiterVertices,
Character quoteCharacterVertices,
boolean ignoreFirstLineVertices,
String ignoreCommentsVertices,
boolean lenientVertices,
int[] includedFieldsVertices,
String lineDelimiterEdges,
String fieldDelimiterEdges,
Character quoteCharacterEdges,
boolean ignoreFirstLineEdges,
String ignoreCommentsEdges,
boolean lenientEdges,
int[] includedFieldsEdges,
MapFunction<K,VV> vertexValueInitializer,
TypeInformation<K> evidence$55,
scala.reflect.ClassTag<K> evidence$56,
TypeInformation<VV> evidence$57,
scala.reflect.ClassTag<VV> evidence$58,
TypeInformation<EV> evidence$59,
scala.reflect.ClassTag<EV> evidence$60)
Creates a Graph from a CSV file of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromDataSet(DataSet<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$11,
scala.reflect.ClassTag<K> evidence$12,
TypeInformation<VV> evidence$13,
scala.reflect.ClassTag<VV> evidence$14,
TypeInformation<EV> evidence$15,
scala.reflect.ClassTag<EV> evidence$16)
Creates a graph from a DataSet of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$11,
scala.reflect.ClassTag<K> evidence$12,
TypeInformation<VV> evidence$13,
scala.reflect.ClassTag<VV> evidence$14,
TypeInformation<EV> evidence$15,
scala.reflect.ClassTag<EV> evidence$16)
Creates a graph from a DataSet of 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,VV,EV> Graph<K,VV,EV> |
Graph$.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$43,
scala.reflect.ClassTag<K> evidence$44,
TypeInformation<VV> evidence$45,
scala.reflect.ClassTag<VV> evidence$46,
TypeInformation<EV> evidence$47,
scala.reflect.ClassTag<EV> evidence$48)
Creates a Graph from a DataSet of Tuples representing the edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$43,
scala.reflect.ClassTag<K> evidence$44,
TypeInformation<VV> evidence$45,
scala.reflect.ClassTag<VV> evidence$46,
TypeInformation<EV> evidence$47,
scala.reflect.ClassTag<EV> evidence$48)
Creates a Graph from a DataSet of Tuples representing the edges.
|
<NV> Graph<K,VV,NV> |
Graph.mapEdges(MapFunction<Edge<K,EV>,NV> mapper,
TypeInformation<NV> evidence$71,
scala.reflect.ClassTag<NV> evidence$72)
Apply a function to the attribute of each edge in the graph.
|
<NV> Graph<K,NV,EV> |
Graph.mapVertices(MapFunction<Vertex<K,VV>,NV> mapper,
TypeInformation<NV> evidence$67,
scala.reflect.ClassTag<NV> evidence$68)
Apply a function to the attribute of each vertex in the graph.
|
Modifier and Type | Class and Description |
---|---|
class |
EdgeToTuple3Map<K,EV>
Create a Tuple3 DataSet from an Edge DataSet
|
static class |
GraphUtils.MapTo<I,O>
Map each element to a value.
|
class |
NullValueEdgeMapper<K,EV> |
class |
Tuple2ToEdgeMap<K>
Create an Edge from a Tuple2.
|
class |
Tuple2ToVertexMap<K,VV>
Create a Vertex DataSet from a Tuple2 DataSet
|
class |
Tuple3ToEdgeMap<K,EV>
Create an Edge DataSet from a Tuple3 DataSet
|
class |
VertexToTuple2Map<K,VV>
Create a Tuple2 DataSet from a Vertex DataSet
|
Modifier and Type | Class and Description |
---|---|
class |
KeyDiscarder<T> |
class |
NestedKeyDiscarder<IN> |
class |
SerializerMap<IN> |
class |
StringDeserializerMap |
class |
StringTupleDeserializerMap |
Modifier and Type | Method and Description |
---|---|
Class<MapFunction<IT,OT>> |
MapDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
MapDriver.setup(TaskContext<MapFunction<IT,OT>,OT> context) |
Modifier and Type | Class and Description |
---|---|
class |
RemoveRangeIndex<T> |
Modifier and Type | Class and Description |
---|---|
static class |
SpoutSplitExample.Enrich
Same as
VerifyAndEnrichBolt . |
Modifier and Type | Class and Description |
---|---|
class |
SplitStreamMapper<T>
|
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
DataStream.map(MapFunction<T,R> mapper)
Applies a Map transformation on a
DataStream . |
Constructor and Description |
---|
StreamMap(MapFunction<IN,OUT> mapper) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
DataStream.map(MapFunction<T,R> mapper,
TypeInformation<R> evidence$7)
Creates a new DataStream by applying the given function to every element of this DataStream.
|
Modifier and Type | Class and Description |
---|---|
static class |
IterateExample.InputMap
Map the inputs so that the next Fibonacci numbers can be calculated while preserving the original input tuple A
counter is attached to the tuple and incremented in every iteration step
|
static class |
IterateExample.OutputMap
Giving back the input pair and the counter
|
static class |
IterateExample.Step
Iteration step function that calculates the next Fibonacci number
|
Modifier and Type | Method and Description |
---|---|
MapFunction<Object,Object> |
FlinkRel.getConversionMapper(TableConfig config,
boolean nullableInput,
TypeInformation<Object> inputType,
TypeInformation<Object> expectedType,
String conversionOperatorName,
scala.collection.Seq<String> fieldNames,
scala.Option<int[]> inputPojoFieldMapping) |
Modifier and Type | Class and Description |
---|---|
class |
MapRunner<IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
AggregateMapFunction<IN,OUT> |
Modifier and Type | Method and Description |
---|---|
static MapFunction<Object,Row> |
AggregateUtil.createPrepareMapFunction(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType)
Create a
MapFunction that prepares for aggregates. |
MapFunction<Object,Row> |
AggregateUtil$.createPrepareMapFunction(scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
int[] groupings,
org.apache.calcite.rel.type.RelDataType inputType)
Create a
MapFunction that prepares for aggregates. |
Modifier and Type | Class and Description |
---|---|
class |
CsvFormatter
Formats a
Row into a String with fields separated by the field delimiter. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.