Package org.apache.flink.api.java.operators

Class ProjectOperator.Projection<T>

java.lang.Object

org.apache.flink.api.java.operators.ProjectOperator.Projection<T>

Type Parameters:

T -

Enclosing class:

ProjectOperator<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>

@Internal
public static class ProjectOperator.Projection<T>
extends Object

A projection of DataSet.

Constructor Summary

Constructors

Constructor	Description
Projection(DataSet<T> ds, int[] fieldIndexes)

Method Summary

Modifier and Type	Method	Description
<T0> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple1<T0>>	projectTuple1()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>>	projectTuple10()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>>	projectTuple11()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>>	projectTuple12()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>>	projectTuple13()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>>	projectTuple14()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>>	projectTuple15()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>>	projectTuple16()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>>	projectTuple17()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>>	projectTuple18()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>>	projectTuple19()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple2<T0,T1>>	projectTuple2()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>>	projectTuple20()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>>	projectTuple21()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>>	projectTuple22()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>>	projectTuple23()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>>	projectTuple24()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>>	projectTuple25()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple3<T0,T1,T2>>	projectTuple3()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple4<T0,T1,T2,T3>>	projectTuple4()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple5<T0,T1,T2,T3,T4>>	projectTuple5()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple6<T0,T1,T2,T3,T4,T5>>	projectTuple6()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple7<T0,T1,T2,T3,T4,T5,T6>>	projectTuple7()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>>	projectTuple8()	Projects a Tuple DataSet to the previously selected fields.
<T0,T1,T2,T3,T4,T5,T6,T7,T8> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>>	projectTuple9()	Projects a Tuple DataSet to the previously selected fields.
<OUT extends org.apache.flink.api.java.tuple.Tuple> ProjectOperator<T,OUT>	projectTupleX()	Chooses a projectTupleX according to the length of fieldIndexes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Projection

public Projection(DataSet<T> ds,
                  int[] fieldIndexes)

Method Detail

projectTupleX

public <OUT extends org.apache.flink.api.java.tuple.Tuple> ProjectOperator<T,OUT> projectTupleX()

Chooses a projectTupleX according to the length of fieldIndexes.

Returns:

The projected DataSet.

See Also:

ProjectOperator.Projection

projectTuple1

public <T0> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple1<T0>> projectTuple1()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple2

public <T0,T1> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple2<T0,T1>> projectTuple2()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple3

public <T0,T1,T2> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple3<T0,T1,T2>> projectTuple3()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple4

public <T0,T1,T2,T3> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple4<T0,T1,T2,T3>> projectTuple4()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple5

public <T0,T1,T2,T3,T4> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple5<T0,T1,T2,T3,T4>> projectTuple5()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple6

public <T0,T1,T2,T3,T4,T5> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple6<T0,T1,T2,T3,T4,T5>> projectTuple6()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple7

public <T0,T1,T2,T3,T4,T5,T6> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple7<T0,T1,T2,T3,T4,T5,T6>> projectTuple7()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple8

public <T0,T1,T2,T3,T4,T5,T6,T7> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>> projectTuple8()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple9

public <T0,T1,T2,T3,T4,T5,T6,T7,T8> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>> projectTuple9()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple10

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>> projectTuple10()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple11

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> projectTuple11()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple12

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> projectTuple12()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple13

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> projectTuple13()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple14

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> projectTuple14()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple15

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> projectTuple15()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple16

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> projectTuple16()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple17

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> projectTuple17()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple18

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> projectTuple18()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple19

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> projectTuple19()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple20

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> projectTuple20()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple21

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> projectTuple21()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple22

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> projectTuple22()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple23

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> projectTuple23()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple24

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>> projectTuple24()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet

projectTuple25

public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24> ProjectOperator<T,org.apache.flink.api.java.tuple.Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>> projectTuple25()

Projects a Tuple DataSet to the previously selected fields.

Returns:

The projected DataSet.

See Also:

Tuple, DataSet