Modifier and Type | Method and Description |
---|---|
<T0,T1,T2> DataSource<Tuple3<T0,T1,T2>> |
CsvReader.types(Class<T0> type0,
Class<T1> type1,
Class<T2> type2)
Specifies the types for the CSV fields.
|
Modifier and Type | Method and Description |
---|---|
static <T,K1,K2> Operator<Tuple3<K1,K2,T>> |
KeyFunctions.appendKeyExtractor(Operator<T> input,
Keys.SelectorFunctionKeys<T,K1> key1,
Keys.SelectorFunctionKeys<T,K2> key2) |
static <T,K1,K2> TypeInformation<Tuple3<K1,K2,T>> |
KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K1> key1,
Keys.SelectorFunctionKeys<T,K2> key2) |
<T0,T1,T2> ProjectOperator<T,Tuple3<T0,T1,T2>> |
ProjectOperator.Projection.projectTuple3()
|
<T0,T1,T2> JoinOperator.ProjectJoin<I1,I2,Tuple3<T0,T1,T2>> |
JoinOperator.JoinProjection.projectTuple3()
Projects a pair of joined elements to a
Tuple with the previously selected fields. |
<T0,T1,T2> CrossOperator.ProjectCross<I1,I2,Tuple3<T0,T1,T2>> |
CrossOperator.CrossProjection.projectTuple3()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
Modifier and Type | Method and Description |
---|---|
Tuple3<K1,K2,T> |
TwoKeyExtractingMapper.map(T value) |
Modifier and Type | Method and Description |
---|---|
void |
PlanUnwrappingSortedGroupCombineOperator.TupleUnwrappingGroupReducer.combine(Iterable<Tuple3<K1,K2,IN>> values,
Collector<OUT> out) |
void |
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer.combine(Iterable<Tuple3<K1,K2,IN>> values,
Collector<Tuple3<K1,K2,IN>> out) |
void |
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer.combine(Iterable<Tuple3<K1,K2,IN>> values,
Collector<Tuple3<K1,K2,IN>> out) |
void |
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer.reduce(Iterable<Tuple3<K1,K2,IN>> values,
Collector<OUT> out) |
void |
PlanUnwrappingSortedReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer.reduce(Iterable<Tuple3<K1,K2,IN>> values,
Collector<OUT> out) |
void |
Tuple3WrappingCollector.set(Collector<Tuple3<K1,K2,IN>> wrappedCollector) |
void |
Tuple3UnwrappingIterator.set(Iterator<Tuple3<K1,K2,T>> iterator) |
Constructor and Description |
---|
PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K1> groupingKey,
Keys.SelectorFunctionKeys<IN,K2> sortingKey,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey) |
PlanUnwrappingSortedReduceGroupOperator(GroupReduceFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K1> groupingKey,
Keys.SelectorFunctionKeys<IN,K2> sortingKey,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey,
boolean combinable) |
Modifier and Type | Method and Description |
---|---|
Tuple3<T0,T1,T2> |
Tuple3.copy()
Shallow tuple copy.
|
static <T0,T1,T2> Tuple3<T0,T1,T2> |
Tuple3.of(T0 value0,
T1 value1,
T2 value2)
Creates a new tuple and assigns the given values to the tuple's fields.
|
Modifier and Type | Method and Description |
---|---|
Tuple3<T0,T1,T2>[] |
Tuple3Builder.build() |
Modifier and Type | Method and Description |
---|---|
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CountAppender.map(Tuple2<Integer,KMeans.Point> t) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Modifier and Type | Method and Description |
---|---|
KMeans.Centroid |
KMeans.CentroidAverager.map(Tuple3<Integer,KMeans.Point,Long> value) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Tuple3<Integer,KMeans.Point,Long> |
KMeans.CentroidAccumulator.reduce(Tuple3<Integer,KMeans.Point,Long> val1,
Tuple3<Integer,KMeans.Point,Long> val2) |
Modifier and Type | Class and Description |
---|---|
static class |
EnumTrianglesDataTypes.Triad |
Modifier and Type | Class and Description |
---|---|
static class |
EmptyFieldsCountAccumulator.StringTriple
It is recommended to use POJOs (Plain old Java objects) instead of TupleX for
data types with many fields.
|
Modifier and Type | Method and Description |
---|---|
boolean |
WebLogAnalysis.FilterByRank.filter(Tuple3<Integer,String,Integer> value)
Filters for records of the rank relation where the rank is greater
than the given threshold.
|
Modifier and Type | Method and Description |
---|---|
void |
WebLogAnalysis.AntiJoinVisits.coGroup(Iterable<Tuple3<Integer,String,Integer>> ranks,
Iterable<Tuple1<String>> visits,
Collector<Tuple3<Integer,String,Integer>> out)
If the visit iterator is empty, all pairs of the rank iterator are emitted.
|
void |
WebLogAnalysis.AntiJoinVisits.coGroup(Iterable<Tuple3<Integer,String,Integer>> ranks,
Iterable<Tuple1<String>> visits,
Collector<Tuple3<Integer,String,Integer>> out)
If the visit iterator is empty, all pairs of the rank iterator are emitted.
|
Modifier and Type | Method and Description |
---|---|
static DataSet<Tuple3<Integer,String,Integer>> |
WebLogData.getRankDataSet(ExecutionEnvironment env) |
Modifier and Type | Class and Description |
---|---|
class |
Edge<K,V>
An Edge represents a link between two
vertices ,
the source and the target and can carry an attached value. |
Modifier and Type | Method and Description |
---|---|
DataSet<Tuple3<K,K,EV>> |
Graph.getEdgesAsTuple3() |
Modifier and Type | Method and Description |
---|---|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<Tuple2<K,VV>> vertices,
DataSet<Tuple3<K,K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for vertices and
Tuple3 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.
|
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.
|
void |
NeighborsFunction.iterateNeighbors(Iterable<Tuple3<K,Edge<K,EV>,Vertex<K,VV>>> neighbors,
Collector<O> out)
This method is called per vertex and can iterate over all of its neighbors
with the specified direction.
|
<T> Graph<K,VV,EV> |
Graph.joinWithEdges(DataSet<Tuple3<K,K,T>> inputDataSet,
EdgeJoinFunction<EV,T> edgeJoinFunction)
Joins the edge DataSet with an input DataSet on the composite key of both
source and target IDs and applies a user-defined transformation on the values
of the matched records.
|
Modifier and Type | Method and Description |
---|---|
void |
MusicProfiles.FilterOutMismatches.coGroup(Iterable<Tuple3<String,String,Integer>> triplets,
Iterable<Tuple1<String>> invalidSongs,
Collector<Tuple3<String,String,Integer>> out) |
void |
MusicProfiles.FilterOutMismatches.coGroup(Iterable<Tuple3<String,String,Integer>> triplets,
Iterable<Tuple1<String>> invalidSongs,
Collector<Tuple3<String,String,Integer>> out) |
Modifier and Type | Method and Description |
---|---|
static List<Tuple3<Long,Long,Long>> |
TriangleCountData.getListOfTriangles() |
static DataSet<Tuple3<String,String,Integer>> |
MusicProfilesData.getUserSongTriplets(ExecutionEnvironment env) |
Modifier and Type | Class and Description |
---|---|
static class |
TriangleEnumerator.Triad<K> |
Modifier and Type | Method and Description |
---|---|
DataSet<Tuple3<K,K,K>> |
TriangleEnumerator.run(Graph<K,VV,EV> input) |
Modifier and Type | Method and Description |
---|---|
void |
NeighborsFunction.iterateNeighbors(Iterable<Tuple3<K,Edge<K,EV>,Vertex<K,VV>>> neighbors,
Collector<T> out) |
Modifier and Type | Method and Description |
---|---|
Tuple3<K,K,EV> |
EdgeToTuple3Map.map(Edge<K,EV> edge) |
Modifier and Type | Method and Description |
---|---|
Edge<K,EV> |
Tuple3ToEdgeMap.map(Tuple3<K,K,EV> tuple) |
Modifier and Type | Method and Description |
---|---|
<T0,T1,T2> SingleOutputStreamOperator<Tuple3<T0,T1,T2>> |
StreamProjection.projectTuple3()
Projects a
Tuple DataStream to the previously selected fields. |
Modifier and Type | Method and Description |
---|---|
void |
FileReadFunction.flatMap(Tuple3<String,Long,Long> value,
Collector<String> out) |
Modifier and Type | Method and Description |
---|---|
void |
FileMonitoringFunction.run(SourceFunction.SourceContext<Tuple3<String,Long,Long>> ctx) |
Modifier and Type | Method and Description |
---|---|
Tuple3<String,Integer,Integer> |
WindowJoin.MyJoinFunction.join(Tuple3<Long,String,Integer> first,
Tuple3<Long,String,Integer> second) |
Tuple3<Long,String,Integer> |
WindowJoin.MySourceMap.map(String line) |
Modifier and Type | Method and Description |
---|---|
Tuple3<String,Integer,Integer> |
WindowJoin.MyJoinFunction.join(Tuple3<Long,String,Integer> first,
Tuple3<Long,String,Integer> second) |
Tuple3<String,Integer,Integer> |
WindowJoin.MyJoinFunction.join(Tuple3<Long,String,Integer> first,
Tuple3<Long,String,Integer> second) |
Modifier and Type | Method and Description |
---|---|
void |
WindowJoin.GradeSource.run(SourceFunction.SourceContext<Tuple3<Long,String,Integer>> ctx) |
void |
WindowJoin.SalarySource.run(SourceFunction.SourceContext<Tuple3<Long,String,Integer>> ctx) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.