Modifier and Type | Class and Description |
---|---|
class |
TableInputFormat<T extends Tuple>
InputFormat subclass that wraps the access for HTables. |
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
DataSet.project(int... fieldIndexes)
Applies a Project transformation on a
Tuple DataSet .Note: Only Tuple DataSets can be projected using field indexes. The transformation projects each Tuple of the DataSet onto a (sub)set of fields. Additional fields can be added to the projection by calling DataSet.project(int[]) . |
Modifier and Type | Class and Description |
---|---|
class |
SelectByMaxFunction<T extends Tuple> |
class |
SelectByMinFunction<T extends Tuple> |
Modifier and Type | Class and Description |
---|---|
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
Modifier and Type | Method and Description |
---|---|
<T extends Tuple> |
CsvReader.tupleType(Class<T> targetType)
Configures the reader to read the CSV data and parse it to the given type.
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregateOperator.AggregatingUdf<T extends Tuple> |
static class |
CrossOperator.ProjectCross<I1,I2,OUT extends Tuple>
|
static class |
CrossOperator.ProjectCrossFunction<T1,T2,R extends Tuple> |
static class |
JoinOperator.ProjectFlatJoinFunction<T1,T2,R extends Tuple> |
static class |
JoinOperator.ProjectJoin<I1,I2,OUT extends Tuple>
|
class |
ProjectOperator<IN,OUT extends Tuple>
This operator represents the application of a projection operation on a data set, and the
result data set produced by the function.
|
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
JoinOperator.DefaultJoin.projectFirst(int... firstFieldIndexes)
|
<OUT extends Tuple> |
JoinOperator.ProjectJoin.projectFirst(int... firstFieldIndexes)
|
<OUT extends Tuple> |
CrossOperator.DefaultCross.projectFirst(int... firstFieldIndexes)
|
<OUT extends Tuple> |
CrossOperator.ProjectCross.projectFirst(int... firstFieldIndexes)
|
<OUT extends Tuple> |
JoinOperator.DefaultJoin.projectSecond(int... secondFieldIndexes)
|
<OUT extends Tuple> |
JoinOperator.ProjectJoin.projectSecond(int... secondFieldIndexes)
|
<OUT extends Tuple> |
CrossOperator.DefaultCross.projectSecond(int... secondFieldIndexes)
|
<OUT extends Tuple> |
CrossOperator.ProjectCross.projectSecond(int... secondFieldIndexes)
|
<OUT extends Tuple> |
ProjectOperator.Projection.projectTupleX()
Chooses a projectTupleX according to the length of
ProjectOperator.Projection.fieldIndexes |
<OUT extends Tuple> |
JoinOperator.JoinProjection.projectTupleX()
Chooses a projectTupleX according to the length of
JoinOperator.JoinProjection.fieldIndexes |
<OUT extends Tuple> |
CrossOperator.CrossProjection.projectTupleX()
Chooses a projectTupleX according to the length of
CrossOperator.CrossProjection.fieldIndexes |
<OUT extends Tuple> |
JoinOperator.ProjectJoin.types(Class<?>... types)
Deprecated.
|
<OUT extends Tuple> |
CrossOperator.ProjectCross.types(Class<?>... types)
Deprecated.
|
<R extends Tuple> |
ProjectOperator.types(Class<?>... types)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
PlanProjectOperator<T,R extends Tuple> |
static class |
PlanProjectOperator.MapProjector<T extends Tuple,R extends Tuple> |
static class |
PlanProjectOperator.MapProjector<T extends Tuple,R extends Tuple> |
Modifier and Type | Method and Description |
---|---|
R |
PlanProjectOperator.MapProjector.map(Tuple inTuple) |
Modifier and Type | Class and Description |
---|---|
class |
TupleSummaryAggregator<R extends Tuple>
Aggregate tuples using an array of aggregators, one for each "column" or position within the Tuple.
|
Modifier and Type | Method and Description |
---|---|
static <R extends Tuple> |
SummaryAggregatorFactory.create(TupleTypeInfoBase<?> inType) |
Modifier and Type | Method and Description |
---|---|
void |
TupleSummaryAggregator.aggregate(Tuple value) |
Modifier and Type | Method and Description |
---|---|
void |
TupleSummaryAggregator.combine(Aggregator<Tuple,R> other) |
Modifier and Type | Class and Description |
---|---|
class |
Tuple0
A tuple with 0 fields.
|
class |
Tuple1<T0>
A tuple with 1 fields.
|
class |
Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>
A tuple with 10 fields.
|
class |
Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>
A tuple with 11 fields.
|
class |
Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>
A tuple with 12 fields.
|
class |
Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>
A tuple with 13 fields.
|
class |
Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>
A tuple with 14 fields.
|
class |
Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>
A tuple with 15 fields.
|
class |
Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>
A tuple with 16 fields.
|
class |
Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>
A tuple with 17 fields.
|
class |
Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>
A tuple with 18 fields.
|
class |
Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>
A tuple with 19 fields.
|
class |
Tuple2<T0,T1>
A tuple with 2 fields.
|
class |
Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>
A tuple with 20 fields.
|
class |
Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>
A tuple with 21 fields.
|
class |
Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>
A tuple with 22 fields.
|
class |
Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>
A tuple with 23 fields.
|
class |
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>
A tuple with 24 fields.
|
class |
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>
A tuple with 25 fields.
|
class |
Tuple3<T0,T1,T2>
A tuple with 3 fields.
|
class |
Tuple4<T0,T1,T2,T3>
A tuple with 4 fields.
|
class |
Tuple5<T0,T1,T2,T3,T4>
A tuple with 5 fields.
|
class |
Tuple6<T0,T1,T2,T3,T4,T5>
A tuple with 6 fields.
|
class |
Tuple7<T0,T1,T2,T3,T4,T5,T6>
A tuple with 7 fields.
|
class |
Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>
A tuple with 8 fields.
|
class |
Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>
A tuple with 9 fields.
|
Modifier and Type | Method and Description |
---|---|
abstract <T extends Tuple> |
Tuple.copy()
Shallow tuple copy.
|
Modifier and Type | Method and Description |
---|---|
static Class<? extends Tuple> |
Tuple.getTupleClass(int arity)
Gets the class corresponding to the tuple of the given arity (dimensions).
|
Modifier and Type | Class and Description |
---|---|
class |
TupleTypeInfo<T extends Tuple>
A
TypeInformation for the tuple types of the Java API. |
Modifier and Type | Method and Description |
---|---|
static <X extends Tuple> |
TupleTypeInfo.getBasicAndBasicValueTupleTypeInfo(Class<?>... basicTypes) |
static <X extends Tuple> |
TupleTypeInfo.getBasicTupleTypeInfo(Class<?>... basicTypes) |
Modifier and Type | Class and Description |
---|---|
class |
TupleComparator<T extends Tuple> |
class |
TupleSerializer<T extends Tuple> |
Modifier and Type | Method and Description |
---|---|
static <R extends Tuple,T extends Tuple> |
DataSetUtils.summarize(DataSet<T> input)
Summarize a DataSet of Tuples by collecting single pass statistics for all columns
Example usage:
|
static <R extends Tuple,T extends Tuple> |
DataSetUtils.summarize(DataSet<T> input)
Summarize a DataSet of Tuples by collecting single pass statistics for all columns
Example usage:
|
Modifier and Type | Class and Description |
---|---|
class |
CassandraInputFormat<OUT extends Tuple>
InputFormat to read data from Apache Cassandra and generate $
Tuple . |
class |
CassandraOutputFormat<OUT extends Tuple>
OutputFormat to write
Tuple into Apache Cassandra. |
Modifier and Type | Class and Description |
---|---|
static class |
EnumTrianglesDataTypes.Edge |
static class |
EnumTrianglesDataTypes.EdgeWithDegrees |
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.
|
static class |
TPCHQuery3.Customer |
static class |
TPCHQuery3.Lineitem |
static class |
TPCHQuery3.Order |
static class |
TPCHQuery3.ShippingPriorityItem |
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. |
class |
Triplet<K,VV,EV>
A Triplet stores and retrieves the edges along with their corresponding source and target vertices.
|
class |
Vertex<K,V>
Represents the graph's nodes.
|
Modifier and Type | Class and Description |
---|---|
static class |
VertexDegrees.Degrees
Wraps the vertex degree, out-degree, and in-degree.
|
Modifier and Type | Class and Description |
---|---|
class |
BipartiteEdge<KT,KB,EV>
A BipartiteEdge represents a link between top and bottom vertices
in a
BipartiteGraph . |
class |
Projection<KC,VVC,VV,EV>
The edge value of a full bipartite projection contains:
the ID and vertex value of the connecting vertex
the vertex value for the source and target vertex
both edge values from the bipartite edges
|
Modifier and Type | Class and Description |
---|---|
class |
Neighbor<VV,EV>
This class represents a
<sourceVertex, edge> pair
This is a wrapper around Tuple2<VV, EV> for convenience in the GatherFunction |
Modifier and Type | Class and Description |
---|---|
static class |
Summarization.EdgeValue<EV>
Value that is stored at a summarized edge.
|
static class |
Summarization.VertexGroupItem<K,VGV>
Represents a single vertex in a vertex group.
|
static class |
Summarization.VertexValue<VV>
Value that is stored at a summarized vertex.
|
static class |
Summarization.VertexWithRepresentative<K>
Represents a vertex identifier and its corresponding vertex group identifier.
|
static class |
TriangleEnumerator.EdgeWithDegrees<K> |
static class |
TriangleEnumerator.Triad<K> |
Modifier and Type | Class and Description |
---|---|
static class |
TriangleListing.Result<T>
Wraps the vertex type to encapsulate results from the Triangle Listing algorithm.
|
Modifier and Type | Class and Description |
---|---|
static class |
LocalClusteringCoefficient.Result<T>
Wraps the vertex type to encapsulate results from the Local Clustering Coefficient algorithm.
|
Modifier and Type | Class and Description |
---|---|
static class |
HITS.Result<T>
Wraps the vertex type to encapsulate results from the HITS algorithm.
|
Modifier and Type | Class and Description |
---|---|
static class |
AdamicAdar.Result<T>
Wraps the vertex type to encapsulate results from the Adamic-Adar algorithm.
|
static class |
JaccardIndex.Result<T>
Wraps the vertex type to encapsulate results from the jaccard index algorithm.
|
Modifier and Type | Method and Description |
---|---|
static Tuple |
PythonReceiver.createTuple(int size) |
Modifier and Type | Method and Description |
---|---|
byte[] |
SerializationUtils.TupleSerializer.serializeWithoutTypeInfo(Tuple value) |
Constructor and Description |
---|
TupleSerializer(Tuple value) |
Modifier and Type | Method and Description |
---|---|
<R extends Tuple> |
DataStream.project(int... fieldIndexes)
Initiates a Project transformation on a
Tuple DataStream .Note: Only Tuple DataStreams can be projected. |
<OUT extends Tuple> |
StreamProjection.projectTupleX()
Chooses a projectTupleX according to the length of
StreamProjection.fieldIndexes |
<X extends Tuple> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Writes a DataStream to the file specified by the path parameter.
|
Modifier and Type | Method and Description |
---|---|
KeyedStream<T,Tuple> |
DataStream.keyBy(int... fields)
Partitions the operator state of a
DataStream by the given key positions. |
KeyedStream<T,Tuple> |
DataStream.keyBy(String... fields)
Partitions the operator state of a
DataStream using field expressions. |
Modifier and Type | Method and Description |
---|---|
double[] |
FieldsFromTuple.extract(Tuple in) |
OUT |
FieldFromTuple.extract(Tuple in) |
Object[] |
ArrayFromTuple.extract(Tuple in) |
Modifier and Type | Class and Description |
---|---|
class |
StreamProject<IN,OUT extends Tuple> |
Modifier and Type | Method and Description |
---|---|
KeyedStream<T,Tuple> |
DataStream.keyBy(scala.collection.Seq<Object> fields)
Groups the elements of a DataStream by the given key positions (for tuple/array types) to
be used with grouped operators like grouped reduce or grouped aggregations.
|
KeyedStream<T,Tuple> |
DataStream.keyBy(String firstField,
scala.collection.Seq<String> otherFields)
Groups the elements of a DataStream by the given field expressions to
be used with grouped operators like grouped reduce or grouped aggregations.
|
Modifier and Type | Class and Description |
---|---|
static class |
CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> |
class |
CassandraTupleSink<IN extends Tuple>
Flink Sink to save data into a Cassandra cluster.
|
class |
CassandraTupleWriteAheadSink<IN extends Tuple>
Sink that emits its input elements into a Cassandra database.
|
Modifier and Type | Method and Description |
---|---|
static <IN,T extends Tuple> |
CassandraSink.addSink(DataStream<IN> input)
Writes a DataStream into a Cassandra database.
|
Modifier and Type | Class and Description |
---|---|
static class |
GroupedProcessingTimeWindowExample.FirstFieldKeyExtractor<Type extends Tuple,Key> |
Modifier and Type | Method and Description |
---|---|
Tuple |
KeySelectorUtil.ComparableKeySelector.getKey(IN value) |
Tuple |
KeySelectorUtil.ArrayKeySelector.getKey(IN value) |
Modifier and Type | Method and Description |
---|---|
TypeInformation<Tuple> |
KeySelectorUtil.ComparableKeySelector.getProducedType() |
TypeInformation<Tuple> |
KeySelectorUtil.ArrayKeySelector.getProducedType() |
static <X> KeySelector<X,Tuple> |
KeySelectorUtil.getSelectorForKeys(Keys<X> keys,
TypeInformation<X> typeInfo,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalAggregateTimeWindowFunction.apply(Tuple key,
TimeWindow window,
Iterable<Row> records,
Collector<Row> out) |
void |
AggregateTimeWindowFunction.apply(Tuple key,
TimeWindow window,
Iterable<Row> input,
Collector<Row> out) |
void |
IncrementalAggregateWindowFunction.apply(Tuple key,
W window,
Iterable<Row> records,
Collector<Row> out)
Calculate aggregated values output by aggregate buffer, and set them into output
Row based on the mapping relation between intermediate aggregate data and output data.
|
void |
AggregateWindowFunction.apply(Tuple key,
W window,
Iterable<Row> input,
Collector<Row> out) |
Modifier and Type | Class and Description |
---|---|
static class |
JavaProgramTestBase.TupleComparator<T extends Tuple> |
static class |
TestBaseUtils.TupleComparator<T extends Tuple> |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.