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> 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 |
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 f0,
T1 f1,
T2 f2)
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
A POJO storing three vertex IDs.
|
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 |
---|---|
Edge<K,Tuple3<EV,D,D>> |
DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree.join(Edge<K,Tuple2<EV,D>> edge,
Vertex<K,D> vertex) |
Modifier and Type | Class and Description |
---|---|
static class |
VertexDegrees.Degrees
Wraps the vertex degree, out-degree, and in-degree.
|
Modifier and Type | Method and Description |
---|---|
DataSet<Edge<K,Tuple3<EV,VertexDegrees.Degrees,VertexDegrees.Degrees>>> |
EdgeDegreesPair.runInternal(Graph<K,VV,EV> input) |
Modifier and Type | Method and Description |
---|---|
DataSet<Edge<K,Tuple3<EV,LongValue,LongValue>>> |
EdgeDegreePair.runInternal(Graph<K,VV,EV> input) |
Modifier and Type | Class and Description |
---|---|
class |
BipartiteEdge<KT,KB,EV>
A BipartiteEdge represents a link between top and bottom vertices in a
BipartiteGraph . |
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>
Tuple storing three vertex IDs.
|
Modifier and Type | Method and Description |
---|---|
DataSet<Tuple3<K,K,K>> |
TriangleEnumerator.run(Graph<K,VV,EV> input) |
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 |
---|---|
Tuple3<String,byte[],Integer> |
PythonFunctionRunner.pollResult()
Retrieves the Python function result.
|
Tuple3<String,byte[],Integer> |
PythonFunctionRunner.takeResult()
Retrieves the Python function result, waiting if necessary until an element becomes
available.
|
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)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
FileMonitoringFunction.run(SourceFunction.SourceContext<Tuple3<String,Long,Long>> ctx)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractExternalPythonFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple)
Sends the execution result to the downstream operator.
|
void |
AbstractExternalOneInputPythonFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
AbstractExternalTwoInputPythonFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
Tuple3<String,byte[],Integer> |
BeamPythonFunctionRunner.pollResult() |
Tuple3<String,byte[],Integer> |
BeamPythonFunctionRunner.takeResult() |
Modifier and Type | Method and Description |
---|---|
static DataStream<Tuple3<String,Integer,Integer>> |
WindowJoin.runWindowJoin(DataStream<Tuple2<String,Integer>> grades,
DataStream<Tuple2<String,Integer>> salaries,
long windowSize) |
Modifier and Type | Method and Description |
---|---|
Map<String,Tuple3<String,CatalogTable,CatalogPartitionSpec>> |
HiveParserQBMetaData.getNameToDestPartition() |
Modifier and Type | Method and Description |
---|---|
void |
PythonStreamGroupWindowAggregateOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
AbstractPythonStreamGroupAggregateOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
void |
BatchArrowPythonGroupAggregateFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
BatchArrowPythonGroupWindowAggregateFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
BatchArrowPythonOverWindowAggregateFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamArrowPythonBoundedRangeOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
AbstractStreamArrowPythonBoundedRowsOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
void |
StreamArrowPythonGroupWindowAggregateFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
void |
PythonScalarFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
void |
ArrowPythonScalarFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Modifier and Type | Method and Description |
---|---|
void |
PythonTableFunctionOperator.emitResult(Tuple3<String,byte[],Integer> resultTuple) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.