Modifier and Type | Method and Description |
---|---|
<T0> DataSource<Tuple1<T0>> |
CsvReader.types(Class<T0> type0)
Specifies the types for the CSV fields.
|
Modifier and Type | Method and Description |
---|---|
<T0> ProjectOperator<T,Tuple1<T0>> |
ProjectOperator.Projection.projectTuple1()
|
<T0> CrossOperator.ProjectCross<I1,I2,Tuple1<T0>> |
CrossOperator.CrossProjection.projectTuple1()
Projects a pair of crossed elements to a
Tuple with the previously selected
fields. |
Modifier and Type | Method and Description |
---|---|
Tuple1<T0> |
Tuple1.copy()
Shallow tuple copy.
|
static <T0> Tuple1<T0> |
Tuple1.of(T0 f0)
Creates a new tuple and assigns the given values to the tuple's fields.
|
Modifier and Type | Method and Description |
---|---|
Tuple1<T0>[] |
Tuple1Builder.build() |
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.
|
Modifier and Type | Method and Description |
---|---|
<T0> SingleOutputStreamOperator<Tuple1<T0>> |
StreamProjection.projectTuple1()
Projects a
Tuple DataStream to the previously selected fields. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.